我有简单的 node.js websocket 服务器:
var fs = require('fs')
var ws = require('../../')
var options = {
secure: false,
}
var Server = ws.createServer(options, function(conn){
conn.on("text", function (str) {
broadcast(str);
//conn.sendText(str.toUpperCase() + "!!!")
console.log('connected');
console.log(str);
//console.log(Server.connections);
})
}).listen(8001, "127.0.0.1");
function broadcast(str){
Server.connections.forEach(function (connection) {
connection.sendText(str)
})
}
这适用于 JS 客户端,但不适用于 PHP 客户端,例如:
function MaskMessage($text)
{
$b1 = 0x80 | (0x1 & 0x0f);
$length = strlen($text);
if($length <= 125)
$header = pack('CC', $b1, $length);
elseif($length > 125 && $length < 65536)
$header = pack('CCn', $b1, 126, $length);
elseif($length >= 65536)
$header = pack('CCNN', $b1, 127, $length);
return $header.$text;
}
$host = 'localhost';
$port = 8001;
$msg = 'hey hi hello';
$msg = MaskMessage('hej hej siema');
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
// Bind the source address
$result = socket_connect($socket, $host, $port);
if(!$result)
echo 'cannot connect '.socket_strerror(socket_last_error());
else{
echo socket_write($socket, strval($msg), strlen($msg));
}
socket_strerror(socket_last_error());
socket_close($socket);
PHP 创建套接字并连接,它不会返回任何错误并发送消息,但 Node.js 服务器不会从该客户端接收任何内容。我究竟做错了什么?该客户端与 PHP websocket 服务器一起使用。