如何自己做网站并开发软件,wordpress修改图片地址,WordPress推荐版本,wordpress html5插件由于Dubbo底层采用Socket进行通信#xff0c;自己对通信理理论也不是很清楚#xff0c;所以顺便把通信的知识也学习一下。 n 通信理论 计算机与外界的信息交换称为通信。基本的通信方法有并行通信和串行通信两种。 1.一组信息#xff08;通常是字节#xff09;的各位数据被…由于Dubbo底层采用Socket进行通信自己对通信理理论也不是很清楚所以顺便把通信的知识也学习一下。 n 通信理论 计算机与外界的信息交换称为通信。基本的通信方法有并行通信和串行通信两种。 1.一组信息通常是字节的各位数据被同时传送的通信方法称为并行通信。并行通信依靠并行IO接口实现。并行通信速度快但传输线根数多只适用于近距离相距数公尺的通信。 2.一组信息的各位数据被逐位顺序传送的通信方式称为串行通信。串行通信可通过串行接口来实现。串行通信速度慢但传输线少适宜长距离通信。 串行通信按信息传送方向分为以下3种 1) 单工 只能一个方向传输数据 2) 半双工 信息能双向传输但不能同时双向传输 3) 全双工 能双向传输并且可以同时双向传输 n Socket Socket 是一种应用接口, TCP/IP 是网络传输协议虽然接口相同, 但是不同的协议会有不同的服务性质。创建Socket 连接时可以指定使用的传输层协议Socket 可以支持不同的传输层协议TCP 或UDP 当使用TCP 协议进行连接时该Socket 连接就是一个TCP 连接。Soket 跟TCP/IP 并没有必然的联系。Socket 编程接口在设计的时候就希望也能适应其他的网络协议。所以socket 的出现只是可以更方便的使用TCP/IP 协议栈而已。 引自http://hi.baidu.com/lewutian/blog/item/b28e27fd446d641d09244d08.html 上一个通信理论其实是想说Socket(TCP)通信是全双工的方式 n Dubbo远程同步调用原理分析 从Dubbo开源文档上了解到一个调用过程如下图 http://code.alibabatech.com/wiki/display/dubbo/UserGuide#UserGuide-APIReference 另外文档里有说明Dubbo缺省协议采用单一长连接和NIO异步通讯适合于小数据量大并发的服务调用以及服务消费者机器数远大于服务提供者机器数的情况。 Dubbo缺省协议使用基于mina1.1.7hessian3.2.1的tbremoting交互。 连接个数单连接连接方式长连接传输协议TCP传输方式NIO异步传输序列化Hessian二进制序列化适用范围传入传出参数数据包较小建议小于100K消费者比提供者个数多单一消费者无法压满提供者尽量不要用dubbo协议传输大文件或超大字符串。适用场景常规远程服务方法调用 通常一个典型的同步远程调用应该是这样的 1 客户端线程调用远程接口向服务端发送请求同时当前线程应该处于“暂停“状态即线程不能向后执行了必需要拿到服务端给自己的结果后才能向后执行 2 服务端接到客户端请求后处理请求将结果给客户端 3 客户端收到结果然后当前线程继续往后执行 Dubbo里使用到了Socket采用apache mina框架做底层调用来建立长连接发送、接收数据底层使用apache mina框架的IoSession进行发送消息。 查看Dubbo文档及源代码可知Dubbo底层使用Socket发送消息的形式进行数据传递结合了mina框架使用IoSession.write()方法这个方法调用后对于整个远程调用(从发出请求到接收到结果)来说是一个异步的即对于当前线程来说将请求发送出来线程就可以往后执行了至于服务端的结果是服务端处理完成后再以消息的形式发送给客户端的。于是这里出现了2个问题 当前线程怎么让它“暂停”等结果回来后再向后执行正如前面所说Socket通信是一个全双工的方式如果有多个线程同时进行远程方法调用这时建立在client server之间的socket连接上会有很多双方发送的消息传递前后顺序也可能是乱七八糟的server处理完结果后将结果消息发送给clientclient收到很多消息怎么知道哪个消息结果是原先哪个线程调用的 分析源代码基本原理如下 client一个线程调用远程接口生成一个唯一的ID比如一段随机字符串UUID等Dubbo是使用AtomicLong从0开始累计数字的将打包的方法调用信息如调用的接口名称方法名称参数值列表等和处理结果的回调对象callback全部封装在一起组成一个对象object向专门存放调用信息的全局ConcurrentHashMap里面put(ID, object)将ID和打包的方法调用信息封装成一对象connRequest使用IoSession.write(connRequest)异步发送出去当前线程再使用callback的get()方法试图获取远程返回的结果在get()内部则使用synchronized获取回调对象callback的锁 再先检测是否已经获取到结果如果没有然后调用callback的wait()方法释放callback上的锁让当前线程处于等待状态。服务端接收到请求并处理后将结果此结果中包含了前面的ID即回传发送给客户端客户端socket连接上专门监听消息的线程收到消息分析结果取到ID再从前面的ConcurrentHashMap里面get(ID)从而找到callback将方法调用结果设置到callback对象里。监听线程接着使用synchronized获取回调对象callback的锁因为前面调用过wait()那个线程已释放callback的锁了再notifyAll()唤醒前面处于等待状态的线程继续执行callback的get()方法继续执行就能拿到调用结果了至此整个过程结束。 这里还需要画一个大图来描述后面再补了 需要注意的是这里的callback对象是每次调用产生一个新的不能共享否则会有问题另外ID必需至少保证在一个Socket连接里面是唯一的。 现在前面两个问题已经有答案了 当前线程怎么让它“暂停”等结果回来后再向后执行 答先生成一个对象obj在一个全局map里put(ID,obj)存放起来再用synchronized获取obj锁再调用obj.wait()让当前线程处于等待状态然后另一消息监听线程等到服务端结果来了后再map.get(ID)找到obj再用synchronized获取obj锁再调用obj.notifyAll()唤醒前面处于等待状态的线程。 正如前面所说Socket通信是一个全双工的方式如果有多个线程同时进行远程方法调用这时建立在client server之间的socket连接上会有很多双方发送的消息传递前后顺序也可能是乱七八糟的server处理完结果后将结果消息发送给clientclient收到很多消息怎么知道哪个消息结果是原先哪个线程调用的 答使用一个ID让其唯一然后传递给服务端再服务端又回传回来这样就知道结果是原先哪个线程的了。 这种做法不是第一次见了10年在上一公司里也是远程接口调用不过走的消息中间件rabbitmq同步调用的原理跟这类似详见rabbitmq 学习-9- RpcClient发送消息和同步接收消息原理转载于:https://www.cnblogs.com/1201x/p/6482638.html
