クライアント WebSocket によって送信されたデータを受け入れるための PHP ソケット コードを作成する方法
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 ) { return true; } $finishIndex = 0; $bytes = null;$zeroTimes = 0; do { if( $finishIndex > 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 <= 0 ) { ++$zeroTimes; if( $zeroTimes > 100 ) { $this->SetError('Send data 0 bytes more than 100 times', __LINE__); return false; } } else { $finishIndex += $bytes; } }while($finishIndex < $bufLen); return true; } /** * 获取数据 * @param string &$buffer 保存接收数据的缓存(注意:函数中会将此缓存清空后再存放接收到的数据) * @param int $length 接收数据长度 * @param int $flags 参数,默认为0 * * @return bool 发送成功返回true,否则返回false */ public function Recv(&$buffer, $length, $flags=0) { $length = intval($length); if( $length <= 0 ) { return true; } $buffer = '';$bytes = -1;$cache = '';$zeroTimes = 0; do { if( $bytes > 0 ) { usleep(100); } $bytes = @socket_recv($this->rLink, $cache, $length, $flags); if( false === $bytes ) { $this->SetSocketError(__LINE__); return false; } else if( $bytes <= 0 ) { ++$zeroTimes; if( $zeroTimes > 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 < 0 || $microseconds < 0 ) { $seconds = 1; $microseconds = 0; } if( !socket_set_option($this->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 < 0 || $microseconds < 0 ) { $seconds = 3; $microseconds = 0; } if( !socket_set_option($this->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 < 65535 ) { $buffer.=$cache; break; } $buffer.=$cache; }while(true); return true; }}
一个获取设备状态的例子,调用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]; }

ホットAIツール

Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

AI Hentai Generator
AIヘンタイを無料で生成します。

人気の記事

ホットツール

メモ帳++7.3.1
使いやすく無料のコードエディター

SublimeText3 中国語版
中国語版、とても使いやすい

ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境

ドリームウィーバー CS6
ビジュアル Web 開発ツール

SublimeText3 Mac版
神レベルのコード編集ソフト(SublimeText3)

ホットトピック









PHP 8.4 では、いくつかの新機能、セキュリティの改善、パフォーマンスの改善が行われ、かなりの量の機能の非推奨と削除が行われています。 このガイドでは、Ubuntu、Debian、またはその派生版に PHP 8.4 をインストールする方法、または PHP 8.4 にアップグレードする方法について説明します。

Visual Studio Code (VS Code とも呼ばれる) は、すべての主要なオペレーティング システムで利用できる無料のソース コード エディター (統合開発環境 (IDE)) です。 多くのプログラミング言語の拡張機能の大規模なコレクションを備えた VS Code は、

あなたが経験豊富な PHP 開発者であれば、すでにそこにいて、すでにそれを行っていると感じているかもしれません。あなたは、運用を達成するために、かなりの数のアプリケーションを開発し、数百万行のコードをデバッグし、大量のスクリプトを微調整してきました。

このチュートリアルでは、PHPを使用してXMLドキュメントを効率的に処理する方法を示しています。 XML(拡張可能なマークアップ言語)は、人間の読みやすさとマシン解析の両方に合わせて設計された多用途のテキストベースのマークアップ言語です。一般的にデータストレージに使用されます

JWTは、JSONに基づくオープン標準であり、主にアイデンティティ認証と情報交換のために、当事者間で情報を安全に送信するために使用されます。 1。JWTは、ヘッダー、ペイロード、署名の3つの部分で構成されています。 2。JWTの実用的な原則には、JWTの生成、JWTの検証、ペイロードの解析という3つのステップが含まれます。 3. PHPでの認証にJWTを使用する場合、JWTを生成および検証でき、ユーザーの役割と許可情報を高度な使用に含めることができます。 4.一般的なエラーには、署名検証障害、トークンの有効期限、およびペイロードが大きくなります。デバッグスキルには、デバッグツールの使用とロギングが含まれます。 5.パフォーマンスの最適化とベストプラクティスには、適切な署名アルゴリズムの使用、有効期間を合理的に設定することが含まれます。

文字列は、文字、数字、シンボルを含む一連の文字です。このチュートリアルでは、さまざまな方法を使用してPHPの特定の文字列内の母音の数を計算する方法を学びます。英語の母音は、a、e、i、o、u、そしてそれらは大文字または小文字である可能性があります。 母音とは何ですか? 母音は、特定の発音を表すアルファベットのある文字です。大文字と小文字など、英語には5つの母音があります。 a、e、i、o、u 例1 入力:string = "tutorialspoint" 出力:6 説明する 文字列「TutorialSpoint」の母音は、u、o、i、a、o、iです。合計で6元があります

静的結合(静的::) PHPで後期静的結合(LSB)を実装し、クラスを定義するのではなく、静的コンテキストで呼び出しクラスを参照できるようにします。 1)解析プロセスは実行時に実行されます。2)継承関係のコールクラスを検索します。3)パフォーマンスオーバーヘッドをもたらす可能性があります。

PHPの魔法の方法は何ですか? PHPの魔法の方法には次のものが含まれます。1。\ _ \ _コンストラクト、オブジェクトの初期化に使用されます。 2。\ _ \ _リソースのクリーンアップに使用される破壊。 3。\ _ \ _呼び出し、存在しないメソッド呼び出しを処理します。 4。\ _ \ _ get、dynamic属性アクセスを実装します。 5。\ _ \ _セット、動的属性設定を実装します。これらの方法は、特定の状況で自動的に呼び出され、コードの柔軟性と効率を向上させます。
