socket.io与workerman的问题-php教程-PHP中文网

socket.io与workerman的问题

php中文网

发布： 2016-06-06 20:27:35

原创

2662人浏览过

有谁玩过这两个东西吗？这两个都能使用websocket协议，
而且workerman服务器的onConnect都已经执行了，说明客户端和服务器是能联系的。
但是为什么刚一连接上马上就断开了呢？而且服务器也没有收到客户端发送的信息。

workerman服务端代码：

use Workerman\Worker;
require_once '../Workerman/Autoloader.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$ws_worker->count = 4;

$worker->onConnect = function($connection)
{
echo "new connection from ip " . $connection->getRemoteIp() . "\n";

};

$worker->onMessage = function($connection, $data)
{
var_dump($data);
$connection->send('receive success');
};

$worker->onError = function($connection, $code, $msg)
{
echo "error $code $msg\n";
};

$worker->onBufferFull = function($connection)
{
echo "bufferFull and do not send again\n";
};
$worker->onBufferDrain = function($connection)
{
echo "buffer drain and continue send\n";
};

$worker->onClose = function($connection)
{
echo "connection closed\n";
};

$worker->onWorkerStop = function($worker)
{
echo "Worker stopping...\n";
};

$worker->onWorkerStart = function($worker)
{
echo "Worker starting...\n";
};

登录后复制

客户端代码：用的是socket.io，这是一个android应用

private Socket mSocket;
{
    try {
        mSocket = IO.socket("websocket://192.168.0.11:8484");
    } catch (URISyntaxException e) {}
}

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main_activity1);

    mSocket.connect();
    mSocket.emit("hello", "hello world");
    mSocket.emit("emit something");
    mSocket.send("send something");
    mSocket.send("hello","thanks");

}

登录后复制

为什么会出现刚连接就断开的情况呢，信息也没有收到。这面这些是服务器收到的信息。

new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3

登录后复制

回复内容：

workerman服务端代码：

use Workerman\Worker;
require_once '../Workerman/Autoloader.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$ws_worker->count = 4;

$worker->onConnect = function($connection)
{
echo "new connection from ip " . $connection->getRemoteIp() . "\n";

};

$worker->onMessage = function($connection, $data)
{
var_dump($data);
$connection->send('receive success');
};

$worker->onError = function($connection, $code, $msg)
{
echo "error $code $msg\n";
};

$worker->onBufferFull = function($connection)
{
echo "bufferFull and do not send again\n";
};
$worker->onBufferDrain = function($connection)
{
echo "buffer drain and continue send\n";
};

$worker->onClose = function($connection)
{
echo "connection closed\n";
};

$worker->onWorkerStop = function($worker)
{
echo "Worker stopping...\n";
};

$worker->onWorkerStart = function($worker)
{
echo "Worker starting...\n";
};

登录后复制

客户端代码：用的是socket.io，这是一个android应用

Ztoy网络商铺多用户版

在原版的基础上做了一下修正：增加1st在线支付功能与论坛用户数据结合，vip也可与论坛相关，增加互动性vip会员的全面修正评论没有提交正文的问题特价商品的调用连接问题删掉了2个木马文件去掉了一个后门补了SQL注入补了一个过滤漏洞浮动价不能删除的问题不能够搜索问题收藏时放入购物车时出错点放入购物车弹出2个窗口修正定单不能删除问题VIP出错问题主题添加问题商家注册页导航连接问题添加了导航FLASH源文

查看详情

private Socket mSocket;
{
    try {
        mSocket = IO.socket("websocket://192.168.0.11:8484");
    } catch (URISyntaxException e) {}
}

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main_activity1);

    mSocket.connect();
    mSocket.emit("hello", "hello world");
    mSocket.emit("emit something");
    mSocket.send("send something");
    mSocket.send("hello","thanks");

}

登录后复制

为什么会出现刚连接就断开的情况呢，信息也没有收到。这面这些是服务器收到的信息。

new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3
connection closed
new connection from ip 192.168.0.3

登录后复制

https://github.com/walkor/phpsocket.io
这里有php版本的socket.io，应该也是基于workerman做的

socket.io的客户端封装了自己的协议，不能直接连workman吧？