老雷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.huangshanshimin.com/