在现实中，你要和天南海北的朋友聊天需要中介，QQ,微信，信息等等这些都是中介工具。中介工具的作用就是把同一类的人放在一起（群），一个发送消息的时候，需要通知其他人 java中的中介者模式有四个角色：抽象中介者，具体抽象者，抽象角色，具体角色。 抽象中介者（群的概念） abstract class M ...
分类：
其他好文 时间：
2020-04-28 16:45:35
阅读次数：
49
（1）Producer的API 1、发送流程：Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程，以及一个线程共享变量——RecordAccumulator。main 线程将消息发送给 RecordAccum ...
在创建套接字时，可以通过指定参数 AF_ROUTE 域创建路由套接字（它只能支持原始套接字，只有超级用户才能创建这个套接字），路由套接字可以访问内核中路由子系统的接口信息。 进程通过写到路由套接字向内核发送消息（路径的增加和删除采用这种方式实现） 进程通过读入路由套接字接收来自内核的消息（内核采用这 ...
分类：
其他好文 时间：
2020-04-27 11:41:41
阅读次数：
57
Vlan是虚拟局域网。用途是在二层可以隔离广播域，从而提高数据传输的效率。在不同的网络端口划分了Vlan时，二层的数据转发的仅能在同一个vlan下进行通信。从而实现了即使在同一个网段下的广播消息隔离。为什么要使用vlan隔离广播域，可以先了解下以太网的冲突域与广播域冲突域CSMA/CD是以太网采用了随机访问控制协议的带有冲突检测的载波侦听多址访问方法作为多路访问控制协议。形象的说，在此方法下每个接
分类：
其他好文 时间：
2020-04-26 23:42:53
阅读次数：
62
Netty获取异步执行结果 步骤：（具体代码参考下面demo） 1. 给消息设置个唯一key 2. 初始化响应消息队列：responseMsgCache.put(key,new LinkedBlockingQueue(1)); 3. 执行异步IO：future.addListener 4. 阻塞等待 ...
分类：
Web程序 时间：
2020-04-26 20:42:13
阅读次数：
463
1.原因描述 我们在工作中遇到耗时的一些操作时我们会使用多线程或者mq来解决以便提高程序的响应速度。但是使用多线程时遇到一个问题，我单独开一个线程去进行其他逻辑处理时，在发送消息之前(未开启多线程时)我们是可以获取到 request 信息的，但是在新开的线程中确是无法获取到 request 信息(r ...
分类：
编程语言 时间：
2020-04-22 19:48:49
阅读次数：
243
MQTT简介 mqtt基于订阅者模型架构，客户端如果互相通信，必须在同一订阅主题下，即都订阅了同一个topic，客户端之间是没办法直接通讯的。订阅模型显而易见的好处是群发消息的话只需要发布到topic，所有订阅了这个topic的客户端就可以接收到消息了。 发送消息必须发送到某个topic，重点说明的 ...
分类：
其他好文 时间：
2020-04-21 11:26:24
阅读次数：
96
以下是博客中python第三方包使用列表(持续更新) "钉钉机器人——DingDingBot" 通过钉钉机器人发送消息到钉钉 "表格化数据——PrettyTable" 将数据以表格的格式展示出来 "Python执行js——Pyexecjs" 利用python执行js "美化错误输出——Pretty ...
分类：
编程语言 时间：
2020-04-20 23:30:55
阅读次数：
76
SOFA企业应用框架 前言 从业这么多年，接触过银行的应用，Apple的应用，eBay的应用和现在阿里的应用，虽然分属于不同的公司，使用了不同的架构，但有一个共同点就是都很复杂。导致复杂性的原因有很多，如果从架构的层面看，主要有两点，一个是架构设计过于复杂，层次太多能把人绕晕。另一个是根本就没架构， ...
分类：
其他好文 时间：
2020-04-20 18:51:56
阅读次数：
78
前言 上一章的工作队列模式中，生产者发布的一堆消息进入队列，消费者接收队列中的消息，每条消息只能发给一个消费者。 本章要做的是吧一条消息发送给多个消费者，这种模式就是Fanout Exchange（扇形交换机）“发布/订阅模式”，它会将消息路由给绑定到它身上的所有队列。 注意：该模式没有存储消息功能 ...
分类：
其他好文 时间：
2020-04-20 12:03:48
阅读次数：
80
