乐趣区

关于java:为RPC而生的tio企业集群版的msg服务器tiomsgdemo你应该感兴趣

jiezi

概念解释
什么是 RPC（Remote Procedure Call）近程过程调用，是一种通过网络从近程计算机程序上申请服务，实现某个业务，然而不须要具体理解底层网络技术的协定。t-io 把程序中对外实现通信的各个协定模块进行了打包解决成一个盒子，下层利用对外通信就只有对接盒子的接口，而不用关怀盒子外面的内容，RPC 服务要对外实现近程调用，首先要跟 t -io 通信，再到远方的服务。
为什么要应用 RPC 呢？如果一个零碎（例如，网站、大型利用等）中外部子系统较多、接口也十分多的状况下，采纳 RPC 的益处就很显著了，RPC 中采纳的长链接，不用每次通信都要像有些协定一样每次都要进行 3 次握手来建设连贯，例如，HTTP 协定，这样就能缩小了网络开销；其次，就是 RPC 中个别都有注册核心，而且有丰盛的监控治理模块；利用方要进行公布、捆绑下线接口、动静扩大等，对调用方来说能够是无感知、归一化的操作。而且 RPC 的安全性也很好。
可见 RPC 上面如果有一个十分高效的网络编程框架配合，应用起来会很不便，因为 t -io 中内置了 socket、NIO 性能，所以跟 RPC 对接具备人造的劣势，当然也能够应用 netty，然而 netty 的应用起来比 t -io 会简单很多。
基于 t -io 开发的最胜利即时通讯软件—谭聊，曾经完整的实现 RPC 的性能，具体请参考:https://www.tiocloud.com/1/blog/1385967412607852544?type=screen-category
msg 服务器介绍
企业集群版的 t -io，曾经实现了 msg 服务器。自从有了集群服务器后，做 rpc, 做 msg 都是很容易的事了！对于有 RPC 业务需要的老铁又是一大福音。咱们本人开发的 IM 聊天工具—谭聊中曾经验证的十分完满了。废话不多说，请看具体实现代码。
示范代码
DemoMessage.java

package org.tio.msg.demo;
import org.tio.msg.common.bs.msg.Message;
public class DemoMessage extends Message {
    private static final long    serialVersionUID    = -985195945448439158L;
    private String                name                = "hello tio message";
    public String getName() {return name;}
    public void setName(String name) {this.name = name;}
}

DemoMessageListener.java

package org.tio.msg.demo;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.tio.msg.common.bs.msg.MessageListener;
import org.tio.utils.json.Json;
 
public class DemoMessageListener implements MessageListener<DemoMessage> {private static Logger                    log    = LoggerFactory.getLogger(DemoMessageListener.class);
    public static final DemoMessageListener    me    = new DemoMessageListener();
 
    @Override
    public void onMessage(String fromCid, DemoMessage message) {log.warn("收到 Tio Message, fromCid[{}], Message:\r\n{}", fromCid, Json.toFormatedJson(message));
    }
}

启动类 TioMsgDemoStarter.java

package org.tio.msg.demo;
 
import java.sql.SQLException;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.tio.core.Node;
import org.tio.msg.client.MsgClientStarter;
import org.tio.msg.client.MsgApi;
import org.tio.msg.common.utils.JsonInit;
import org.tio.msg.common.utils.PropInit;
import org.tio.utils.jfinal.P;
 
/**
 * @author tanyaowu
 */
public class TioMsgDemoStarter {private static Logger log = LoggerFactory.getLogger(TioMsgDemoStarter.class);
    public static MsgClientStarter cluClientStarter = null;
    /**
     * 根本的初始化，个别用于单元小测试
     * @throws SQLException 
     */
    public static void initBase() throws SQLException {PropInit.init(new String[] {"app.properties"});
        JsonInit.init();}
    /**
     * @param args
     * @author tanyaowu
     */
    public static void main(String[] args) {
        try {initBase();
            // 启动 tio cluster client
            Node cluServerNode = new Node(P.get("tio.clu.server.ip"), P.getInt("tio.clu.server.port"));
            cluClientStarter = new MsgClientStarter(false, null, cluServerNode, null);
            cluClientStarter.start();
            Thread.sleep(100L);//sleep 一下，让各连贯的握手实现，理论我的项目中，个别不须要这样
            // 增加 listener
            MsgApi.addListener(cluClientStarter.getClientTioConfig(), DemoMessage.class, DemoMessageListener.me);
            for (int i =0; i < 1000; i++) {
                // 公布一个 demo 音讯
                DemoMessage demoMessage = new DemoMessage();
                demoMessage.setName("hello tio message" + i);
                MsgApi.publish(cluClientStarter.getClientTioConfig(), demoMessage, true);
            }
        } catch (Throwable e) {log.error("", e);
            System.exit(1);
        }
    }
}

运行

04-24 22:27:01 INFO  o.t.c.client.PacketDispatcher[102]
server:127.0.0.1:1982, client:0:0:0:0:0:0:0:0:13378 收到音讯:MessageNtf
 
04-24 22:27:01 WARN  o.t.m.demo.DemoMessageListener[20]
收到 Tio Message, fromCid[1385963494888697856], Message:
{"name":"hello tio message"}
退出移动版