Yii2 swool websocket поддерживает jsonrpc для доставки асинхронных задач работникам через WS, HTTP и redis

https://github.com/immusen/yii2 – свул -websocket

Пример:

Случай чата, пример кода: websocket/Контроллеры/контроллер комнаты. php

Отправить сообщение:

{
        "jsonrpc":"2.0",
        "id":1,
        "method":"room/msg",
        "params":{
            "id":"100111",
            "content":{
                "text":"Hello world!"
            }
        }
    }

Участники чата получают сообщения:

{
        "jsonrpc":"2.0",
        "id":1,
        "result":{
            "text":"Hello world!"
        }
    }

Развитие:

1. Создайте контроллер в каталоге websocket/контроллеры (это также может быть другой путь, просто измените конфигурацию пространства имен контроллеров в конфигурации/main.php)

addFds($this->fd, $param_1);
          
          #Send information to the current websocket client
          $this->publish($this->fd, ['p1' => param_1, 'p2' => param_2]);
          
          #Take all customer degrees FD from the set
          $fds_array = $this->getFds($param_1);
          
          #Group messages to clients in the collection
          $this->publish($fds_array, ['p1' => param_1, 'p2' => param_2]);
          
          #Operating redis through redis connection pool
          $this->redis->set($param_1, 0)
     }
     
     public function actionBaz()
     {
          //...
     }
}

2. Отправьте jsonrpc, укажите метод как “foo/bar” и передайте соответствующие параметры через параметры, чтобы вызвать вышеуказанное действие

    {
        "jsonrpc":"2.0",
        "id":1,
        "method":"foo/bar",
        "params":{
            "param_1":"client_01",
            "param_2":100,
            "param_n":{
                "time":1551408888,
                "type":"report"
            }
        }
    }

В дополнение к клиенту websocket все вызовы RPC от клиента к серверу также могут быть доставлены с помощью HTTP или публикации redis. Эта функция может быть использована веб-приложением Yii для доставки асинхронных задач (таких как отправка SMS..) работнику swool. В примере с комнатой чата вы можете сделать следующее:

HTTP-запрос:

http://127.0.0.1:8721/rpc?p={"jsonrpc":"2.0","id":1,"method":"room/msg","params":{"id":"100111","content":{"text":"System warning!"}}}

Или redis cli:

127.0.0.1:6379> publish rpc '{"jsonrpc":"2.0","id":1,"method":"room/msg","params":{"id":"100111","content":{"text":"System warning!"}}}'

Или в веб-приложении Yii

Yii:$app->redis->publish('rpc', '{"jsonrpc":"2.0","id":1,"method":"room/msg","params":{"id":"100111","content":{"text":"System warning!"}}}')

Или с помощью hook (рекомендуемый метод) поддерживается RunOnce, чтобы гарантировать, что задача может быть выполнена только один раз, даже в случае нескольких экземпляров swool. См. immusen/yii2-swool-websocket/крюк.php для получения подробной информации

Yii::$app->hook->run('room/msg', ['id' => 100111, 'content' => ['text' => 'System warning!']]);
Yii::$app->hook->runOnce('sms/send', ['mobile' => 15600008721, 'code' => '8721']);

Новое обновление: сценарий запуска поддерживает больше операций

./websocket-сервер {запуск|перезапуск|перезагрузка|остановка|состояние}

./websocket-server status
master_pid=7404
start_time=1554030075
connection_num=130
accept_count=1025767
close_count=1025637
tasking_num=123
request_count=2051456
worker_request_count=511103
coroutine_num=2

Читайте ещё по теме: