blocks|key|1600202|text|嗯，这很简单，你可以做到这一点，这要感谢我们找到答案的所有来源(对不起，我不能全部记住)|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1600203|<?php
$host+=+'10.9.8.173';++//where+is+the+websocket+server
$port+=+8575;
$local+=+"http://mypc";++//url+where+this+script+run
$data+=+"first+message";++//data+to+be+send

$head+=+"GET+/+HTTP/1.1"."\r\n".
++++++++"Upgrade:+WebSocket"."\r\n".
++++++++"Connection:+Upgrade"."\r\n".
++++++++"Origin:+$local"."\r\n".
++++++++"Host:+$host"."\r\n".
++++++++"Sec-WebSocket-Key:+asdasdaas76da7sd6asd6as7d"."\r\n".
++++++++"Content-Length:+".strlen($data)."\r\n"."\r\n";
//WebSocket+handshake
$sock+=+fsockopen($host,+$port,+$errno,+$errstr,+2);
fwrite($sock,+$head+)+or+die('error:'.$errno.':'.$errstr);
$headers+=+fread($sock,+2000);
echo+$headers;
fwrite($sock,+hybi10Encode($data))+or+die('error:'.$errno.':'.$errstr);
$wsdata+=+fread($sock,+2000);
var_dump(hybi10Decode($wsdata));
fclose($sock);


function+hybi10Decode($data)
{
++++$bytes+=+$data;
++++$dataLength+=+'';
++++$mask+=+'';
++++$coded_data+=+'';
++++$decodedData+=+'';
++++$secondByte+=+sprintf('%2508b',+ord($bytes[1]));
++++$masked+=+($secondByte[0]+==+'1')+?+true+:+false;
++++$dataLength+=+($masked+===+true)+?+ord($bytes[1])+&+127+:+ord($bytes[1]);

++++if($masked+===+true)
++++{
++++++++if($dataLength+===+126)
++++++++{
+++++++++++$mask+=+substr($bytes,+4,+4);
+++++++++++$coded_data+=+substr($bytes,+8);
++++++++}
++++++++elseif($dataLength+===+127)
++++++++{
++++++++++++$mask+=+substr($bytes,+10,+4);
++++++++++++$coded_data+=+substr($bytes,+14);
++++++++}
++++++++else
++++++++{
++++++++++++$mask+=+substr($bytes,+2,+4);+++++++
++++++++++++$coded_data+=+substr($bytes,+6);++++++++
++++++++}+++
++++++++for($i+=+0;+$i+<+strlen($coded_data);+$i%2B%2B)
++++++++{+++++++
++++++++++++$decodedData+.=+$coded_data[$i]+%5E+$mask[$i+%25+4];
++++++++}
++++}
++++else
++++{
++++++++if($dataLength+===+126)
++++++++{++++++++++
+++++++++++$decodedData+=+substr($bytes,+4);
++++++++}
++++++++elseif($dataLength+===+127)
++++++++{+++++++++++
++++++++++++$decodedData+=+substr($bytes,+10);
++++++++}
++++++++else
++++++++{+++++++++++++++
++++++++++++$decodedData+=+substr($bytes,+2);+++++++
++++++++}+++++++
++++}+++

++++return+$decodedData;
}


function+hybi10Encode($payload,+$type+=+'text',+$masked+=+true)+{
++++$frameHead+=+array();
++++$frame+=+'';
++++$payloadLength+=+strlen($payload);

++++switch+($type)+{
++++++++case+'text':
++++++++++++//+first+byte+indicates+FIN,+Text-Frame+(10000001):
++++++++++++$frameHead[0]+=+129;
++++++++++++break;

++++++++case+'close':
++++++++++++//+first+byte+indicates+FIN,+Close+Frame(10001000):
++++++++++++$frameHead[0]+=+136;
++++++++++++break;

++++++++case+'ping':
++++++++++++//+first+byte+indicates+FIN,+Ping+frame+(10001001):
++++++++++++$frameHead[0]+=+137;
++++++++++++break;

++++++++case+'pong':
++++++++++++//+first+byte+indicates+FIN,+Pong+frame+(10001010):
++++++++++++$frameHead[0]+=+138;
++++++++++++break;
++++}

++++//+set+mask+and+payload+length+(using+1,+3+or+9+bytes)
++++if+($payloadLength+>+65535)+{
++++++++$payloadLengthBin+=+str_split(sprintf('%25064b',+$payloadLength),+8);
++++++++$frameHead[1]+=+($masked+===+true)+?+255+:+127;
++++++++for+($i+=+0;+$i+<+8;+$i%2B%2B)+{
++++++++++++$frameHead[$i+%2B+2]+=+bindec($payloadLengthBin[$i]);
++++++++}

++++++++//+most+significant+bit+MUST+be+0+(close+connection+if+frame+too+big)
++++++++if+($frameHead[2]+>+127)+{
++++++++++++$this->close(1004);
++++++++++++return+false;
++++++++}
++++}+elseif+($payloadLength+>+125)+{
++++++++$payloadLengthBin+=+str_split(sprintf('%25016b',+$payloadLength),+8);
++++++++$frameHead[1]+=+($masked+===+true)+?+254+:+126;
++++++++$frameHead[2]+=+bindec($payloadLengthBin[0]);
++++++++$frameHead[3]+=+bindec($payloadLengthBin[1]);
++++}+else+{
++++++++$frameHead[1]+=+($masked+===+true)+?+$payloadLength+%2B+128+:+$payloadLength;
++++}

++++//+convert+frame-head+to+string:
++++foreach+(array_keys($frameHead)+as+$i)+{
++++++++$frameHead[$i]+=+chr($frameHead[$i]);
++++}

++++if+($masked+===+true)+{
++++++++//+generate+a+random+mask:
++++++++$mask+=+array();
++++++++for+($i+=+0;+$i+<+4;+$i%2B%2B)+{
++++++++++++$mask[$i]+=+chr(rand(0,+255));
++++++++}

++++++++$frameHead+=+array_merge($frameHead,+$mask);
++++}
++++$frame+=+implode('',+$frameHead);
++++//+append+payload+to+frame:
++++for+($i+=+0;+$i+<+$payloadLength;+$i%2B%2B)+{
++++++++$frame+.=+($masked+===+true)+?+$payload[$i]+%5E+$mask[$i+%25+4]+:+$payload[$i];
++++}

++++return+$frame;
}

?>|code-block|syntax|javascript|1600204|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

