-
java 从零开始实现消息队列 mq-04-启动初始化代码优化&broker 启动连接 check
前景回顾
【mq】从零开始实现 mq-01-生产者、消费者启动
【mq】从零开始实现 mq-02-如何实现生产者调用消费者?
【mq】从零开始实现 mq-03-引入 broker 中间人
【mq】从零开始实现 mq-04-启动检测与实现优化
上一节我们引入了中间人 broker,让消息的生产者和消费者解耦。
这一节我们对初始化代码进行优化,便于后期拓展维护。
生产者启动优...
2022-04-15 01:22:02 |
MQ
-
java 从零开始实现消息队列 mq-03-引入 broker 中间人
前景回顾
【mq】从零开始实现 mq-01-生产者、消费者启动
【mq】从零开始实现 mq-02-如何实现生产者调用消费者?
【mq】从零开始实现 mq-03-引入 broker 中间人
上一节我们学习了如何实现生产者给消费者发送消息,但是是通过直连的方式。
那么如何才能达到解耦的效果呢?
答案就是引入 broker,消息的中间人。
MqBroker 实现
核心启动类
...
2022-04-15 01:22:02 |
MQ
-
java 从零开始实现消息队列 mq-02-生产者直连调用消费者
前景回顾
上一节我们学习了如何实现基于 netty 客服端和服务端的启动。
【mq】从零开始实现 mq-01-生产者、消费者启动
【mq】java 从零开始实现消息队列 mq-02-如何实现生产者调用消费者?
那么客户端如何调用服务端呢?
我们本节就来一起实现一下。
消费者实现
启动类的调整
ServerBootstrap serverBootstrap = new Serv...
2022-04-15 01:22:02 |
MQ
-
java 从零开始实现消息队列 mq-01-生产者、消费者启动
MQ 是什么?
MQ(Message Queue)消息队列,是基础数据结构中“先进先出”的一种数据结构。
指把要传输的数据(消息)放在队列中,用队列机制来实现消息传递——生产者产生消息并把消息放入队列,然后由消费者去处理。
消费者可以到指定队列拉取消息,或者订阅相应的队列,由MQ服务端给其推送消息。
MQ 的作用?
消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息...
2022-04-15 01:22:02 |
MQ
-
WebSocket-04-socketjs
一、定义
SockJS是一个浏览器JavaScript库,它提供了一个类似于网络的对象。SockJS提供了一个连贯的、跨浏览器的Javascript API,它在浏览器和web服务器之间创建了一个低延迟、全双工、跨域通信通道。
二、产生的原因
一些浏览器中缺少对WebSocket的支持,因此,回退选项是必要的,而Spring框架提供了基于SockJS协议的透明的回退选项。
SockJ...
2022-04-15 01:22:02 |
Web
-
WebSocket-03-spring 整合实现
WebSocket 是什么?
WebSocket 是一种网络通信协议。RFC6455 定义了它的通信标准。
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
为什么需要 WebSocket ?
了解计算机网络协议的人,应该都知道:HTTP 协议是一种无状态的、无连接的、单向的应用层协议。它采用了请求/响应模型。通信请求只能由客户端发起,服...
2022-04-15 01:22:02 |
Web
-
WebSocket-02-java 实现例子
WebSocket
WebSocket 是一种网络通信协议。
WebSocket 教程-阮一峰
缘起
为了实现如下功能:后台内容变更,前端实时刷新。
常见解决方案:
一、Ajax long-polling
性能差。
二、 flash
需要会写 flash 代码。而且这个技术即将被淘汰。
三、 Node.js Socket.io
对于前端架构有要求,个人不太想用。...
2022-04-15 01:22:02 |
Web
-
RocketMQ-12-api 消费者接口文档
问题
假设有A、B两张表。
如果查询在A表中存在,但是在B表中不存在的记录,应该如何操作?
例子数据
假设A表数据:
id
1
2
3
4
5
B表数据:
id a_id
1 3
其中,B表中的a_id是需要排除的A表的id。
这里我们要排除A表中id为3的记录,实际中可能有上万条记录。
子查询方法
一般我们首先想到的可能就是not in语句:
select A....
2022-03-18 13:01:55 |
SQL