首页
下载
文档
社区
视频
捐赠
源代码
赞助商
AOT 编译器
AI 助理
商业产品
PHP AOT 原生编译器
Swoole-Compiler 代码加密器
CRMEB 新零售社交电商系统
登录
注册
全部
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
发表新帖
如何用swool从kafka拉取日志,进行处理
我现在用swool做的日志服务,想用swool从kafka实时的拉取日志,然后进行处理.问题是swool做守护进程拉取日志的实现方法是什么?用swool定时器不停的拉取吗?还是直接写一个while循环?
发布于9年前 · 3 次浏览 · 来自
提问
w
webstar
我现在用swool做的日志服务,想用swool从kafka实时的拉取日志,然后进行处理.问题是swool做守护进程拉取日志的实现方法是什么?用swool定时器不停的拉取吗?还是直接写一个while循环?
赞
0
收藏
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
登录
后参与评论
评论
2016-12-24
夏
夏天
可以用swoole_client实现一个kafka的客户端，与kafka服务器通信拉取数据。
赞
0
回复
2016-12-24
Ж
Жуковаский
我现在准备使用swool的process模块+kafka的php扩展来做.一个守护的master进程专门拉取数据,然后启动几个workder进程来处理数据(发送http请求). 代码如下: <?php $workers = []; $worker_num = 2; date_default_timezone_set('Asia/Shanghai'); for($i = 0; $i < $worker_num; $i++) { $process = new swoole_process(
赞
0
回复
2017-01-07
向
向前跑
父进程读取管道即可$process->read()，管道就是在本端写在对端就可以读。$process对象在子进程执行write，父进程就可以执行read。同样父进程调用write，子进程就可以执行read拿到数据。
赞
0
回复