深入浅出Java分布式系统通信

　　一个socket连接在同一时间内传输多次请求的信息，输入通道接收多条响应消息，消息是连续发出，连续收回的。
　　业务处理和发消息是异步的，一个业务线程告诉通道发送消息后，不再占用通道，而是等待响应到达，而此时其它
　　业务线程也可以往该连接通道发信息，这样可以充分利用通道来进行通信。
　　实现挑战
　　但该方案使编码变得复杂，如上图，请求request1，request2，request3顺序发出，但是服务端处理请求并不是
　　排队的，而是并行处理的，有可能request3先于request1响应给客户端，那么一个request将无法找到他的response，
　　这时候我们需要在request和response报文中添加标识，如通信序列号，在一个通信通道里面保持，
　　那么可以根据序列号去获取对应的响应报文。
　　我的方案是:
　　1.客户端获取一个tcp连接
　　2.调用session.write()发送信息，并将消息的序列号存入一个Result对象
　　result对象存入一个map
　　3.同步阻塞获取结果，线程在result对象进行同步阻塞
　　4.接收消息，并通过序列号从map里面获取result对象，并唤醒阻塞在result对象上的线程
　　客户端发送消息示例代码：
public TransInfo send(TransInfo info) throws InterruptedException {
Result result = new Result();
result.setInfo(info);
//获取socket连接
ConnectFuture connectFuture = ConnectFutureFactory
.getConnection(result);
IoSession session = connectFuture.getSession();
//将result放入ConcurrentHashMap
ConcurrentHashMap<Long， Result> resultMap = (ConcurrentHashMap<Long， Result>)session.getAttribute("resultMap");
resultMap.put(info.getId()， result);
//发送消息
session.write(info);
//同步阻塞获取结果
return result.synGetInfo();
}
同步阻塞和唤醒方法：
public synchronized TransInfo synGetInfo() {
//等待消息返回
//必须要在同步的情况下执行
while (!done) {
try {
wait();
} catch (InterruptedException e) {
log.error(e.getMessage()， e);
}
}
return info;
}
public synchronized void synSetInfo(TransInfo info) {
this.info = info;
this.done = true;
notify();
}
　　接收消息示例代码：
　　public void messageReceived(IoSession session， Object message)
　　throws Exception {
　　TransInfo info = (TransInfo) message;
　　//根据序列号从resultMap中获取result
　　ConcurrentHashMap<Long， Result> resultMap = (ConcurrentHashMap<Long， Result>)session.getAttribute("resultMap");
　　//移除result
　　Result result = resultMap.remove(info.getId());
　　//唤醒阻塞线程
　　result.synSetInfo(info);
　　}
　　测试场景：
　　每个请求的业务处理时间110ms
　　300个线程10个连接并发测试，每个线程循环请求服务端
　　测试环境:
　　客户端服务器：
　　Cpu为4线程 2400mhz
　　服务端cpu: 4线程 3000Mhz
　　测试结果：
　　在经过10分钟测试之后，稳定情况下的tps
　　Tps:2600左右
　　客户端Cpu:25%
　　服务端cpu：250%
　　经测试发现，异步通信可以用更少的tcp连接实现同样高效的通信，极大的减少了系统性能开销。
　　暂时写到这里。