PHP socket代码怎么写 才能接受客户端websocket发过来的数据
程序员文章站
2022-05-20 08:52:58
...
PHP socket代码怎么写 才能接受客户端websocket发过来的数据
百度了半天都没看到完整的代码 也没好的教程
他这个我用过不行 客户端发过来的数据根本收不到 要自己改得。。我想写原生
百度了半天都没看到完整的代码 也没好的教程
回复讨论(解决方案)
建议直接使用workerman,它有现成的php 的 websocket server,性能非常棒
下面是三个workerman的websocket的线上的demo,官网有源代码,注释也比较详细,值得看下
http://kedou.workerman.net/
http://www.workerman.net:55151/
http://flap.workerman.net/
建议直接使用workerman,它有现成的php 的 websocket server,性能非常棒
下面是三个workerman的websocket的线上的demo,官网有源代码,注释也比较详细,值得看下
http://kedou.workerman.net/
http://www.workerman.net:55151/
http://flap.workerman.net/
他这个我用过不行 客户端发过来的数据根本收不到 要自己改得。。我想写原生
谁帮个忙写个原生的。
网上有现成的
/** * TCP操作基类 * @package SHIT\Protocol * @see \SHIT\Object */class TCPv4 extends \X\Core\Object { /** * 套接字句柄 * @var resource */ protected $rLink = null; /** * 构造函数 * @param string $ip IP地址 * @param int $port 端口号 * * @throws \X\Exception\Abstraction */ public function __construct($ip, $port) { $this->rLink = @socket_create(AF_INET, SOCK_STREAM, SOL_TCP); if( false === $this->rLink ) { $this->rLink = null; $this->SetSocketError(__LINE__); throw new \X\Exception\Error($this->sError, $this->iErrno); } //设置连接超时为1秒 if( !$this->SetSendTimeout(1) ) { $this->Close(); throw new \X\Exception\Error($this->sError, $this->iErrno); }// echo 'sssssssssssss'; if( !@socket_connect($this->rLink, $ip, $port) ) { $this->SetSocketError(__LINE__); $this->Close(); throw new \X\Exception\Error($this->sError, $this->iErrno); }// var_dump($this->rLink);exit; if( !$this->SetSendTimeout(1) || !$this->SetRecvTimeout(3) ) { $this->Close(); throw new \X\Exception\Error($this->sError, $this->iErrno); } } /** * 析构函数 */ public function __destruct() { $this->Close(); } /** * 发送数据 * @param string $buffer 待发送数据的缓存 * @param int $flags 参数,默认为0 * * @return bool 发送成功返回true,否则返回false */ public function Send($buffer, $flags=0) { $buffer = strval($buffer); $bufLen = strlen($buffer); if( $bufLen 0 ) { usleep(100); } $bytes = @socket_send($this->rLink, substr($buffer, $finishIndex), $bufLen - $finishIndex, $flags); if( false === $bytes ) { $this->SetSocketError(__LINE__); return false; } else if( $bytes 100 ) { $this->SetError('Send data 0 bytes more than 100 times', __LINE__); return false; } } else { $finishIndex += $bytes; } }while($finishIndex 0 ) { usleep(100); } $bytes = @socket_recv($this->rLink, $cache, $length, $flags); if( false === $bytes ) { $this->SetSocketError(__LINE__); return false; } else if( $bytes 100 ) { $this->SetError('Receive data 0 bytes more than 100 times', __LINE__); return false; } } else { $length -= $bytes; } $buffer.=$cache; }while($length > 0); return true; } /** * 设置发送超时时间 * @param int $seconds 秒数,默认值为1 * @param int $microseconds 微秒,默认值为0 * * @return bool 发送成功返回true,否则返回false */ public function SetSendTimeout($seconds=1, $microseconds=0) { $seconds = intval($seconds);$microseconds = intval($microseconds); if( $seconds rLink, SOL_SOCKET, SO_SNDTIMEO, array("sec"=>$seconds, "usec"=>$microseconds)) ) { $this->SetSocketError(__LINE__); return false; } return true; } /** * 设置接收超时时间 * @param int $seconds 秒数,默认值为3 * @param int $microseconds 微秒,默认值为0 * * @return bool 发送成功返回true,否则返回false */ public function SetRecvTimeout($seconds=3, $microseconds=0) { $seconds = intval($seconds);$microseconds = intval($microseconds); if( $seconds rLink, SOL_SOCKET, SO_RCVTIMEO, array("sec"=>$seconds, "usec"=>$microseconds)) ) { $this->SetSocketError(__LINE__); return false; } return true; } /** * 关闭连接的套接字 * * @return void */ protected function Close() { if( is_resource($this->rLink) ) { socket_close($this->rLink); $this->rLink = null; } } /** * 设置套接字错误 * @param int $line 错误行 * * @return void */ protected function SetSocketError($line) { $code = socket_last_error(); $msg = socket_strerror($code); $this->SetError("[$code]$msg", $line); } /** * 获取不定长数据 * @param string &$buffer 保存接收数据的缓存(注意:函数中会将此缓存清空后再存放接收到的数据) * @param int $flags 参数,默认为0 * * @return bool 发送成功返回true,否则返回false */ public function RecvForDontKnowLength(&$buffer, $flags=0) { $buffer = '';$bytes = -1;$cache = ''; do { if( $bytes > 0 ) { usleep(100); } $bytes = @socket_recv($this->rLink, $cache, 65535, $flags); if( false === $bytes ) { $this->SetSocketError(__LINE__); return false; } else if( $bytes
一个获取设备状态的例子,调用socket并获取数据/* * 设备注销 * */ private function DeviceLogout() { $serverIp = $_SERVER ['SERVER_ADDR']; // 服务器IP $header = "\x01\x00\x30\x04" . pack ( 'n', 0 ); $buffer = pack ( 'N', $this->deviceID ) . $serverIp . "\0"; $buffer = $header . pack ( 'n', 8 + strlen ( $buffer ) ) . $buffer; $this->package = $buffer; }/** * 发送数据包 * @param string $action socket发送动作:REGISTER_DEVICE、SENDCONFIG_DEVICE、GETDEVICE_INFORMATION、LOGOUT_DEVICE * @param string $ip ip地址 * * @return bytes 返回socket的数据 */ public function SendPackage($action = null,$ip=null,$lengthtype=null,$length=null) { $TCPv4 = new \X\Protocol\TCPv4 ( $ip, $this->agentPort ); $TCPv4->SetSendTimeout ( 5 ); $TCPv4->SetRecvTimeout ( 30 ); switch ($action) { case 'REGISTER_DEVICE' : $this->DeviceRegister(); break; case 'SENDCONFIG_DEVICE' : break; case 'GETDEVICE_INFORMATION' : $this->DeviceInformation (); break; case 'LOGOUT_DEVICE' : $this->DeviceLogout (); break; } $status = $TCPv4->Send ( $this->package ); $result = ''; if (0 === $lengthtype) // 定长 { $TCPv4->Recv ( $result, $length ); } else { $TCPv4->RecvForDontKnowLength ( $result ); } return $result; } public function RegisterDevice($ip=null) { /* * Action:注册行为: 1:检查设备是否注册于本Server; 2:注册该设备到本Server; 3:无视该设备已经注册于其他Server的情形,强制注册设备到本Server。 Result: 0:该设备成功注册于本Server; 1:注册失败; 2:该设备尚未注册; 3:该设备已在其他Server注册; 4:内部错误:该设备已在该Server注册,但指派的设备ID与现有的设备ID不同。 * */ $REG_TCP = new \X\Protocol\TCPv4 ( $ip, $this->agentPort ); $REG_TCP->SetSendTimeout ( 5 ); $REG_TCP->SetRecvTimeout ( 30 ); $this->DeviceRegister(); $status = $REG_TCP->Send ( $this->package ); $result = ''; $REG_TCP->Recv ( $result, 12 ); $SERVER_SOCKET_DATA = unpack ( 'N', substr ( $result, 8, 4 ) ); return $SERVER_SOCKET_DATA [1]; }