RocketMQ Java 客户端实现
2024-08-31 04:22:57
本章介绍使用 Java 实现RocketMQ 的客户端、 以及各种消息的方式的实现。
本章实现了以下几种消息的实现方式：
一：普通消息
普通的消息分为三种：
1> 可靠的同步消息
可靠的同步传输用于广泛的场景，如重要通知信息，短信通知，短信营销系统等。
2> 可靠的异步消息
异步传输通常用于响应时间敏感的业务场景。
3> 单向传输消息
单向传输用于要求中等可靠性的情况，如日志收集。
二：顺序消费
RocketMQ使用FIFO顺序提供有序消息
三：广播消息
广播正在向主题的所有订阅者发送消息。 如果您希望所有订阅者接收有关主题的消息，广播是一个不错的选择。
四：定时消息
定时的消息与正常消息不同，因为它们将在以后提供的时间内不会被传送。
五：事务消息
事务消息为了解决分布式事务最终一致性。
应为以上五中消息类型的实现代码比较多、不方便在此处贴出。如有感兴趣的同学可以到如下地址查看。
git: https://github.com/yuelicn/rocketmq-example
最新文章
- lintcode循环数组之连续子数组求和
- MySQL迁移[转]
- COCI2011:友好数对
- 【linux】学习1
- Crystal Reports 2008(水晶报表) 安装
- ELK-Python（二）
- Printing Array elements with Comma delimiters
- Drupal 7.23：函数drupal_alter()注释
- C++中 类的构造函数理解（一）
- 软件开发杂谈之从需求到上线---valen
- Bootstrap学习笔记(一) 排版
- jQuery学习-----（一）JQuery的'$'符号用法
- Android -tool工具UIautomatorviewer提示“不能让屏幕黑屏”
- 字符串（后缀自动机）：COGS 2399. 循环同构
- Linux下进程间管道通信小作业
- Android 开发环境搭建之——ADT-Bundle for Windows
- Extjs6（七）——增删查改之删除
- 【转】matlab图形句柄详解(一)
- Arthas
- thinkphp 把小程序码二进制流存储到本地