分布式部署多个gateway时，不同的client如何通信？ about gatewayworker HOT 8 CLOSED

需要带上，不然怎么知道给谁发呢，必须有个id标示

from gatewayworker.

向某个用户的网关发送消息函数：
protected static function sendCmdAndMessageToClient($client_id, $cmd, $message, $ext_data = '')
{
// 如果是发给当前用户则直接获取上下文中的地址
if ($client_id === Context::$client_id || $client_id === null) {
$address = long2ip(Context::$local_ip) . ':' . Context::$local_port;
$connection_id = Context::$connection_id;
} else {
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return false;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
$connection_id = $address_data['connection_id'];
}
businessworker接收gateway发送的消息回调：
public function onGatewayMessage($connection, $data){
// 上下文数据
Context::$client_ip = $data['client_ip'];
Context::$client_port = $data['client_port'];
Context::$local_ip = $data['local_ip'];
Context::$local_port = $data['local_port'];
Context::$connection_id = $data['connection_id'];
Context::$client_id = Context::addressToClientId($data['local_ip'], $data['local_port'],
$data['connection_id']);
...
// 尝试执行 Event::onConnection、Event::onMessage、Event::onClose
switch ($cmd) {
case GatewayProtocol::CMD_ON_CONNECT:
if ($this->_eventOnConnect) {
call_user_func($this->_eventOnConnect, Context::$client_id);
}
break;
case GatewayProtocol::CMD_ON_MESSAGE:
if ($this->_eventOnMessage) {
call_user_func($this->_eventOnMessage, Context::$client_id, $data['body']);
}
break;
}
可以看到eventOnMessage接收的client_id参数就是 Context::$client_id, 所以gateway分布部署在多台机器时，这种路由怎么实现的呢？

from gatewayworker.

http://doc2.workerman.net/principle.html
这里有原理图

from gatewayworker.

你好，我之前看到原理图了，只是在代码里面没有找到这部分的路由过程。是不是这个需要客户端c1给c2发消息的时候，包含c2的client_id进去，然后这个路由过程由业务代码自己实现？

from gatewayworker.

路由是自动的，需要带上client_id

from gatewayworker.

比如c1给c2发消息，是要带上c2的client_id吗？如果是，那我就明白了，谢谢。

from gatewayworker.

好的，谢谢~

from gatewayworker.

不客气

from gatewayworker.