当前位置：文档之家 › php中socket的用法详解

php中socket的用法详解

  • 格式：pdf
  • 大小：56.78 KB
  • 文档页数：2

php中socket的⽤法详解

本⽂实例详细讲述了php中socket的⽤法，分享给⼤家供⼤家参考。具体⽤法如下：

⼀、开启socket

phpinfo();查看是否开启了socket扩展，否则在php.ini中开启。

⼆、服务器端代码的写法

复制代码 代码如下:

error_reporting(E_ALL);

set_time_limit(0);

//ob_implicit_flush();

$address = '127.0.0.1';

$port = 10005;

//创建端⼝

if( ($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) === false) {

echo "socket_create() failed :reason:" . socket_strerror(socket_last_error()) . "\n";

}

//绑定

if (socket_bind($sock, $address, $port) === false) {

echo "socket_bind() failed :reason:" . socket_strerror(socket_last_error($sock)) . "\n";

}

//监听

if (socket_listen($sock, 5) === false) {

echo "socket_bind() failed :reason:" . socket_strerror(socket_last_error($sock)) . "\n";

}

do {

//得到⼀个链接

if (($msgsock = socket_accept($sock)) === false) {

echo "socket_accepty() failed :reason:".socket_strerror(socket_last_error($sock)) . "\n";

break;

}

//welcome 发送到客户端

$msg = "server send:welcome
";

socket_write($msgsock, $msg, strlen($msg));

echo 'read client message\n';

$buf = socket_read($msgsock, 8192);

$talkback = "received message:$buf\n";

echo $talkback;

if (false === socket_write($msgsock, $talkback, strlen($talkback))) {

echo "socket_write() failed reason:" . socket_strerror(socket_last_error($sock)) ."\n";

} else {

echo 'send success';

}

socket_close($msgsock);

} while(true);

//关闭socket

socket_close($sock);

>

服务器端需要在cli模式是执⾏，有可能cli模式下php.ini⽂件载⼊的不⼀样可以像如下输出：

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

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

三、客户端

复制代码 代码如下:

//error_reporting(E_ALL);

echo "

tcp/ip connection

\n";

$service_port = 10005;

$address = '127.0.0.1';

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

if ($socket === false) {

echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";

} else {

echo "OK. \n";

}

echo "Attempting to connect to '$address' on port '$service_port'...";

$result = socket_connect($socket, $address, $service_port);

if($result === false) {

echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";

} else {

echo "OK \n";

}

$in = "HEAD / http/1.1\r\n";

$in .= "HOST: localhost \r\n";

$in .= "Connection: close\r\n\r\n";

$out = "";

echo "sending http head request ...";

socket_write($socket, $in, strlen($in));

echo "OK\n";

echo "Reading response:\n\n";

while ($out = socket_read($socket, 8192)) {

echo $out;

}

echo "closeing socket..";

socket_close($socket);

echo "ok .\n\n";

执⾏结果如下： server:client:

希望本⽂所述对⼤家的PHP程序设计有所帮助。

合集下载

ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解

ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解

ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解

本⽂实例讲述了ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例。分享给⼤家供⼤家参考，具体如下：

ThinkPHP使⽤Swoole需要安装 think-swoole Composer包，前提系统已经安装好了Swoole PECL 拓展（相关⽂章：）

在tp5的项⽬根⽬录下执⾏composer命令安装think-swoole：composer require topthink/think-swoole安装成功：

话不多说，直接上代码：

新建WebSocket.php控制器：

（监听端⼝要确认服务器放⾏，宝塔环境还需要添加安全组规则）

namespace app\home\controller;

use think\swoole\Server;

class WebSocket extends Server