well, it's easy and you can do in this 
Thanks to all sources where we found answers (sorry, I can't remember all)

<pre><code>&lt;?php
$host = '10.9.8.173'; //where is the websocket server
$port = 8575;
$local = "http://mypc"; //url where this script run
$data = "first message"; //data to be send

$head = "GET / HTTP/1.1"."\r\n".
 "Upgrade: WebSocket"."\r\n".
 "Connection: Upgrade"."\r\n".
 "Origin: $local"."\r\n".
 "Host: $host"."\r\n".
 "Sec-WebSocket-Key: asdasdaas76da7sd6asd6as7d"."\r\n".
 "Content-Length: ".strlen($data)."\r\n"."\r\n";
//WebSocket handshake
$sock = fsockopen($host, $port, $errno, $errstr, 2);
fwrite($sock, $head ) or die('error:'.$errno.':'.$errstr);
$headers = fread($sock, 2000);
echo $headers;
fwrite($sock, hybi10Encode($data)) or die('error:'.$errno.':'.$errstr);
$wsdata = fread($sock, 2000);
var_dump(hybi10Decode($wsdata));
fclose($sock);


function hybi10Decode($data)
{
 $bytes = $data;
 $dataLength = '';
 $mask = '';
 $coded_data = '';
 $decodedData = '';
 $secondByte = sprintf('%08b', ord($bytes[1]));
 $masked = ($secondByte[0] == '1') ? true : false;
 $dataLength = ($masked === true) ? ord($bytes[1]) &amp; 127 : ord($bytes[1]);

 if($masked === true)
 {
 if($dataLength === 126)
 {
 $mask = substr($bytes, 4, 4);
 $coded_data = substr($bytes, 8);
 }
 elseif($dataLength === 127)
 {
 $mask = substr($bytes, 10, 4);
 $coded_data = substr($bytes, 14);
 }
 else
 {
 $mask = substr($bytes, 2, 4); 
 $coded_data = substr($bytes, 6); 
 } 
 for($i = 0; $i &lt; strlen($coded_data); $i++)
 { 
 $decodedData .= $coded_data[$i] ^ $mask[$i % 4];
 }
 }
 else
 {
 if($dataLength === 126)
 { 
 $decodedData = substr($bytes, 4);
 }
 elseif($dataLength === 127)
 { 
 $decodedData = substr($bytes, 10);
 }
 else
 { 
 $decodedData = substr($bytes, 2); 
 } 
 } 

 return $decodedData;
}


function hybi10Encode($payload, $type = 'text', $masked = true) {
 $frameHead = array();
 $frame = '';
 $payloadLength = strlen($payload);

 switch ($type) {
 case 'text':
 // first byte indicates FIN, Text-Frame (10000001):
 $frameHead[0] = 129;
 break;

 case 'close':
 // first byte indicates FIN, Close Frame(10001000):
 $frameHead[0] = 136;
 break;

 case 'ping':
 // first byte indicates FIN, Ping frame (10001001):
 $frameHead[0] = 137;
 break;

 case 'pong':
 // first byte indicates FIN, Pong frame (10001010):
 $frameHead[0] = 138;
 break;
 }

 // set mask and payload length (using 1, 3 or 9 bytes)
 if ($payloadLength &gt; 65535) {
 $payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8);
 $frameHead[1] = ($masked === true) ? 255 : 127;
 for ($i = 0; $i &lt; 8; $i++) {
 $frameHead[$i + 2] = bindec($payloadLengthBin[$i]);
 }

 // most significant bit MUST be 0 (close connection if frame too big)
 if ($frameHead[2] &gt; 127) {
 $this-&gt;close(1004);
 return false;
 }
 } elseif ($payloadLength &gt; 125) {
 $payloadLengthBin = str_split(sprintf('%016b', $payloadLength), 8);
 $frameHead[1] = ($masked === true) ? 254 : 126;
 $frameHead[2] = bindec($payloadLengthBin[0]);
 $frameHead[3] = bindec($payloadLengthBin[1]);
 } else {
 $frameHead[1] = ($masked === true) ? $payloadLength + 128 : $payloadLength;
 }

 // convert frame-head to string:
 foreach (array_keys($frameHead) as $i) {
 $frameHead[$i] = chr($frameHead[$i]);
 }

 if ($masked === true) {
 // generate a random mask:
 $mask = array();
 for ($i = 0; $i &lt; 4; $i++) {
 $mask[$i] = chr(rand(0, 255));
 }

 $frameHead = array_merge($frameHead, $mask);
 }
 $frame = implode('', $frameHead);
 // append payload to frame:
 for ($i = 0; $i &lt; $payloadLength; $i++) {
 $frame .= ($masked === true) ? $payload[$i] ^ $mask[$i % 4] : $payload[$i];
 }

 return $frame;
}

?&gt;
</code></pre>

blocks|key|1966356|text|以上这些都不是一个好的答案。其中有几个是关于服务器的，而问题是关于客户端的。来自Rodislav的代码对我不起作用，因为它不能与我在Heroku上的WebSockets服务器通信。然而，这个库工作得很好：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1966357|https://github.com/Devristo/phpws|offset|length|1966358|更新:虽然这段代码在一切正常的情况下可以正常工作，但似乎根本没有错误返回或异常，因此当出现错误时(例如，服务器没有运行、地址错误、端口被阻塞等)，它就无法使用。因此，虽然实验很有趣，但它在生产代码中是不可用的。|1966359|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|X|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|P|8|@]|9|@$D|Q|E|R|1|S]]|A|$]]|$1|F|3|G|5|6|7|T|8|@]|9|@]|A|$]]|$1|H|3|-4|5|6|7|U|8|@]|9|@]|A|$]]]|I|$J|$5|K|L|M|A|$N|C]]]]

None of the above is a good answer. Several of them are about a server, whereas the question is about a client. The code from Rodislav didn't work for me, as it didn't talk to my WebSockets server on Heroku. However, this library worked very well:

