walkor大神,请教一个socket相关的问题
现在情况是这样的,我要写一个将MySQL数据同步到ES的服务,方案是将MySQL binlog日志解析成结构化的数据,然后写入ES,解析binlog的是一个php cli 单进程,死循环获取binlog数据,因为怕数据太多,消费能力跟不上,想着用workerman多个worker进程处理,但是多个worker进程存在的问题是有序性问题,同一张表的事件只能同时由一个worker进程处理,我目前的想法是缓存了几个缓存了几个socket链接,然后根据表名去走对应的socket链接发送消息,不确定这样子稳不稳定。// 启动4个进程对外提供服务
$worker->count = 6;
$worker->name = 'write_es';
Worker::$logFile = __DIR__ . '/' .读取推送结果
echo fread($client, 8192);
}
function getTableFromEvent($event) {
//逻辑没实现,大概就是不同的增删改查返回不同的表名