+
80
-

swoole怎么同时监听websocket和http端口服务?

php
swoole怎么同时监听websocket和http端口服务?

网友回复

+
0
-
<?php
$server = new Swoole\WebSocket\Server("0.0.0.0", 9514, SWOOLE_BASE);

$http = $server->listen("0.0.0.0", 9515, SWOOLE_SOCK_TCP);

$server->on("open", function ($serv, $req) {
    echo "new WebSocket Client, fd={$req->fd}\n";
});

$server->on("message", function ($serv, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
    $serv->push($frame->fd, "this is server OnMessage");
});
$http->set([
    'open_http_protocol' => true, // 设置这个端口关闭http协议功能
]);
$http->on("request", function ($request, $response) {

    $response->header("Content-Type", "text/plain");
    $response->end("ok");
});

$server->start();

+
0
-

还有一种就是同一个端口实现websocket和http服务,只要在set中增加一条 'open_http_protocol' => true,

并且实现onrequest的回调即可,代码如下:

<?php

$server = new Swoole\Websocket\Server("0.0.0.0", 9502);
$server->set([
    'open_http_protocol' => true,
]);

$server->on('open', function($server, $req) {
    echo "connection open: {$req->fd}\n";
});
$server->on('request', function($request, $response) {

    $response->header("Content-Type", "text/html; charset=utf-8");
    $response->end("<h1>OK.</h1>");

});
$server->on('message', function($server, $frame) {
    echo "received message: {$frame->data}\n";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

$server->on('close', function($server, $fd) {
    echo "connection close: {$fd}\n";
});

$server->start();

我知道答案,我要回答