<a href="https://github.com/Devristo/phpws" rel="noreferrer">https://github.com/Devristo/phpws</a>

UPDATE: While this code worked when all was well, there seems to be no error returns or exceptions at all, and as a result it's unusable when there's an error (e.g., the server isn't running, the address is wrong, the port is blocked, etc.). So, while it was fun to experiment with, it's not usable in production code.

blocks|key|1600219|text|这个库看起来相当不错，如果您对依赖项没意见的话：https://github.com/gabrielbull/php-websocket-client|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1600220|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/gabrielbull/php-websocket-client^0|O|1F|0|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@$A|M|B|N|1|O]]|C|$]]|$1|D|3|-4|5|6|7|P|8|@]|9|@]|C|$]]]|E|$F|$5|G|H|I|C|$J|K]]]]

This library looks pretty good, if you're ok with the dependencies: <a href="https://github.com/gabrielbull/php-websocket-client" rel="nofollow">https://github.com/gabrielbull/php-websocket-client</a>

blocks|key|1604028|text|一个PHP+Websocket库和一个示例聊天应用程序。与演示和完整的实现说明。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1604029|http://www.techzonemind.com/php-websocket-library-two-way-real-time-communication/|offset|length|1604030|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|2A|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|N|8|@]|9|@$D|O|E|P|1|Q]]|A|$]]|$1|F|3|-4|5|6|7|R|8|@]|9|@]|A|$]]]|G|$H|$5|I|J|K|A|$L|C]]]]

A PHP Websocket library with an example chat application. With demo and full description of implementation.

<a href="http://www.techzonemind.com/php-websocket-library-two-way-real-time-communication/" rel="nofollow">http://www.techzonemind.com/php-websocket-library-two-way-real-time-communication/</a>

blocks|key|4077068|text|我尝试在tivoka+(json-rpc)中使用上面的许多方法，但它们要么不能很好地读取较大的数据包(不能读取整个帧或读入下一帧)，要么具有较大的依赖性。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4077069|所以，我写了https://github.com/Textalk/websocket-php|offset|length|4077070|它不是先从套接字读取所有可用的数据，然后对其进行解码，而是读取帧头并解析有效负载长度，然后加载这些数据。|4077071|它缺乏对ping/pong的支持，但我认为它在其他方面做得很好。它在tivoka上工作得很好，至少有92%25是自动测试的:)它可能需要一些额外的功能来检查是否有另一个帧，而不是真正地读取它。|4077072|让我知道你的想法。|4077073|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/Textalk/websocket-php^0|0|6|14|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|U|8|@]|9|@$D|V|E|W|1|X]]|A|$]]|$1|F|3|G|5|6|7|Y|8|@]|9|@]|A|$]]|$1|H|3|I|5|6|7|Z|8|@]|9|@]|A|$]]|$1|J|3|K|5|6|7|10|8|@]|9|@]|A|$]]|$1|L|3|-4|5|6|7|11|8|@]|9|@]|A|$]]]|M|$N|$5|O|P|Q|A|$R|S]]]]

I tried to use many of the above to include in tivoka (json-rpc), but they either wasn't good enough reading larger packets (not getting the whole frame or reading into the next one) or had large dependencies.

So, I wrote <a href="https://github.com/Textalk/websocket-php" rel="noreferrer">https://github.com/Textalk/websocket-php</a>

Instead of first reading all available data from the socket and then decoding it, it reads the frame header and parses payload length, and then loads just that.

It lacks ping/pong support, but I think it does most of the other stuff well. It works well with tivoka and is at least 92% autotested :) It might need some extra functions to check if there is another frame without actually reading it.

Let me know what you think.

Is there a library or client for connecting to a WebSocket server from PHP? If not, is there a reason why?

(<a href="http://code.google.com/p/phpwebsocket/" rel="noreferrer">phpwebsocket</a> only seem to have Javascript client code.)

WebSocket client in PHP?

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

有没有可以从PHP连接到WebSocket服务器的库或客户端？如果没有，有什么原因吗？(似乎只有Javascript客户端代码。)

问用PHP实现WebSocket客户端？
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问用PHP实现WebSocket客户端？EN