blocks|key|153278|text|我正在使用http://elephant.io/进行php和socket.io之间的通信，只有建立连接的时间有问题，需要3到4秒才能完成数据发送。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|153279|<?php

require(+__DIR__+.+'/ElephantIO/Client.php');
use+ElephantIO\Client+as+ElephantIOClient;

$elephant+=+new+ElephantIOClient('http://localhost:8080',+'socket.io',+1,+false,+true,+true);

$elephant->init();
$elephant->emit('message',+'foo');
$elephant->close();|code-block|syntax|javascript|153280|entityMap|0|LINK|mutability|MUTABLE|url|http://elephant.io/^0|5|J|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

im using <a href="http://elephant.io/" rel="nofollow">http://elephant.io/</a> for comunication between php and socket.io, i have only problems with the time to stablish connection, 3 or 4 seconds to complete sending data.

<pre><code>&lt;?php

require( __DIR__ . '/ElephantIO/Client.php');
use ElephantIO\Client as ElephantIOClient;

$elephant = new ElephantIOClient('http://localhost:8080', 'socket.io', 1, false, true, true);

$elephant-&gt;init();
$elephant-&gt;emit('message', 'foo');
$elephant-&gt;close();
</code></pre>

blocks|key|153321|text|ElephantIO仍未更新到最新的Socket.IO。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|153322|因为socket.io+v0.9和v1.x非常不同。|153323|此处为Socket.io+v1.0：http://socket.io/blog/introducing-socket-io-1-0/|offset|length|153324|更新:此链接可能会有所帮助：https://github.com/psinetron/PHP_SocketIO_Client|153325|entityMap|0|LINK|mutability|MUTABLE|url|http://socket.io/blog/introducing-socket-io-1-0/|1|https://github.com/psinetron/PHP_SocketIO_Client^0|0|0|I|1C|0|0|E|1C|1|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|U|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|V|8|@]|9|@$F|W|G|X|1|Y]]|A|$]]|$1|H|3|I|5|6|7|Z|8|@]|9|@$F|10|G|11|1|12]]|A|$]]|$1|J|3|-4|5|6|7|13|8|@]|9|@]|A|$]]]|K|$L|$5|M|N|O|A|$P|Q]]|R|$5|M|N|O|A|$P|S]]]]

ElephantIO still not yet updated to the latest Socket.IO.

Because socket.io v0.9 and v1.x is very different.

Socket.io v1.0 here : <a href="http://socket.io/blog/introducing-socket-io-1-0/" rel="nofollow">http://socket.io/blog/introducing-socket-io-1-0/</a>

Updated : This link may help : <a href="https://github.com/psinetron/PHP_SocketIO_Client" rel="nofollow">https://github.com/psinetron/PHP_SocketIO_Client</a>

blocks|key|153349|text|使用最新版本的ElephantIO，我成功地发送了一条消息：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|153350|include_once("vendor/autoload.php");
use+ElephantIO\Exception\ServerConnectionFailureException;

$client+=+new+\ElephantIO\Client(new+\ElephantIO\Engine\SocketIO\Version1X('http://localhost:9000'));

try
{
++++$client->initialize();
++++$client->emit('message',+['title'+=>+'test']);
++++$client->close();
}
catch+(ServerConnectionFailureException+$e)
{
++++echo+'Server+Connection+Failure!!';
}|code-block|syntax|javascript|153351|entityMap^0|7|A|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@$9|N|A|O|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|P|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|Q|8|@]|D|@]|E|$]]]|L|$]]

With the latest version of <code>ElephantIO</code>, I've managed to send a message with:

<pre><code>include_once("vendor/autoload.php");
use ElephantIO\Exception\ServerConnectionFailureException;

$client = new \ElephantIO\Client(new \ElephantIO\Engine\SocketIO\Version1X('http://localhost:9000'));

try
{
 $client-&gt;initialize();
 $client-&gt;emit('message', ['title' =&gt; 'test']);
 $client-&gt;close();
}
catch (ServerConnectionFailureException $e)
{
 echo 'Server Connection Failure!!';
}
</code></pre>

