Go语言视频零基础入门到精通

admin

一、开启socket
phpinfo();查看是否开启了socket扩展，否则在php.ini中开启。
二、服务器端代码的写法

1. <?php
2. error_reporting(E_ALL);
3. set_time_limit(0);
4. //ob_implicit_flush();
6. $address = "127.0.0.1";
7. $port = 10005;
8. //创建端口
9. if( ($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {
10.         echo "socket_create() failed :reason:" . socket_strerror(socket_last_error()) . "\n";
11. }
13. //绑定
14. if (socket_bind($sock, $address, $port) === false) {
15.         echo "socket_bind() failed :reason:" . socket_strerror(socket_last_error($sock)) . "\n";
16. }
18. //监听
19. if (socket_listen($sock, 5) === false) {
20.         echo "socket_bind() failed :reason:" . socket_strerror(socket_last_error($sock)) . "\n";
21. }
23. do {
24.         //得到一个链接
25.         if (($msgsock = socket_accept($sock)) === false) {
26.                 echo "socket_accepty() failed :reason:".socket_strerror(socket_last_error($sock)) . "\n";
27.                 break;
28.         }
29.         //welcome  发送到客户端
30.         $msg = "<font color="red">server send:welcome</font><br/>";
31.         socket_write($msgsock, $msg, strlen($msg));
32.         echo "read client message\n";
33.         $buf = socket_read($msgsock, 8192);
34.         $talkback = "received message:$buf\n";
35.         echo $talkback;
36.         if (false === socket_write($msgsock, $talkback, strlen($talkback))) {
37.                 echo "socket_write() failed reason:" . socket_strerror(socket_last_error($sock)) ."\n";
38.         } else {
39.                 echo "send success";
40.         }
41.         socket_close($msgsock);
42. } while(true);
43. //关闭socket
44. socket_close($sock);
47. ?>

复制代码

服务器端需要在cli模式是执行，有可能cli模式下php.ini文件载入的不一样
可以像如下输出

这时候在zhoxh目录下就有个tem.text文件。查看 Configuration File (php.ini) Path => C:\WINDOWS 。不是我的php.ini 文件，这说明调用的php.ini文件时错误的。这时候我们要指定php.ini文件命令如下


注意的是我的php可以直接执行时配置了环境变量。

三、客户端

1. <?php
2. //error_reporting(E_ALL);
3. [url=http://www.php.net/echo]echo[/url] "<h2>tcp/ip connection </h2>\n";
4. $service_port = 10005;
5. $address = "127.0.0.1";
7. $[url=http://www.php.net/socket]socket[/url] = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
8. [url=http://www.php.net/if]if[/url] ($[url=http://www.php.net/socket]socket[/url] === [url=http://www.php.net/false]false[/url]) {
9.         [url=http://www.php.net/echo]echo[/url] "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
10. } [url=http://www.php.net/else]else[/url] {
11.         [url=http://www.php.net/echo]echo[/url] "OK. \n";
12. }
14. [url=http://www.php.net/echo]echo[/url] "Attempting to connect to "$address" on port "$service_port"...";
15. $result = socket_connect($[url=http://www.php.net/socket]socket[/url], $address, $service_port);
16. [url=http://www.php.net/if]if[/url]($result === [url=http://www.php.net/false]false[/url]) {
17.         [url=http://www.php.net/echo]echo[/url] "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($[url=http://www.php.net/socket]socket[/url])) . "\n";
18. } [url=http://www.php.net/else]else[/url] {
19.         [url=http://www.php.net/echo]echo[/url] "OK \n";
20. }
21. $in = "HEAD / http/1.1\r\n";
22. $in .= "HOST: localhost \r\n";
23. $in .= "Connection: close\r\n\r\n";
24. $out = "";
25. [url=http://www.php.net/echo]echo[/url] "sending http head request ...";
26. socket_write($[url=http://www.php.net/socket]socket[/url], $in, [url=http://www.php.net/strlen]strlen[/url]($in));
27. [url=http://www.php.net/echo]echo[/url]  "OK\n";
29. [url=http://www.php.net/echo]echo[/url] "Reading response:\n\n";
30. [url=http://www.php.net/while]while[/url] ($out = socket_read($[url=http://www.php.net/socket]socket[/url], 8192)) {
31.         [url=http://www.php.net/echo]echo[/url] $out;
32. }
33. [url=http://www.php.net/echo]echo[/url] "closeing socket..";
34. socket_close($[url=http://www.php.net/socket]socket[/url]);
35. [url=http://www.php.net/echo]echo[/url] "ok .\n\n";

复制代码

复制代码

1. 执行结果：

复制代码

1. server:

复制代码

client: