使用grpc双向模式，可以实现客户端随时发送消息给服务端，服务端也可以随时发送消息到客户端，不再是一问一答的模式。 grpc_stream/hellowoldstream/helloworldstream.proto protoc --go_out=plugins=grpc:. helloworld ...
分类：
其他好文 时间：
2019-11-01 13:18:36
阅读次数：
143
一：worker注册机制（worker启动之后） 1- worker在启动之后，就会主动向master进行注册； 2- Master将dead状态的worker过滤掉；将unknown状态的worker信息更新； 3- Master将worker将入到内存缓存中（HashMap）； 4- 持久化引擎 ...
分类：
其他好文 时间：
2019-10-26 10:50:50
阅读次数：
147
一.WebSocket介绍 1.WebSocket是什么? WebSocket是协议,是HTML5开始提供的基于TCP(传输层)的一种新的网络协议, 它实现了浏览器与服务器全双工(full-duplex)通信,即允许服务器主动发送消息给客户端 WebSocket 使得客户端和服务器之间的数据交换变得 ...
分类：
编程语言 时间：
2019-10-25 15:04:57
阅读次数：
135
Redis发布订阅（pub/sub）是一种消息通讯模式，发送者（pub）发送消息，订阅者（sub）接收消息。 下图展示渠道channel1，及订阅这个渠道的三个客户端client2，client5，client1之间的关系： 当有新消息通过PUBLISH命令发送到渠道channel1时，这个消息就会 ...
分类：
其他好文 时间：
2019-10-25 09:31:29
阅读次数：
66
场景很简单，就是多个客户端通过udp，连接到服务器（其实是无连接的，就是服务器保存了客户端的ip信息）。然后通过udp协议先服务器发送消息，然后服务器在通过udp转发在各个客服端。 这个是不是 观察者模式 server代码 client 代码 ...
分类：
编程语言 时间：
2019-10-24 15:45:19
阅读次数：
86
[TOC] 为什么出现粘包问题？ ~~~python TCP协议就类似于打电话 只有在TCP协议中才会出现粘包现象，因为TCP协议是流式协议 它的特点是将数据量小并且时间间隔比较短的数据一次性打包发送出去 本质其实还是因为我们不知道需要接收的数据的长短 ~~~ 如何解决粘包问题？ ~~~python ...
分类：
其他好文 时间：
2019-10-23 20:33:56
阅读次数：
96
一、RabbitMQ消息队列介绍 RabbitMQ也是消息队列，那RabbitMQ和之前的Python的Queue有什么区别呢： py消息队列 1. 线程queue(同一进程下线程之间进行交互) 2. 进程Queue(父子进程进行交互或者同属于同一进程下的多个子进程进行交互) 类似于这种公共的中间有 ...
分类：
其他好文 时间：
2019-10-23 10:01:01
阅读次数：
87
服务端：接收客户端发送的消息，并进行转发。 客户端：发送消息和读取消息 ...
分类：
其他好文 时间：
2019-10-22 15:05:40
阅读次数：
67
#TCP协议实现（发送消息的顺序无要求）（以conn为对象发送和接收消息）（字节流） #-------serve层 import socket import time sk=socket.socket() sk.bind(('10.70.2.143',8080)) #1.服务器地址 2.服务器端口，... ...
分类：
其他好文 时间：
2019-10-22 12:56:40
阅读次数：
88
认识JMSJMS是Java消息服务（Javamessageservice），是java平台关于面向消息中间件（MOM）的API。用于两个应用程序或分布式系统应用中，消息发送，消息异步处理。即应用程序间通信通过JMS服务，进行消息转发。应用程序间消息异步处理可解除应用程序的耦合。JMS有消息异步处理、程序间解耦、消息可靠的优势。JMS消息模型Queue点对点（PointtoPoint）Queue队列
分类：
其他好文 时间：
2019-10-21 13:21:54
阅读次数：
89