blocks|key|153546|text|ElephantIO似乎已经死了。我找了很多发射器，this+one似乎是最快的，而且作者似乎很活跃，我建议做以下事情|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|153547|composer+require+ashiina/socket.io-emitter|code-block|syntax|javascript|153548|然后，在您的php文件中|153549|public+function+sendMessage($name,+$data)
{

++++$emitter+=+new+SocketIO\Emitter(array('port'+=>+strval($this->port),+'host'+=>+$this->ipv4));
++++$emitter->broadcast->emit($name,+$data);
++++
}|153550|当然你需要设置一个$port和一个$ipv4，但是这个包看起来又快又好用！您可以在socket.io服务器端使用@user1274820提供的相同代码来测试它|153551|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/ashiina/socket.io-php-emitter^0|Q|8|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|F|7|10|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|11|8|@]|9|@]|C|$]]|$1|K|3|L|5|F|7|12|8|@]|9|@]|C|$G|H]]|$1|M|3|N|5|6|7|13|8|@]|9|@]|C|$]]|$1|O|3|-4|5|6|7|14|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]]]

ElephantIO seems to be dead. I looked for a lot of emitters, and <a href="https://github.com/ashiina/socket.io-php-emitter" rel="nofollow noreferrer">this one</a> seems to be the fastest, and the author seems to be active, I would suggest doing the following
<pre><code>composer require ashiina/socket.io-emitter
</code></pre>
then, on your php file
<pre><code>public function sendMessage($name, $data)
{

 $emitter = new SocketIO\Emitter(array('port' =&gt; strval($this-&gt;port), 'host' =&gt; $this-&gt;ipv4));
 $emitter-&gt;broadcast-&gt;emit($name, $data);
 
}
</code></pre>
of course you need to set a $port and an $ipv4, but the package seems to be fast and easy to use! you can use the same code provided by @user1274820 on the socket.io server side to test it

blocks|key|153633|text|Socket+IO已更改内部代码，因此来自V2的所有连接都无法连接到V3，反之亦然。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|153634|github上的所有库都使用V2协议，所以如果你使用的是最新的socketIO+V3，让它在这些库上运行是一件很痛苦的事情。|153635|最简单的解决方案是使用“轮询”和CURL。|153636|我用symfony做了一个小教程，你可以直接在php上使用CURL，在这篇文章中：|153637|Socket.io+3+and+PHP+integration|offset|length|153638|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/questions/65527330/socket-io-3-and-php-integration/65572463#65572463^0|0|0|0|0|0|V|0|0^^$0|@$1|2|3|4|5|6|7|T|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|U|8|@]|9|@]|A|$]]|$1|D|3|E|5|6|7|V|8|@]|9|@]|A|$]]|$1|F|3|G|5|6|7|W|8|@]|9|@]|A|$]]|$1|H|3|I|5|6|7|X|8|@]|9|@$J|Y|K|Z|1|10]]|A|$]]|$1|L|3|-4|5|6|7|11|8|@]|9|@]|A|$]]]|M|$N|$5|O|P|Q|A|$R|S]]]]

Socket IO has changed internal code, so all connections from V2 cant connect to V3, and vice versa.
All the libraries on github uses the V2 protocol, so if you are using the latest socketIO V3, is a pain get it working on those libraries.
The simplest solution is to use &quot;polling&quot; and CURL.
I made a mini tutorial using symfony, you can use CURL directly on php, on this post:
<a href="https://stackoverflow.com/questions/65527330/socket-io-3-and-php-integration/65572463#65572463">Socket.io 3 and PHP integration</a>

blocks|key|153742|text|适用于socket.io版本3的全新答案|type|unstyled|depth|inlineStyleRanges|entityRanges|data|153743|https://github.com/socketio/socket.io-protocol#sample-session|offset|length|153744|正常工作的服务器示例：|153745|运行服务器直接/usr/local/bin/node+/socket_io/server/index.js|style|CODE|153746|或者通过‘永远’运行服务器|153747|/usr/local/bin/forever+-a+-l+/logs/socket.io/forever-log.log+-o+/logs/socket.io/forever-out.log+-e+/media/flashmax/var/logs/socket.io/forever-err.log+start+/socket_io/server/index.js|code-block|syntax|javascript|153748|index.js文件内容(接收请求)：|153749|var+io+=+require('/usr/local/lib/node_modules/socket.io')(8000);
//25-01-2021
//+socket.io+v3
//iptables+-I+INPUT+45+-p+tcp+-m+state+--state+NEW+-m+tcp+--dport+8000+-j+ACCEPT
//iptables+-nvL+--line-number
io.sockets.on('connection',+function+(socket)+{
++++socket.on('router',+function+(channel,newmessage)+{
//++console.log('router==========='%2Bchannel);
//++console.log('router-----------'%2Bnewmessage);
++++socket.broadcast.to(channel).emit('new_chat',newmessage);
++++});
++++socket.on('watch_for_me',+function+(chanelll)+{
++++++++socket.join(chanelll);
//console.log('user+watch+new+'%2Bchanelll);
++++});
++++socket.on('dont_watch',+function+(del_chanelll)+{
++++++++socket.leave(del_chanelll);
//console.log('user+go+out'+%2Bdel_chanelll);
++++});
});+|153750|从PHP发送的脚本|153751|<?php
//++php+-n+/socket_io/test.php
//++dl('curl.so');
//++dl('json.so');

$site_name='http://127.0.0.1:8000/socket.io/?EIO=4&transport=polling&t=mytest';
//+create+curl+resource
$ch+=+curl_init();

//Request+n°1+(open+packet)
//+set+url
curl_setopt($ch,+CURLOPT_URL,+$site_name);
//return+the+transfer+as+a+string
curl_setopt($ch,+CURLOPT_RETURNTRANSFER,+1);
//+$output+contains+the+output+string
$output+=+curl_exec($ch);
$output=substr($output,+1);
$decod=json_decode($output);

//Request+n°2+(namespace+connection+request):
$site_name2=$site_name.'&sid='.$decod->sid;
curl_setopt($ch,+CURLOPT_URL,+$site_name2);
curl_setopt($ch,+CURLOPT_POST,+true);
//+4+++++++++++=>+Engine.IO+"message"+packet+type
//+0+++++++++++=>+Socket.IO+"CONNECT"+packet+type
curl_setopt($ch,+CURLOPT_POSTFIELDS,+'40');
$output+=+curl_exec($ch);

//+Request+n°3+(namespace+connection+approval)
if+($output==='ok')++{
++curl_setopt($ch,+CURLOPT_URL,+$site_name2);
++curl_setopt($ch,+CURLOPT_RETURNTRANSFER,+1);
++$output+=+curl_exec($ch);
}

//+Request+n°4+socket.emit('hey',+'Jude')+is+executed+on+the+server:
if+($output==='ok')++{
curl_setopt($ch,+CURLOPT_URL,+$site_name2);
curl_setopt($ch,+CURLOPT_POST,+true);

$message_send='{\\"uuuuu\\":+\\"000\\",\\"ryyyd\\":\\"999\\",\\"hyyya\\":\\"<div+class=\'fro9\'>llll</div><div+class=\'9ig\'>iiiii</div><div+class=\'ti9g\'>iiiii</div>\\"}';

curl_setopt($ch,+CURLOPT_POSTFIELDS,+"42[\"router\",\"chanel@id\",\"$message_send\"]");
$output+=+curl_exec($ch);
print_r($output);
}

$message_send='send+2+message';
curl_setopt($ch,+CURLOPT_POSTFIELDS,+"42[\"router\",\"chanel@id\",\"$message_send\"]");
$output+=+curl_exec($ch);


$message_send='send+3+message';
curl_setopt($ch,+CURLOPT_POSTFIELDS,+"42[\"router\",\"chanel@id\",\"$message_send\"]");
$output+=+curl_exec($ch);

//+close+curl+resource+to+free+up+system+resources
curl_close($ch);++
?>|153752|额外好处:+apache+->+mod_proxy访问socket.io的设置，可用于虚拟主机或整个服务器。|153753|RewriteEngine+on
RewriteCond+%25{QUERY_STRING}+transport=polling++++[NC]
RewriteRule+/(.*)$+http://127.0.0.1:8000/$1+[P,L]
ProxyRequests+off
ProxyPass+/socket.io/+ws://127.0.0.1:8000/socket.io/
ProxyPassReverse+/socket.io/+ws://127.0.0.1:8000/socket.io/|153754|entityMap|0|LINK|mutability|MUTABLE|url^0|0|0|1P|0|0|0|7|1A|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|1B|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|1C|8|@]|9|@$D|1D|E|1E|1|1F]]|A|$]]|$1|F|3|G|5|6|7|1G|8|@]|9|@]|A|$]]|$1|H|3|I|5|6|7|1H|8|@$D|1I|E|1J|J|K]]|9|@]|A|$]]|$1|L|3|M|5|6|7|1K|8|@]|9|@]|A|$]]|$1|N|3|O|5|P|7|1L|8|@]|9|@]|A|$Q|R]]|$1|S|3|T|5|6|7|1M|8|@]|9|@]|A|$]]|$1|U|3|V|5|P|7|1N|8|@]|9|@]|A|$Q|R]]|$1|W|3|X|5|6|7|1O|8|@]|9|@]|A|$]]|$1|Y|3|Z|5|P|7|1P|8|@]|9|@]|A|$Q|R]]|$1|10|3|11|5|6|7|1Q|8|@]|9|@]|A|$]]|$1|12|3|13|5|P|7|1R|8|@]|9|@]|A|$Q|R]]|$1|14|3|-4|5|6|7|1S|8|@]|9|@]|A|$]]]|15|$16|$5|17|18|19|A|$1A|C]]]]

<h2>Fresh answer that works with socket.io version 3</h2>
<a href="https://github.com/socketio/socket.io-protocol#sample-session" rel="nofollow noreferrer">https://github.com/socketio/socket.io-protocol#sample-session</a>
Example of a working server:
run server direct <code>/usr/local/bin/node /socket_io/server/index.js</code>
or run server via 'forever'
<pre><code>/usr/local/bin/forever -a -l /logs/socket.io/forever-log.log -o /logs/socket.io/forever-out.log -e /media/flashmax/var/logs/socket.io/forever-err.log start /socket_io/server/index.js
</code></pre>
index.js file contents (receives requests):
<pre><code>var io = require('/usr/local/lib/node_modules/socket.io')(8000);
//25-01-2021
// socket.io v3
//iptables -I INPUT 45 -p tcp -m state --state NEW -m tcp --dport 8000 -j ACCEPT
//iptables -nvL --line-number
io.sockets.on('connection', function (socket) {
 socket.on('router', function (channel,newmessage) {
// console.log('router==========='+channel);
// console.log('router-----------'+newmessage);
 socket.broadcast.to(channel).emit('new_chat',newmessage);
 });
 socket.on('watch_for_me', function (chanelll) {
 socket.join(chanelll);
//console.log('user watch new '+chanelll);
 });
 socket.on('dont_watch', function (del_chanelll) {
 socket.leave(del_chanelll);
//console.log('user go out' +del_chanelll);
 });
}); 
</code></pre>
script that sends from PHP
<pre><code>&lt;?php
// php -n /socket_io/test.php
// dl('curl.so');
// dl('json.so');

$site_name='http://127.0.0.1:8000/socket.io/?EIO=4&amp;transport=polling&amp;t=mytest';
// create curl resource
$ch = curl_init();

//Request n°1 (open packet)
// set url
curl_setopt($ch, CURLOPT_URL, $site_name);
//return the transfer as a string
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
// $output contains the output string
$output = curl_exec($ch);
$output=substr($output, 1);
$decod=json_decode($output);

//Request n°2 (namespace connection request):
$site_name2=$site_name.'&amp;sid='.$decod-&gt;sid;
curl_setopt($ch, CURLOPT_URL, $site_name2);
curl_setopt($ch, CURLOPT_POST, true);
// 4 =&gt; Engine.IO &quot;message&quot; packet type
// 0 =&gt; Socket.IO &quot;CONNECT&quot; packet type
curl_setopt($ch, CURLOPT_POSTFIELDS, '40');
$output = curl_exec($ch);

// Request n°3 (namespace connection approval)
if ($output==='ok') {
 curl_setopt($ch, CURLOPT_URL, $site_name2);
 curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
 $output = curl_exec($ch);
}

// Request n°4 socket.emit('hey', 'Jude') is executed on the server:
if ($output==='ok') {
curl_setopt($ch, CURLOPT_URL, $site_name2);
curl_setopt($ch, CURLOPT_POST, true);

$message_send='{\\&quot;uuuuu\\&quot;: \\&quot;000\\&quot;,\\&quot;ryyyd\\&quot;:\\&quot;999\\&quot;,\\&quot;hyyya\\&quot;:\\&quot;&lt;div class=\'fro9\'&gt;llll&lt;/div&gt;&lt;div class=\'9ig\'&gt;iiiii&lt;/div&gt;&lt;div class=\'ti9g\'&gt;iiiii&lt;/div&gt;\\&quot;}';

curl_setopt($ch, CURLOPT_POSTFIELDS, &quot;42[\&quot;router\&quot;,\&quot;chanel@id\&quot;,\&quot;$message_send\&quot;]&quot;);
$output = curl_exec($ch);
print_r($output);
}

$message_send='send 2 message';
curl_setopt($ch, CURLOPT_POSTFIELDS, &quot;42[\&quot;router\&quot;,\&quot;chanel@id\&quot;,\&quot;$message_send\&quot;]&quot;);
$output = curl_exec($ch);


$message_send='send 3 message';
curl_setopt($ch, CURLOPT_POSTFIELDS, &quot;42[\&quot;router\&quot;,\&quot;chanel@id\&quot;,\&quot;$message_send\&quot;]&quot;);
$output = curl_exec($ch);

// close curl resource to free up system resources
curl_close($ch); 
?&gt;
</code></pre>
bonus: settings for apache -&gt; mod_proxy to access the socket.io which can be used for a virtual host or for the entire server.
<pre><code>RewriteEngine on
RewriteCond %{QUERY_STRING} transport=polling [NC]
RewriteRule /(.*)$ http://127.0.0.1:8000/$1 [P,L]
ProxyRequests off
ProxyPass /socket.io/ ws://127.0.0.1:8000/socket.io/
ProxyPassReverse /socket.io/ ws://127.0.0.1:8000/socket.io/
</code></pre>

I'm not too sure if I'm going about this in the right way. I want to stick with my Socket.IO server, and do not want to create a separate HTTP server within node. With this, can I create a PHP client that can send data (e.g.: player buys item from online shop) to the node Socket.IO server directly?

I've started with this:

<pre><code>&lt;?php

class communicator {
 public function connect($address, $port){
 $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

 if($socket){
 try {
 socket_connect($socket, $address, $port);
 } catch(Exception $e){
 throw new Exception($e-&gt;getMessage());
 }
 }else{
 throw new Exception('Could not create socket.');
 }
}

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

The socket seems to connect just fine to the node server, but how can I start receiving data directly from the PHP client?

E.g.: Say I use <code>socket_write</code> to send a message to the server. How do I get that through Socket.IO?

Hope my question makes sense!

PHP sending message to Node / Socket.IO server

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

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

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

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

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

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

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

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

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

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

我不太确定我是否以正确的方式来做这件事。我想继续使用我的Socket.IO服务器，而不想在节点中创建单独的HTTP服务器。有了这个，我可以创建一个可以直接发送数据(例如:玩家从网上商店购买商品)到节点Socket.IO服务器的客户端吗？我从这个开始：<?phpclass communicator { public ...

问PHP向Node / Socket.IO服务器发送消息
EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问PHP向Node / Socket.IO服务器发送消息EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问PHP向Node / Socket.IO服务器发送消息
EN