PHP Socket 编程实现

WBOY
Freigeben: 2016-07-25 08:45:17
Original
900 Leute haben es durchsucht

最近在做的项目有一项需要耗时任务在后台运行的功能,虽然PHP并不是非常适合做常驻后台的守护进程,但是由于项目主要代码都是基于PHP实现,如 果运行在后台的守护进程改换别的语言会非常不方便。所以不可避免会涉及到Web端和Daemon部分的通信,Socket是一个不错的方式。

Socket是什么

socket的英文原义是“孔”或“插座”。作为BSD UNIX的进程通信机制,取后一种意思。通常也称作”套接字”,用于描述IP地址和端口,是一个通信链的句柄。在Internet上的主机一般运行了多个 服务软件,同时提供几种服务。每种服务都打开一个Socket,并绑定到一个端口上,不同的端口对应于不同的服务。

以上内容来自百度百科

简单说来,socket可以帮助不同的服务在不同的端口进行通信。

PHP中的实现

### 服务端

  1. set_time_limit(0);
  2. // 设置主机和端口
  3. $host = "127.0.0.1";
  4. $port = 12387;
  5. // 创建一个tcp流
  6. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
  7. or die("socket_create() failed:" . socket_strerror(socket_last_error()));
  8. // 设置阻塞模式
  9. socket_set_block($socket)
  10. or die("socket_set_block() failed:" . socket_strerror(socket_last_error()));
  11. // 绑定到端口
  12. socket_bind($socket, $host, $port)
  13. or die("socket_bind() failed:" . socket_strerror(socket_last_error()));
  14. // 开始监听
  15. socket_listen($socket, 4)
  16. or die("socket_listen() failed:" . socket_strerror(socket_last_error()));
  17. echo "Binding the socket on $host:$port ... \n";
  18. while (true) {
  19. // 接收连接请求并调用一个子连接Socket来处理客户端和服务器间的信息
  20. if (($msgsock = socket_accept($socket)) echo "socket_accept() failed:" . socket_strerror(socket_last_error());
  21. }else{
  22. // 读数据
  23. $out = '';
  24. while($buf = socket_read($msgsock,8192)){
  25. $out .= $buf;
  26. }
  27. // 写数据
  28. $in = "数据是 $out";
  29. socket_write($msgsock, $in, strlen($in));
  30. }
  31. // 结束通信
  32. socket_close($msgsock);
  33. }
  34. socket_close($socket);
  35. ?>
复制代码

服务端主要进行了以下步骤:

创建Socket的监听,等待连接 当链接到来时,开启一个子连接处理IO 接收来自客户端的传输数据 将结果写回给客户端 客户端
  1. set_time_limit(0);
  2. $host = "127.0.0.1";
  3. $port = 12387;
  4. // 创建一个tcp流
  5. $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
  6. or die("socket_create() failed:" . socket_strerror(socket_last_error()));
  7. echo "try to connect to $host:$port...\n";
  8. $result = socket_connect($socket, $host, $port)
  9. or die("socket_connect() failed:" . socket_strerror(socket_last_error()));
  10. $in = "hello \n";
  11. if(!socket_write($socket, $in, strlen($in))) {
  12. echo "socket_write() failed:" . socket_strerror($socket);
  13. }else {
  14. echo "发送成功!\n";
  15. }
  16. $out = '';
  17. while($buf = socket_read($socket, 8192)) {
  18. $out .= $buf;
  19. }
  20. echo "接受内容为:$out \n";
  21. socket_close($socket);
  22. ?>
复制代码

客户端主要有以下步骤:

连接到服务端Socket 向服务端写数据 接收来自服务端的数据

来源:闫肃的博客

PHP, Socket


Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage