# mq-demo

**Repository Path**: PerfectGo/mq-demo

## Basic Information

- **Project Name**: mq-demo
- **Description**: 阿里云消息队列 RocketMQ 4.0版使用示例
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-02-04
- **Last Updated**: 2024-02-04

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 阿里云消息队列 RocketMQ 4.0版使用示例

[消息队列 RocketMQ 版](https://www.aliyun.com/product/rocketmq)是企业级互联网架构的核心产品，服务于整个阿里巴巴集团已超过 10 年，经过阿里巴巴交易核心链路反复打磨与历年双十一购物狂欢节的严苛考验，是一个真正具备低延迟、高并发、高可用、高可靠，可支撑万亿级数据洪峰的分布式消息中间件。

## 如何开通使用消息队列 RocketMQ 产品

打开消息队列 RocketMQ 版的[产品页](https://www.aliyun.com/product/rocketmq)，点击 `立即开通购买` 即可。

## 如何使用该示例程序

首先请阅读消息队列RocketMQ 4.0版的文档[快速入门](https://help.aliyun.com/document_detail/169004.html)。

## Spring

推荐通过 Spring 的方式接入 MQ。1.8.8.5.Final+的SDK提供包括所有Client类型的Spring Bean，具体的配置在resources目录下：

* common.xml， 提供AK， SK， Topic， PID 以及CID等资源的配置，使用该Demo前请修改。
* producer.xml， 使用普通Producer的配置文件
* order_producer.xml， 使用OrderProducer的配置文件
* transaction_producer.xml， 使用TransactionProducer的配置文件
* consumer.xml， 使用普通Consumer的配置文件
* order_consumer.xml， 使用OrderConsumer的配置文件
* batch_consumer.xml， 使用BatchConsumer的配置文件

## 非Spring

非Spring应用也可以直接使用消息队列的客户端接入，详见[TCP 接入](https://github.com/AliwareMQ/mq-demo/tree/master/tcp/java-tcp-demo)。