rabbitmq的安装不在此赘述，想了解的可以参考：
1、新建一个spring-boot工程，本示例命名为：spring-boot-rabbitmq-demo
2、在pom.xml中引入amqp
org.springframework.boot spring-boot-starter-amqp
3、在application.properties中配置rabbitmq
spring.application.name=spring-boot-rabbitmq-demo spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest spring.rabbitmq.listener.simple.concurrency=10
4、配置rabbitmq的队列和消息转换器
package com.huatech.config;
import org.springframework.amqp.core.queue;
import org.springframework.amqp.rabbit.config.simplerabbitlistenercontainerfactory;
import org.springframework.amqp.rabbit.connection.connectionfactory;
import org.springframework.amqp.rabbit.core.rabbittemplate;
import org.springframework.amqp.support.converter.jackson2jsonmessageconverter;
import org.springframework.amqp.support.converter.messageconverter;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
@configuration
public class rabbitconfig {
@bean
public queue helloqueue() {
return new queue("user");
}
@bean
public messageconverter messageconverter() {
return new jackson2jsonmessageconverter();
}
@bean
public simplerabbitlistenercontainerfactory containerfactory(simplerabbitlistenercontainerfactory factory) {
factory.setmessageconverter(messageconverter());
return factory;
}
@bean
public rabbittemplate rabbittemplate(connectionfactory connectionfactory) {
rabbittemplate template = new rabbittemplate(connectionfactory);
template.setmessageconverter(messageconverter());
return template;
}
}
5、消息生产者usersender
package com.huatech.rabbit;
import java.util.date;
import org.springframework.amqp.rabbit.core.rabbittemplate;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.component;
import com.huatech.domain.user;
@component
public class usersender {
@autowired
private rabbittemplate rabbittemplate;
public void send() {
for (int i = 0; i < 100; i ) {
user user = new user();
user.setcreatetime(new date());
user.setemail("lihua_java@163.com");
user.setid(11l);
user.setremark("remark");
user.setusername("lihua");
system.out.println("sender : " user.tostring());
this.rabbittemplate.convertandsend("user", user);
}
}
}
6、消息消费者userreceiver
package com.huatech.rabbit;
import org.springframework.amqp.rabbit.annotation.rabbithandler;
import org.springframework.amqp.rabbit.annotation.rabbitlistener;
import org.springframework.stereotype.component;
import com.huatech.domain.user;
@component
@rabbitlistener(queues = "user", containerfactory = "containerfactory")
public class userreceiver {
@rabbithandler
public void process(user user) {
system.out.println("receiver : " user.tostring());
}
}
7、测试
package com.huatech;
import org.junit.test;
import org.junit.runner.runwith;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
import org.springframework.test.context.junit4.springrunner;
import com.huatech.rabbit.usersender;
@runwith(springrunner.class)
@springboottest
public class applicationtests {
@autowired
private usersender sender;
@test
public void testuser() throws exception {
sender.send();
thread.sleep(5000);
}
}
相关推荐
spring boot 集成各种框架 使用案例(spring-boot-rabbitmq、spring-boot-mail、spring-boot-thymeleaf、spring-boot-shiro)
spring-boot-examples-master示例程序，与各种框架集成，包括： dockercompose-springboot-mysql-nginx spring-boot-actuator spring-boot-banner spring-boot-docker spring-boot-elasticsearch spring-boot-...
- [spring-boot-rabbitmq](https://github.com/ityouknow/spring-boot-examples/tree/master/spring-boot-rabbitmq)：spring boot 和 rabbitmq 各种消息应用案例 - [spring-boot-scheduler]...
介绍spring cloud stream与rabbitmq集成的代码示例。spring cloud stream是一个建立在spring boot和spring integration之上的框架，有助于创建事件驱动或消息驱动的微服务。
spring websockets 支持 stomp 协议并与 rabbitmq 集成，用于在 ui 上显示实时信息。 spring boot 用于打包整个应用程序 要运行应用程序，首先设置 rabbitmq 并添加 stomp 插件 然后可以使用以下命令启动应用程序...
springboot集成rabbitmq非常简单，如果只是简单的使用配置非常少，springboot提供了spring-boot-starter-amqp项目对消息各种支持。下面通过本文给大家介绍下spring boot整合rabbitmq（direct模式）,需要的朋友可以...
java8 集合源码分析 说明 spring-boot-notes 用于记录学习、使用 ...rabbitmq-consumer-demo：rabbitmq消费者示例 rabbitmq-provider-demo：rabbitmq生产者示例 e.tools 一些常用功能框架的使用示例。
testcontainers-spring-boot：用于基于spring-boot的集成测试的容器自动配置
项目打包(同时处理项目所依赖的包)mvn clean install -pl emily-spring-boot-starter -am或./mvnw clean install -pl emily-spring-boot-starter -am参数全程说明-pl--projects选项后可跟随{groupid}:{artifactid}...
spring-boot-group(springboot集成各种中间件)1、spring boot集成rabbitmq
该项目中使用的技术 ...$ git clone https://github.com/jorgeacetozi/ebook-chat-app-spring-websocket-cassandra-redis-rabbitmq.git 输入存储库目录： $ cd ebook-chat-app-spring-websocket-cass
主要给大家介绍了关于spring boot集成rabbitmq的相关资料，springboot集成rabbitmq非常简单，文中通过示例代码介绍的非常详细，需要的朋友们可以参考借鉴，下面随着小编来一起学习学习吧。
springboot集成rabbitmq，分模块开发。
- spring boot 集成 消息队列，包括 kafka、rabbitmq、activemq、rocketmq、redismq - springboot-auth - spring boot 权限认证，包括 apache shiro、spring security - springboot-cloud - spring cloud ...
spring boot demo 是一个用来深度学习并实战 spring boot 的项目，目前总共包含 63 个集成demo，已经完成 52 个。 该项目已成功集成 actuator(监控)、admin(可视化监控)、logback(日志)、aoplog(通过aop记录web请求...
null 博文链接：https://dwj147258.iteye.com/blog/2430847
该项目已成功集成batis-aop(aop自定义多数据源)、multi-datasource-mybatis(使用mybatis集成多数据源)、quartz(定时任务)、rabbitmq-access(rabbitmq手动确认模式)、rabbitmq-availability(rabbitmq消息100%可靠性...
mysql需开启binlog 查看是否开启binlog ...3.3 rabbitmq配置 在virtualhost：/ 下新增exchanges： canal.exchange 新增队列：test.queue, 绑定canal.queue， routingkey：canal.routing.key canal下载及配置 ...