# RocketMQ-Spring
[![Build Status](https://travis-ci.org/apache/rocketmq-spring.svg?branch=master)](https://travis-ci.org/apache/rocketmq-spring)
[![Coverage Status](https://coveralls.io/repos/github/apache/rocketmq-spring/badge.svg?branch=master)](https://coveralls.io/github/apache/rocketmq-spring?branch=master)
[![Maven Central](https://maven-badges.herokuapp.com/maven-central/org.apache.rocketmq/rocketmq-spring-all/badge.svg)](https://search.maven.org/search?q=g:org.apache.rocketmq%20AND%20a:rocketmq-spring-all)
[![GitHub release](https://img.shields.io/badge/release-download-orange.svg)](https://github.com/apache/rocketmq-spring/releases)
[![License](https://img.shields.io/badge/license-Apache%202-4EB1BA.svg)](https://www.apache.org/licenses/LICENSE-2.0.html)
[![Average time to resolve an issue](http://isitmaintained.com/badge/resolution/apache/rocketmq-spring.svg)](http://isitmaintained.com/project/apache/rocketmq-spring "Average time to resolve an issue")
[![Percentage of issues still open](http://isitmaintained.com/badge/open/apache/rocketmq-spring.svg)](http://isitmaintained.com/project/apache/rocketmq-spring "Percentage of issues still open")
This project aims to help developers quickly integrate [RocketMQ](http://rocketmq.apache.org/) with [Spring Boot](http://projects.spring.io/spring-boot/).
## Features
- [x] Send messages synchronously
- [x] Send messages asynchronously
- [x] Send messages in one-way mode
- [x] Send ordered messages
- [x] Send batched messages
- [x] Send transactional messages
- [x] Send scheduled messages with delay level
- [x] Consume messages with concurrent mode (broadcasting/clustering)
- [x] Consume ordered messages
- [x] Filter messages using the tag or sql92 expression
- [x] Support message tracing
- [x] Support authentication and authorization
- [x] Support request-reply message exchange pattern
- [x] Consume messages with push/pull mode
## Prerequisites
- JDK 1.8 and above
- [Maven](http://maven.apache.org/) 3.0 and above
- Spring Boot 2.0 and above
## Usage
Add a dependency using maven:
```xml
<!--add dependency in pom.xml-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${RELEASE.VERSION}</version>
</dependency>
```
## Samples
Please see the [rocketmq-spring-boot-samples](rocketmq-spring-boot-samples).
## User Guide
Please see the [wiki](https://github.com/apache/rocketmq-spring/wiki) page.
## Contributing
We are always very happy to have contributions, whether for trivial cleanups or big new features. Please see the RocketMQ main website to read the [details](http://rocketmq.apache.org/docs/how-to-contribute/).
## License
[Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0.html) Copyright (C) Apache Software Foundation
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
该资源内项目源码是个人的课程设计、毕业设计,代码都测试ok,都是运行成功后才上传资源,答辩评审平均分达到96分,放心下载使用! ## 项目备注 1、该资源内项目代码都经过严格测试运行成功才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.md文件(如有),仅供学习参考, 切勿用于商业用途。
资源推荐
资源详情
资源评论
收起资源包目录
毕业设计&课设_RocketMQ 与 Spring集成的项目.zip (168个子文件)
spring.factories 134B
spring.factories 132B
.gitignore 152B
org.springframework.boot.autoconfigure.AutoConfiguration.imports 66B
org.springframework.boot.autoconfigure.AutoConfiguration.imports 66B
RocketMQTemplate.java 60KB
DefaultRocketMQListenerContainer.java 28KB
RocketMQClientTemplate.java 19KB
RocketMQAutoConfigurationTest.java 17KB
RocketMQUtil.java 16KB
ProducerApplication.java 15KB
RocketMQProperties.java 14KB
DefaultRocketMQListenerContainerTest.java 14KB
RocketMQTemplateTest.java 13KB
DefaultListenerContainer.java 11KB
RocketMQAutoConfiguration.java 10KB
ClientProducerApplication.java 10KB
RocketMQUtil.java 9KB
RocketMQProperties.java 9KB
RocketMQMessageListenerContainerRegistrar.java 8KB
ExtConsumerResetConfiguration.java 8KB
ExtConsumerResetConfiguration.java 8KB
RocketMQAutoConfiguration.java 8KB
ExtProducerResetConfiguration.java 8KB
RocketMQUtilTest.java 8KB
ExtTemplateResetConfiguration.java 7KB
ProducerACLApplication.java 7KB
ClientConsumeApplication.java 6KB
ListenerContainerConfiguration.java 6KB
RocketMQMessageListener.java 5KB
RocketMQMessageListenerBeanPostProcessor.java 5KB
RocketMQMessageListenerBeanPostProcessor.java 5KB
ExtRocketMQTemplateTest.java 5KB
RocketMQTransactionConfiguration.java 4KB
ExtRocketMQConsumerConfiguration.java 4KB
RocketMQMessageConverter.java 4KB
RocketMQMessageConverter.java 4KB
ExtRocketMQTemplateConfiguration.java 4KB
RocketMQTransactionConfiguration.java 4KB
RocketMQMessageListenerBeanPostProcessorTest.java 3KB
ExtConsumerResetConfiguration.java 3KB
ClientProducerACLApplication.java 3KB
RocketMQMessageListener.java 3KB
RocketMQTransactionListener.java 3KB
ExtProducerResetConfiguration.java 3KB
MessageExtConsumer.java 2KB
ConsumerApplication.java 2KB
V5PushConsumerConsumerApplication.java 2KB
RocketMQListenerConfiguration.java 2KB
RocketMQListenerConfiguration.java 2KB
V5SimpleConsumerConsumerApplication.java 2KB
V5ProducerApplication.java 2KB
PushConsumerApplication.java 2KB
ConsumerACLApplication.java 2KB
ProducerApplication.java 2KB
ListenerContainerConfiguration.java 2KB
ACLConsumer.java 2KB
ObjectConsumerWithReplyUser.java 2KB
Checker.java 2KB
ConsumerWithReplyGeneric.java 2KB
RocketMQHeaders.java 2KB
ProductWithPayload.java 2KB
ProductWithPayload.java 2KB
PullConsumerApplication.java 2KB
ACLStringTransactionalConsumer.java 2KB
FifoConsumer.java 2KB
TransConsumer.java 2KB
ConsumerWithReplyBytes.java 2KB
StringConsumerWithReplyString.java 2KB
OrderPaidEvent.java 2KB
ACLStringConsumer.java 2KB
RocketMQHeaders.java 2KB
UserConsumer.java 2KB
OrderPaidEventConsumer.java 2KB
OrderPaidEvent.java 2KB
User.java 1KB
User.java 1KB
UserMessage.java 1KB
UserMessage.java 1KB
StringConsumer.java 1KB
StringConsumerNewNS.java 1KB
StringTransactionalConsumer.java 1KB
MessageConverterConfiguration.java 1KB
MessageConverterConfiguration.java 1KB
Pair.java 1KB
RocketMQTransactionListener.java 1KB
RocketMQReplyListener.java 1KB
ExtRocketMQTemplate.java 1KB
RocketMQLocalRequestCallback.java 1KB
ExtRocketMQTemplate.java 1KB
ClientConsumerACLApplication.java 1KB
RocketMQTransactionChecker.java 1KB
RocketMQListener.java 1KB
MessageModel.java 1KB
ExtRocketMQTemplate.java 1KB
RocketMQLocalTransactionListener.java 1KB
RocketMQPushConsumerLifecycleListener.java 1KB
ConsumeMode.java 1KB
SelectorType.java 1KB
RocketMQListenerContainer.java 1001B
共 168 条
- 1
- 2
资源评论
pk_xz123456
- 粉丝: 2063
- 资源: 1321
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功