老雷socket编程之PHP利用socket扩展实现聊天服务
2019-07-23 08:41:26来源:博客园 阅读 ()
老雷socket编程之PHP利用socket扩展实现聊天服务
socket聊天服务原理
PHP有两个socket的扩展 sockets和streams
sockets
socket_create(AF_INET, SOCK_STREAM, SOL_TCP)
socket_write
socket_read
socket_close
客户端
socket_connect($socket, $address, $service_port);
服务端
socket_bind($sock, $address, $port)
socket_listen($sock)
socket_accept
Streams
客户端
stream_socket_client
fwrite
fread
fclose($fp);
服务端
stream_socket_server
stream_set_blocking
stream_select
stream_socket_accept conn
stream_socket_recvfrom
stream_socket_sendto
stream_socket_shutdown
课后练习
使用sockets和streams扩展实现客户端跟服务端的功能。
服务端代码 客服端可使用udp&tcp测试工具
<?php class SocketService { public $host="tcp://0.0.0.0:8000"; private $address; private $port; private $_sockets; public $clients; public $maxid=1000; public function __construct($address = '', $port='') { if(!empty($address)){ $this->address = $address; } if(!empty($port)) { $this->port = $port; } } public function onConnect($client_id){ echo "Client client_id:{$client_id} \n"; } public function onMessage($client_id,$msg){ //发给所有的 foreach($this->clients as $kk=>$cc){ if($kk>0){ $this->send($cc, $msg); } } } public function onClose($client_id){ echo "$client_id close \n"; } public function service(){ //获取tcp协议号码。 $tcp = getprotobyname("tcp"); $sock = stream_socket_server($this->host, $errno, $errstr);; if(!$sock) { throw new Exception("failed to create socket: ".socket_strerror($sock)."\n"); } stream_set_blocking($sock,0); $this->_sockets = $sock; echo "listen on $this->address $this->host ... \n"; } public function run(){ $this->service(); $this->clients[] = $this->_sockets; while (true){ $changes = $this->clients; //$write = NULL; //$except = NULL; stream_select($changes, $write, $except, NULL); foreach ($changes as $key => $_sock){ if($this->_sockets == $_sock){ //判断是不是新接入的socket if(($newClient = stream_socket_accept($_sock)) === false){ unset($this->clients[$key]); continue; } $line = trim(stream_socket_recvfrom($newClient, 1024)); $this->maxid++; $this->clients[$this->maxid] = $newClient; $this->onConnect($this->maxid); } else { $msg=@stream_socket_recvfrom($_sock, 2048); if(!$msg){ stream_socket_shutdown($this->clients[$key],STREAM_SHUT_RDWR); unset($this->clients[$key]); $this->onClose($key); }else{ $msg=$this->decode($msg); $this->onMessage($key,$msg); } } } } } /** * 发送数据 * @param $newClinet 新接入的socket * @param $msg 要发送的数据 * @return int|string */ public function send($newClinet, $msg){ $msg=$this->encode($msg); if($msg){ stream_socket_sendto($newClinet, $msg); } } public function encode($msg){ return $msg . "\n"; } public function decode($msg){ return rtrim($msg, "\r\n"); } /** * 关闭socket */ public function close(){ return socket_close($this->_sockets); } } $sock = new SocketService('127.0.0.1','9000'); $sock->run();
原文链接:https://www.cnblogs.com/lrjxgl/p/11123923.html
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- PHP多进程编程之僵尸进程问题的理解 2020-02-17
- php中常用的魔术方法 2020-02-13
- 操作PHP文件的方法 2020-02-10
- 如何关闭PHP错误提示 2020-02-10
- 常用的Stream函数集 2020-02-10
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash