如何基于netty实现mq 编程思路

消费者netty客户端与nettyServer端MQ服务器端保持长连接，MQ服务器端保存
消费者连接。
生产者netty客户端发送请求给nettyServer端MQ服务器端，MQ服务器端在将该
消息内容发送给消费者。

body:{“msg”:{“userId”:“123456”,“age”:“23”},“type”:“producer”，”topic”:””}

生产者投递消息给MQ服务器端，MQ服务器端需要缓存该消息
如果mq服务器端宕机之后，消息如何保证不丢失

持久化机制
如果mq接收到生产者投递消息，如果消费者不在的情况下，该消息是否会丢失？
不会丢失，消息确认机制必须要消费者消费该消息成功之后，在通知给mq服务器端
删除该消息。
Mq服务器端将该消息推送消费者：
消费者已经和mq服务器保持长连接。
消费者主动拉取消息：
消费者第一次刚启动的时候

Mq如何实现抗高并发思想

Mq消费者根据自身能力情况，拉取mq服务器端消息消费。
默认的情况下是取出一条消息。

缺点：存在延迟的问题

需要考虑mq消费者提高速率的问题：

如何消费者提高速率：消费者实现集群、消费者批量获取消息即可。
Maven依赖

<dependencies><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.62</version></dependency><dependency><groupId>io.netty</groupId><artifactId>netty-all</artifactId><version>4.0.23.Final</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.62</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.11</version></dependency>
</dependencies>

如何基于netty实现mq 编程思路相关推荐

基于netty实现mq
消费者netty客户端与nettyServer端MQ服务器端保持长连接,MQ服务器端保存消费者连接. 生产者netty客户端发送请求给nettyServer端MQ服务器端,MQ服务器端在将该消息内 ...
AsyncHttpClient源码分析-基于Netty的连接池实现
原文地址:asynchttpclient源码分析-基于Netty的连接池实现最近项目重构,有了个机会更多接触一个有别于HttpAsyncClient的异步网络框架AsyncHttpClient,是个 ...
基于 Netty 网络编程项目实战课程
一基于 Netty 网络编程项目实战课程 1项目介绍 2Netty 介绍与相关基础知识 2.1Netty 介绍简介 Netty 是由 JBOSS 提供的一个 java 开源框架.Netty 提供异 ...
labview报表生成工具包_后台开发java 常见工具包 netty、mq 、分布式锁等，干货
why搞这么一个玩意用过vue-cli的小伙伴会很轻松的搭建出一个包含vue骨架的前端开发组件,然后install所需要的模块,后台常见springcloud框架也是如此,但是少了所需要的好多模块, ...
手动实现一个基于netty的RPC框架（模拟dubble）
轻量级RPC框架开发内容安排: 1.掌握RPC原理 2.掌握nio操作 3.掌握netty简单的api 4.掌握自定义RPC框架 RPC原理学习什么是RPC RPC(Remote Procedur ...
适合新手：从零开发一个IM服务端（基于Netty，有完整源码）
本文由"yuanrw"分享,博客:juejin.im/user/5cefab8451882510eb758606,收录时内容有改动和修订. 0.引言站长提示:本文适合IM新手阅读 ...
FPGA之道（58）关于外界接口的编程思路
文章目录前言关于外界接口的编程思路按传递方向分类输入接口输出接口双向接口原理简介工作模式主从模式对等模式简单示例按电气特性分类单端接口差分接口无线接口按功能特性分类时 ...
helloworld讲解cocos2d-x的编程思路与要点
用helloworld讲解cocos2d-x的编程思路与要点本文以cocos2d-x的helloworld为例,讲解cocos2d-x引擎的特点和要点,2.2为了展示新功能,把包括屏幕自适应在内的新 ...
Java编写基于netty的RPC框架
一简单概念RPC: ( Remote Procedure Call),远程调用过程,是通过网络调用远程计算机的进程中某个方法,从而获取到想要的数据,过程如同调用本地的方法一样.阻塞IO :当阻塞I/ ...

如何基于netty实现mq 编程思路

如何基于netty实现mq 编程思路相关推荐

最新文章

热门文章