（1）Producer的API 1、发送流程：Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程，以及一个线程共享变量——RecordAccumulator。main 线程将消息发送给 RecordAccum ...
这是一个辅助阳光网络课堂的油猴脚本，目前最新的版本是 v1.1，已经实现的功能有： 1. 实时显示在线人数和在线管理员名单； 2. 聊天区显示消息发送的时间； 3. 增加高级输入框，可以发送带换行的消息、发送图片以及对指定用户私聊。 使用方法： 1. 打开 "油猴官网" ，选择你使用的浏览器对应的版 ...
分类：
其他好文 时间：
2020-04-24 23:28:35
阅读次数：
151
大纲 (一)、异步投递与确认签收回调 (二)、延迟投递与确认投递 (三)、消费重试机制 (四)、死信队列 (一)、异步投递与确认签收回调 1.What?Why? ActiveMQ 支持同步、异步两种发送的模式将消息发送到 broker，模式的选择对发送延时有巨大的影响。producer 能达到怎样的 ...
分类：
其他好文 时间：
2020-04-22 20:15:33
阅读次数：
92
微信聊天功能测试 发送对象 普通用户、公众号、群、其他特殊主体 衍生功能 转发、语音转文字、删除等 消息发送 单聊、群聊、语音、文字、图片、表情、链接、字符及长度 消息管理 发布通知、接受通知、发文件、消息提醒、通知提醒、声音、震动、好友请求、请求处理 发送内容 空白、正常文字、超长文字、以前曾经引 ...
分类：
微信 时间：
2020-04-22 16:55:25
阅读次数：
527
前言 上一章的工作队列模式中，生产者发布的一堆消息进入队列，消费者接收队列中的消息，每条消息只能发给一个消费者。 本章要做的是吧一条消息发送给多个消费者，这种模式就是Fanout Exchange（扇形交换机）“发布/订阅模式”，它会将消息路由给绑定到它身上的所有队列。 注意：该模式没有存储消息功能 ...
分类：
其他好文 时间：
2020-04-20 12:03:48
阅读次数：
80
在发送微信客服消息初始使用的是 设置 或者是 都报 invalid openid hint 错误 后来发现 是 未使用 ，改正后但是发送的消息还是中文乱码，这就很蛋疼了 鄙人才疏学浅，经过不断的肝，发现一个好用的类，使用 完美解决 invalid openid hint 报错以及中文乱码问题 所以说 ...
分类：
微信 时间：
2020-04-19 10:51:46
阅读次数：
98
RPC 通信 对于单独部署，独立运行的微服务实例而言，在业务需要时，需要与其他服务时行通信，这种通信方式是进程之间的通讯方式（简称IPC）。 IPC有两种实现方式，分别为：同步过程调用、异步消息调用。在同步过程调用的具体实现中，有一种实现方式为RPC通信方式，远程过程调用。（英语：Remote Pr ...
分类：
其他好文 时间：
2020-04-16 15:16:56
阅读次数：
65
python中使用redis发布订阅者模型 redis发布订阅者模型： Redis提供了发布订阅功能，可以用于消息的传输，Redis的发布订阅机制包括三个部分，发布者，订阅者和Channel。发布者和订阅者都是Redis客户端，Channel则为Redis服务器端，发布者将消息发送到某个的频道，订阅 ...
分类：
编程语言 时间：
2020-04-13 14:12:27
阅读次数：
85
做消息持久化 借助 jdbc， kahadb或 leveldb+zookeeper首先将将消息发送设置为持久化发送（mq自带的属性），然后再借助jdbc kahadb leveldb+zookeeper等做消息的存储来持久化。思想都是发送者（消息生产者）将消息发送出去后，消息中心首先将消息存储到本地 ...
分类：
其他好文 时间：
2020-04-10 22:48:34
阅读次数：
232
上一篇讲解了MQTT协议在JS实现，通过和Unity3D交互实现通信，因为对JS不是特别精通，所以讲得比较粗略。这一篇中，介绍Unity3D实现MQTT协议通信，将细致讲解过程MQTT是IBM开源的一个通讯方式，是一个基于TCP的发布订阅协议，MQTT使用类似MQ常用的发布/订阅模式，起到应用程序解耦，异步消息，削峰填谷的作用。优点：使用发布/订阅模式，提供一对多的消息发布，使消息发送者和接收者在
分类：
编程语言 时间：
2020-04-10 10:24:46
阅读次数：
257
