概念解释
什么是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
1import org.tio.msg.common.bs.msg.Message; 2public class DemoMessage extends Message { 3 private static final long serialVersionUID = -985195945448439158L; 4 private String name = "hello tio message"; 5 public String getName() { 6 return name; 7 } 8 public void setName(String name) { 9 this.name = name; 10 } 11}
DemoMessageListener.java
1 2import org.slf4j.Logger; 3import org.slf4j.LoggerFactory; 4import org.tio.msg.common.bs.msg.MessageListener; 5import org.tio.utils.json.Json; 6 7public class DemoMessageListener implements MessageListener<DemoMessage> { 8 private static Logger log = LoggerFactory.getLogger(DemoMessageListener.class); 9 public static final DemoMessageListener me = new DemoMessageListener(); 10 11 @Override 12 public void onMessage(String fromCid, DemoMessage message) { 13 log.warn("收到Tio Message, fromCid[{}], Message:\r\n{}", fromCid, Json.toFormatedJson(message)); 14 } 15}
启动类TioMsgDemoStarter.java
1 2import java.sql.SQLException; 3 4import org.slf4j.Logger; 5import org.slf4j.LoggerFactory; 6import org.tio.core.Node; 7import org.tio.msg.client.MsgClientStarter; 8import org.tio.msg.client.MsgApi; 9import org.tio.msg.common.utils.JsonInit; 10import org.tio.msg.common.utils.PropInit; 11import org.tio.utils.jfinal.P; 12 13/** 14 * @author tanyaowu 15 */ 16public class TioMsgDemoStarter { 17 private static Logger log = LoggerFactory.getLogger(TioMsgDemoStarter.class); 18 public static MsgClientStarter cluClientStarter = null; 19 /** 20 * 基本的初始化，一般用于单元小测试 21 * @throws SQLException 22 */ 23 public static void initBase() throws SQLException { 24 PropInit.init(new String[] { "app.properties" }); 25 JsonInit.init(); 26 } 27 /** 28 * @param args 29 * @author tanyaowu 30 */ 31 public static void main(String[] args) { 32 try { 33 initBase(); 34 //启动tio cluster client 35 Node cluServerNode = new Node(P.get("tio.clu.server.ip"), P.getInt("tio.clu.server.port")); 36 cluClientStarter = new MsgClientStarter(false, null, cluServerNode, null); 37 cluClientStarter.start(); 38 Thread.sleep(100L);//sleep一下，让各连接的握手完成，实际项目中，一般不需要这样 39 //添加listener 40 MsgApi.addListener(cluClientStarter.getClientTioConfig(), DemoMessage.class, DemoMessageListener.me); 41 for (int i =0; i < 1000; i++) { 42 //发布一个demo 消息 43 DemoMessage demoMessage = new DemoMessage(); 44 demoMessage.setName("hello tio message " + i); 45 MsgApi.publish(cluClientStarter.getClientTioConfig(), demoMessage, true); 46 } 47 } catch (Throwable e) { 48 log.error("", e); 49 System.exit(1); 50 } 51 } 52}
运行
1server:127.0.0.1:1982, client:0:0:0:0:0:0:0:0:13378 收到消息:MessageNtf 2 304-24 22:27:01 WARN o.t.m.demo.DemoMessageListener[20] 4收到Tio Message, fromCid[1385963494888697856], Message: 5{ 6 "name":"hello tio message" 7}