基于SWOOLE的高可用分布式SOKET服务器系统搭建V2.0

时间 2019-11-09

标签基于 swoole 可用分布式 soket 服务器系统搭建 v2.0 栏目系统架构繁體版

原文原文链接

基于SWOOLE的高可用分布式SOKET服务器系统搭建V2.0

做者: hope
时间: October 30, 2014
分类: php

昨天初步实现了不一样聊天服务器消息互发,但效率很差，且有性能瓶颈，Swoole的做者韩天峰提醒可使用长链接转发消息，今天测试了一遍，效果不错。php

上一篇的逻辑讲的不是很清楚，此次清楚的描述下：现有A、B两台消息服务器，用户1链接在服务器A，用户2链接在服务器B，而用户1须要给用户2发送消息，因为Socket链接在不一样服务器，没法直接互通。现有两种办法解决：redis

1. 消息服务器进行串联json

优势centos

不用单独增长服务器来作proxy，服务器与服务器之间可酌情采用长链接/短连接。服务器

消息少一次传输，能够减小网络消耗。swoole
缺点网络

每台服务器必须和剩下的全部服务器创建链接。若是其中任意一个链接断掉，都会影响服务，服务器多的时候也不利于监控服务状态。异步

2. 单独使用服务器作转发并联socket

优势分布式

消息服务器专一于消息收发，再也不发起Client，专一于服务端自己。

转发服务器发起Client链接全部消息服务器，利于监控服务器状态，并且转发服务器宕机不影响消息服务器，对用户的影响时间短。

可使用keepalived来给转发服务器作高可用，或者把转发服务器作成链接池，进一步减轻单台服务器的压力。

更能够把一个转发服务器和几台消息服务器作成一个节点，再把这些节点组合起来，能够知足超大的即时通信服务。
缺点

因为消息经过转发服务器，会比直接串联多一次数据传输，增长了网络消耗。

暂时没想到其余的。

开始搭建

流程图

环境

全部测试在虚拟机上进行：

主机

os  Ubuntu14.10 64位
cpu 4 core
mem 16 G
soft Virtual box

虚拟机

centos 6.5 mini swoole php//
192.168.0.201   //socket1 消息服务器
192.168.0.202   //socket2 消息服务器
192.168.0.203   //proxy   转发服务器
192.168.0.231   //Redis

客户端
```
telnet
```

编码

消息服务器

因为消息服务器再也不发起客户端链接,因此代码要精简不少。直接上测试代码：

<?php

/**
 * @filename server.php
 * @encoding UTF-8
 * @author CaiXin Liao <king.liao@qq.com>
 * @link http://www.51zhima.com
 * @copyright 51zhima@CopyRight
 * @datetime 2014-10-28 15:09:54
 * @version 1.0
 * @Description 
 */
//服务端
$serv = new swoole_server("0.0.0.0", 9501);

//redis
$redis = new \Redis();
$redis->connect("192.168.0.231", 6379);

//Server
$serv->on('start', function($serv) {
    echo "Service:Start...";
});
$serv->on('connect', function ($serv, $fd) {

});
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
    global $redis;

    $data = (array) json_decode($data);
    $cmd = $data['cmd'];

    switch ($cmd) {

        case "login"://登录
            //保存链接信息
            $save = array(
                'fd' => $fd,
                'socket_ip' => "192.168.0.201"
            );
            $redis->set($data['name'], serialize($save));
            break;

        case "chat":
            $recv = unserialize($redis->get($data['recv']));
            if ($recv['socket_ip'] != "192.168.0.201") {//发消息给proxy
               $proxy = unserialize($redis->get('192.168.0.201_router'));
                //须要转发
                $data['recv_ip'] = $recv['socket_ip'];
                $serv->send($proxy['fd'], json_encode($data));
            } else {
                //直接发送
                $serv->send($recv['fd'], "{$data['send']}给您发了消息：{$data['content']}\n");
            }
            break;
    }
});
$serv->on('close', function ($serv, $fd) {
    echo "Client: Close.\n";
});

$serv->start();

不一样的消息服务器只需修改ip便可。

转发服务器

转发服务器须要遍历链接全部的消息服务器，而且采用异步的方式，测试代码：

<?php

/**
 * @filename proxy.php
 * @encoding UTF-8
 * @author CaiXin Liao <king.liao@qq.com>
 * @link http://www.51zhima.com
 * @copyright 51zhima@CopyRight
 * @datetime 2014-10-29 15:50:37
 * @version 1.0
 * @Description 
 */

$clients = array();
$servers = array(
    '192.168.0.201',
    '192.168.0.202',
);
for ($i = 0; $i < count($servers); $i++) {
    $clients[$servers[$i]] = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
    $clients[$servers[$i]]->remote_ip = $servers[$i];
    $clients[$servers[$i]]->on("connect", function(swoole_client $cli) {
        $data = array(
            'cmd'=>'login',
            'name'=>$cli->remote_ip . '_router',
        );
        $cli->send(json_encode($data));
        echo $cli->remote_ip . " Connect Success \n";
    });

    $clients[$servers[$i]]->on("receive", function (swoole_client $cli, $data) {
        $msg = (array) json_decode($data);
        $remote_ip = $msg['recv_ip'];
        unset($msg['recv_ip']);
        global $clients;
        $clients[$remote_ip]->send(json_encode($msg));
    });
    $clients[$servers[$i]]->on("error", function(swoole_client $cli) {
        echo "{$cli->remote_ip} error\n";
    });

    $clients[$servers[$i]]->on("close", function(swoole_client $cli) {
        echo "{$cli->remote_ip} Connection close\n";
    });
    $clients[$servers[$i]]->connect($servers[$i], 9501, 0.5);
}

测试

开启全部的虚拟机，同步脚本，这里在proxy脚本里没有作监控和链接状态检测，这里只作简单的消息发送测试。

开启消息服务器1：
开启消息服务器2：
开启转发服务器
telnet登录两个用户到socket1和socket2
如今用户2给用户1发送消息测试

成功收到消息，后面就是进行针对性的优化了。

消息格式

{"cmd":"login","name":"zhima201"} //登录消息
{"cmd":"chat","send":"zhima201","recv":"zhima202","content":"how are youe"}//文本消息