pulsarwebsocketclient/pulsarclient

这是用于 pulsar WebSocket 客户端

维护者

详细信息

github.com/dongzhouzhoudz/phppulsarclient

源代码

问题

安装: 12

依赖: 0

建议者: 0

安全性: 0

星星: 2

关注者: 1

分支: 1

开放问题: 1

1.1.0 2021-11-18 07:07 UTC

Requires

MIT f517b7059afad930925e7d20de9624332cb5bafe

  • ZhouDong <zhoudong.woop@zz-med.com>

This package is auto-updated.

Last update: 2024-09-18 13:15:45 UTC

README

PHP Pulsar 客户端 WebSocket

此客户端用于 Php 队列服务

目前仅包含 pulsar 和 redis 客户端

如何使用 Pulsar 队列服务

 use ZZQueueService\QueueService;
 
 $queueService = QueueService::getPulsarQueue([
             "url" => "111.111.0.60:8080",
             "tenant"=>"socket",
             "namespace"=>"socket_namespace",
             "topic"=>"socket_topic"
         ]);
 
 $array = ["a"=>"b","c"=>"d"];
 for ($i=0;$i<100;$i++) {
         $queueService->produceMessage($array);
         sleep(2);
   }

如何使用 Redis 队列服务

       $queueService = QueueService::getRedisQueue(["params"=>'tcp://192.168.33.30:6379',"qname"=>"test_redis_queue"]);
        $queueService->produceMessage("show me code");

        $queueService->consumerMessage(function($msg){
            print_r($msg);
        });