Netty提供的handler：编解码，消息头，消息编码 1. 连接建立后，客户端和服务端都不会主动发消息，实现handler的channelActive来触发消息发送。 2.SimpleChannelInboundHandler的重载方法 (1)handlerAdded 连接建立时调用 (2)Ha ...
分类：
Web程序 时间：
2017-07-05 22:06:22
阅读次数：
361
效果图 代码实现 用的变量： 启动服务按钮代码如下： 监听客户端消息代码如下： 将消息发送到客户端 ...
（一）WebSocket简介 短连接：在传统的Http协议中，客户端和服务器端的通信方式是短连接的方式，也就是服务器端并不会保持一个和客户端的连接，在消息发送后，会断开这个连接，客户端下次通信时，必须再建立和服务器的新连接，这就是短连接。在短链接的情况下，客户端必须不停的主动发起请求，而服务器始终被 ...
分类：
Web程序 时间：
2017-06-30 11:07:34
阅读次数：
205
简介：Message MiddleWare消息中间件是在消息的传递过程中保存消息的容器。消息中间件再将消息从它的源中继到它的目标时，充当中间人的作用。消息包括：订单信息等，需要消费者处理的东西特点：1）异步处理模式 发送者发送消息而无需等待响应。消息发送者将消息发送到一条虚拟的通道上，消息接受者则订 ...
分类：
其他好文 时间：
2017-06-29 01:02:38
阅读次数：
241
一、现象二、原因排查2.1 SparkStreaming程序排查2.2 Kafka数据验证2.3 查看OGG源码2.3.1 生成Kafka消息类2.3.2 Kafka配置类2.3.3 Kafka 消息发送类2.3.4 Kafka 分区获取方式三、结论 一、现象 目前我们的数据是通过OGG->Kafk... ...
分类：
其他好文 时间：
2017-06-28 09:22:48
阅读次数：
1741
一、发起transaction 当client想要发起一个transaction时，它会首先发送一个PROPOSE消息到它选择的一组endorser节点，消息模式有以下两种，节点可以自由选择（可能有更多种）： client首先将<PROPOSE, tx>消息发送给某个单个的endorser，该end ...
分类：
其他好文 时间：
2017-06-28 02:20:32
阅读次数：
902
一简介 使用itcha实现微信登录及消息发送接收，使用图灵AI实现智能回复。 参考API： http://www.tuling123.com/ https://itchat.readthedocs.io/zh/latest/ 二代码 三效果 ...
分类：
微信 时间：
2017-06-27 16:20:08
阅读次数：
383
0. 何谓安全？ 对于信息安全性的重要性，我想大家都不会否认。那么具体来说应该具有哪些特性才能称之为安全呢？举个简单的例子：我给你发送一条消息“借给我100元”，当你收到这条消息并且处理后你的账户里面会少出来100块，我的账户会多出来100块。在这个过程中，你是消息接收方，我是消息发送方。 总结来说 ...
分类：
其他好文 时间：
2017-06-26 23:57:10
阅读次数：
351
Producer拦截器(interceptor)是个相当新的功能，它和consumer端interceptor是在Kafka 0.10版本被引入的，主要用于实现clients端的定制化控制逻辑。 对于producer而言，interceptor使得用户在消息发送前以及producer回调逻辑前有机会 ...
分类：
其他好文 时间：
2017-06-24 10:01:58
阅读次数：
124
在RabbitMQ中，producer只能将消息发送到一个exchange中。要理解exchange也非常简单，它一边负责接收producer发送的消息， 另一边将消息推送到queue中。exchange必须清楚的知道在收到消息之后该如何进行下一步的处理，比如是否应该将这条消息发送到某个queue中 ...
分类：
其他好文 时间：
2017-06-17 18:21:25
阅读次数：
143
