• Rocketmq-ONS spring 整合
  spring 版本整合 显示文件信息 tree /f 文件目录如下 └─src ├─main │ ├─java │ │ └─com │ │ └─github │ │ └─houbb │ │ └─spring │ │ C...
  2022-03-18 13:01:55 | Apache
• Rocketmq-ONS 入门案例
  Message ONS maven 依赖 <dependency> <groupId>com.aliyun.openservices</groupId> <artifactId>ons-client</artifactId> <version>1.8.0.Final</version&g...
  2022-03-18 13:01:55 | Apache
• Rocketmq-03-java hello world 入门案例
  从零手写实现 mq rocketmq java 入门案例 整体结构 |____src | |____main | | |____java | | | |____com | | | | |____ryo | | | | | |____rocket | | | | | | |____demo | | | | | | | |____common | | | | | | | | |__...
  2022-03-18 13:01:55 | Apache
• Rocketmq-02-mac/linux 安装笔记
  从零手写实现 mq Quick Start quick start 需要 64位操作系统，最好是Linux/Unix/Mac； 64位JDK 1.6+； Maven 3.x Git Screen JDK houbinbindeMacBook-Pro:aliyun-ons-client-java houbinbin$ java -version java version ...
  2022-03-18 13:01:55 | Apache
• Rocketmq-01-入门介绍
  Message Queue 消息队列（Message Queue，简称 MQ）是阿里巴巴集团中间件技术部自主研发的专业消息中间件。 产品基于高可用分布式集群技术，提供消息发布订阅、消息轨迹查询、定时（延时）消息、资源统计、监控报警等一系列消息云服务，是企业级互联网架构的核心产品。 为分布式应用系统提供异步解耦、削峰填谷的能力，同时具备海量消息堆积、高吞吐、可靠重试等互联网应用所需的特性...
  2022-03-18 13:01:55 | Apache
• RocketMQ-12-api 消费者接口文档
  DefaultPullConsumer 类简介 DefaultMQPullConsumer extends ClientConfig implements MQPullConsumer DefaultMQPullConsumer主动的从Broker拉取消息，主动权由应用控制，可以实现批量的消费消息。Pull方式取消息的过程需要用户自己写,首先通过打算消...
  2022-03-18 13:01:55 | MQ
• RocketMQ-11-api 生产者接口文档
  DefaultMQProducer 类简介 public class DefaultMQProducer extends ClientConfig implements MQProducer DefaultMQProducer类是应用用来投递消息的入口，开箱即用，可通过无参构造方法快速创建一个生产者。主要负责消息的发送，支持同步/异步/oneway的发送方式，这些发送方式均支...
  2022-03-18 13:01:55 | MQ
• RocketMQ-10-operation 集群部署
  运维管理 1 集群搭建 1.1 单Master模式 这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。 1）启动 NameServer ### 首先启动Name Server $ nohup sh mqnamesrv & ### 验证Name Server 是否启动成功 $ tail -f ~/logs/...
  2022-03-18 13:01:55 | MQ