期待大佬能基于rdkafka封装一个webman能用扩展？
最近要和大数据部门合作，处理下他们的kafka-topic的数据，打算用webman的自定义进程实现，找了几个包， nmred/kafka-php // 这个包里面有amphp ，在start的时候会多启动一个进程去消费，担心在webman的自定义进程中没法很好的管理， 所以打算放弃。 longlang/phpkafka // 这个包可在fpm和swoole下使用，但是还没出正式版，放弃了。 目前是这两个包 下载量比...
请教使用socket做为客户端和北向接口对接，请教如何打包数据发送。
实时告警采用消息方式，采用socket/tcp协议，OMC为socket的server端，NMS为socket的client端。 5.3.1 消息格式 消息数据由消息头和消息体组成。消息头由9个字节（byte）表示，消息体长度不固定，各类消息不同。消息头的9个字节不能当做字符处理，需要按整型数处理。 上面是文档，下面是我的代码部分，代码是有问题的。 $con->onConnect = function(As...
tanhongbin
7626
积分
0
获赞数
0
粉丝数
2021-08-23 加入