zoukankan      html  css  js  c++  java
  • RocketMQ Java 客户端实现

      本章介绍使用 Java 实现RocketMQ 的客户端、 以及各种消息的方式的实现。

    本章实现了以下几种消息的实现方式:

    一:普通消息

      普通的消息分为三种:

      1> 可靠的同步消息

        可靠的同步传输用于广泛的场景,如重要通知信息,短信通知,短信营销系统等。

      2> 可靠的异步消息

        异步传输通常用于响应时间敏感的业务场景。

      3> 单向传输消息

        单向传输用于要求中等可靠性的情况,如日志收集。

    二:顺序消费

      RocketMQ使用FIFO顺序提供有序消息

    三:广播消息

      广播正在向主题的所有订阅者发送消息。 如果您希望所有订阅者接收有关主题的消息,广播是一个不错的选择。

    四:定时消息

      定时的消息与正常消息不同,因为它们将在以后提供的时间内不会被传送。

    五:事务消息

      事务消息为了解决分布式事务最终一致性。

    应为以上五中消息类型的实现代码比较多、不方便在此处贴出。如有感兴趣的同学可以到如下地址查看。

    git: https://github.com/yuelicn/rocketmq-example

  • 相关阅读:
    poj1573
    poj2632
    poj2993 poj2996
    poj3295 构造法
    poj2965枚举
    poj1753 枚举
    poj942Paths on a Grid
    poj1019
    poj1321棋盘问题
    博客园访问量有些小,我就没有必要在复制一份了,博客园就这样吧,继续CSDN了。
  • 原文地址:https://www.cnblogs.com/yueli/p/7526456.html
Copyright © 2011-2022 走看看