GateWayWorker2
2016-06-18 14:48:44 0 举报GateWayWorker2是一个高性能、高可用的分布式任务调度与执行框架。它主要用于解决大规模数据处理和计算问题，通过将任务分解为多个子任务并分配给多台服务器并行执行，从而实现任务的高效处理。GateWayWorker2具有丰富的功能和灵活的配置选项，支持多种任务类型，如MapReduce、Spark等。同时，它还提供了完善的监控和管理功能，方便用户实时了解任务执行情况，快速定位和解决问题。通过使用GateWayWorker2，企业可以大幅提高数据处理速度，降低运维成本，实现业务的快速扩展。
作者其他创作
大纲/内容
onWorkerConnect事件
GateWay启动
返回连接对象$worker_connections[$clientConnection-businessworker_address]
Key-1 : $BusniessWorkConnection
Key-2 : $BusniessWorkConnection
当前：$clientConnection是否设置$businessworker_address或者当前GateWay $worker_connections数组是否保存了$businessworker_address这个键
fork子进程
Key-n : $BusniessWorkConnection
带上返回数据
Lib\\GateWay
Client
Route
通过$client_id找到与Client连接的GateWay进程
1，127.0.0.1:29002，127.0.0.1:2901....n，127.0.0.1:nnnn
创建连接
创建Socket监听
与每个GateWay子进程创建连接
GateWay选择一条BusinessWork进程为Client服务并绑定ClientConnection到该BusinessWork子进程
Key-3 : $BusniessWorkConnection
businesswork_子进程
创建Socket，监听指定端口
GateWay子进程
1，127.0.0.1:29002，127.0.0.1:2901....n，127.0.0.1:nnnn广播给每个BusinessWok子进程
BusinessWork启动
...............
evenHandle(Events)
businesswork子进程
Register启动
GateWay共享内存
收藏
收藏
0 条评论
下一页
为你推荐
查看更多