{

protected $host = '0.0.0.0'; //监听所有地址

protected $port = 9501; //监听9501端⼝

protected $serverType = 'socket';

protected $option = [

'worker_num'=> 4, //设置启动的Worker进程数

'daemonize' => false, //守护进程化（上线改为true）

'backlog' => 128, //Listen队列长度

'dispatch_mode' => 2, //固定模式，保证同⼀个连接发来的数据只会被同⼀个worker处理

//⼼跳检测：每60秒遍历所有连接，强制关闭10分钟内没有向服务器发送任何数据的连接

'heartbeat_check_interval' => 60,

'heartbeat_idle_time' => 600

];

//建⽴连接时回调函数

PHP的Socket编程

PHP的Socket编程

PHP的Socket编程

分类： web 开发（div/css） 其他 php(dede thinkphp)2013-01-05 11:55 23人阅读 评论(0) 收藏 举报

客户端发送指令接受服务器反馈信息。

[php] view plaincopyprint?

1. set_time_limit(0);

2.

3. $host = "127.0.0.1";

4. $port = 2046;

5.

6. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create socket\n"); // 创建一个Socket

7.

8. $connection = socket_connect($socket, $host, $port) or die("Could not connet server\n");

// 连接

9.

10. socket_write($socket, "time") or die("Write failed\n"); // 数据传送 向服务器发送消息

11.

12. while ($buffer = socket_read($socket, 1024, PHP_NORMAL_READ)) {

13. echo("Data sent was: time\nResponse was:" . $buffer . "\n");

14. }

15. socket_close($socket);

服务端 创建socket服务监听，接受服务端指令返回对应信息关闭服务

[php] view plaincopyprint?

1. set_time_limit(0);

2.

3. $host = "127.0.0.1";

php面试socket.io原理

php面试socket.io原理

一、什么是PHP面试中的socket.io原理

在PHP面试中，socket.io原理是一个常见的面试题目。Socket.io是一种支持实时、双向通信的协议，它能够使客户端和服务器端建立长连接，并实现实时的数据传输。在面试中，了解socket.io的原理和工作机制是非常重要的。

二、socket.io的工作原理

1. 客户端和服务器端都可以使用socket.io进行通信，通过在客户端和服务器端分别安装socket.io的库，就可以实现socket.io的双向通信。

2. 在客户端，通过创建一个socket.io实例，并连接到服务器端指定的位置区域和端口，就可以建立客户端和服务器端的连接。

3. 一旦连接建立成功，客户端和服务器端就可以通过socket.io进行实时的数据传输。客户端可以向服务器端发送消息，服务器端也可以向客户端发送消息。

4. socket.io基于事件驱动的机制，可以监听到客户端和服务器端发送的各种事件，并进行相应的处理。

5. 在服务器端，通过监听客户端的连接事件，可以实时地获取客户端的连接信息，并进行相应的处理。服务器端也可以向指定的客户端发送消息，实现实时的双向通信。

6. 在实际的应用中，socket.io可以用于实时的聊天应用、实时数据监控和实时通知等场景，实现了实时性和高效性。

三、socket.io在PHP中的应用

1. 在PHP中，可以使用socket.io的PHP库或者第三方库来实现socket.io的功能。通过在PHP中安装相关的库，就可以在PHP项目中使用socket.io进行实时通信。

2. 在PHP中使用socket.io可以使项目实现更加实时、高效的数据传输，尤其是在需要实时更新数据的场景下，如在线游戏、在线聊天室、实时监控系统等。

3. 在PHP中，使用socket.io需要注意的是，socket.io是基于事件驱动的机制，需要合理地处理事件和消息的传递，以保证通信的稳定和可靠。

streamsocket用法

streamsocket用法

`stream_socket` 是 PHP 中用于操作网络套接字的一系列函数。这些函数提供了一种相对低级别的网络编程接口，允许开发者创建和操作网络连接，包括 TCP、UDP 连接等。使用 `stream_socket` 系列函数，可以实现服务器和客户端之间的数据通信。

### 基本用法

#### 创建服务器 (TCP)

```php

// 创建一个服务器端套接字

$server = stream_socket_server(");

if ($server === false) {

throw new UnexpectedValueException("Could not bind to socket: $errorMessage");

}

while ($client = @stream_socket_accept($server)) {

fwrite($client, 'Hello World!' . PHP_EOL);

fclose($client);

}

fclose($server);

```

这段代码创建了一个监听在本机 8000 端口的 TCP 服务器。当客户端连接时，它发送

"Hello World!" 给客户端，然后关闭连接。

#### 创建客户端 (TCP)

```php

// 连接到服务器

$client = stream_socket_client(");

if ($client === false) {

throw new UnexpectedValueException("Failed to connect: $errorMessage");

}

echo stream_get_contents($client);

fclose($client);

```

这段代码尝试连接到本机的 8000 端口上的服务器，并读取从服务器接收到的数据。