springBoot+RabbitMQ例子
阿新 • • 發佈：2017-06-01
boot code cer .... ebo set print return cor
demo目錄
貼代碼
1.ProducerConfig.java
package com.test.config;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
2.RabbitMQConfig.java
package com.test.config;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Created by admin on 2017/6/1 11:26.
*/
@Configuration
public class RabbitMQConfig {
/**
* 註入配置文件屬性
*/
@Value("${spring.rabbitmq.addresses}")
String addresses;//MQ地址
@Value("${spring.rabbitmq.username}")
String username;//MQ登錄名
@Value("${spring.rabbitmq.password}")
String password;//MQ登錄密碼
@Value("${spring.rabbitmq.virtual-host}")
String vHost;//MQ的虛擬主機名
/**
* 創建 ConnectionFactory
*
* @return
* @throws Exception
*/
@Bean
public ConnectionFactory connectionFactory() throws Exception {
return RabbitUtil.connectionFactory(addresses, username, password, vHost);
}
/**
* 創建 RabbitAdmin
*
* @param connectionFactory
* @return
* @throws Exception
*/
@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) throws Exception {
RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
return rabbitAdmin;
}
}
3.RabbitUtil.java
package com.test.config;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.messaging.converter.GenericMessageConverter;
/**
* RabbitMQ 公共類
* Created by admin on 2017/6/1 11:25.
*/
public class RabbitUtil {
/**
* 初始化 ConnectionFactory
*
* @param addresses
* @param username
* @param password
* @param vHost
* @return
* @throws Exception
*/
public static ConnectionFactory connectionFactory(String addresses, String username, String password, String vHost) throws Exception {
CachingConnectionFactory factoryBean = new CachingConnectionFactory();
factoryBean.setVirtualHost(vHost);
factoryBean.setAddresses(addresses);
factoryBean.setUsername(username);
factoryBean.setPassword(password);
return factoryBean;
}
/**
* 初始化 RabbitMessagingTemplate
*
* @param connectionFactory
* @return
*/
public static RabbitMessagingTemplate simpleMessageTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate template = new RabbitTemplate(connectionFactory);
RabbitMessagingTemplate rabbitMessagingTemplate = new RabbitMessagingTemplate();
rabbitMessagingTemplate.setMessageConverter(new GenericMessageConverter());
rabbitMessagingTemplate.setRabbitTemplate(template);
return rabbitMessagingTemplate;
}
}
4.Student.java
package com.test.model;
import java.io.Serializable;
/**
* Created by admin on 2017/6/1 13:36.
*/
public class Student implements Serializable {
private String name;
private Integer age;
private String address;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
}
5.Consumers.java
package com.test.task;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;
/**
* Created by admin on 2017/6/1 13:29.
*/
@Service
public class Consumers {
@RabbitListener(
admin = "rabbitAdmin",
bindings = @QueueBinding(
value = @Queue(value = "test.demo.send", durable = "true", autoDelete = "false"),
exchange = @Exchange(value = "default.topic", durable = "true", type = "topic"),
key = "test2.send")
)
public void test(Object obj) {
System.out.println("receive....");
System.out.println("obj:" + obj.toString());
}
}
6.Producers.java
package com.test.task;
import com.test.model.Student;
import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* Created by admin on 2017/6/1 13:35.
*/
@Service
public class Producers {
@Autowired
RabbitMessagingTemplate rabbitSendTemplate;
public void send(Student student) {
System.out.println("send start.....");
rabbitSendTemplate.convertAndSend(
"default.topic",
"test2.send",
student);
}
}
7.TestController.java
package com.test.test;
import com.test.model.Student;
import com.test.task.Producers;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
/**
* Created by admin on 2017/6/1 13:38.
*/
@Controller
@RequestMapping(value = "/test")
public class TestController {
@Autowired
Producers producers;
@RequestMapping(value = "/send", method = RequestMethod.GET)
@ResponseBody
public void test() {
Student s = new Student();
s.setName("zhangsan");
s.setAddress("wuhan");
s.setAge(20);
producers.send(s);
}
}
8.MainApplication.java
package com.test;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* Created by admin on 2017/6/1 11:19.
*/
@SpringBootApplication
public class MainApplication {
public static void main(String[] args) {
System.getProperties().put("test", "test");
SpringApplication.run(MainApplication.class, args);
}
}
9.application.yml
server:
address: 192.168.200.117 #自己主機的IP地址
port: 8000 #端口
spring:
rabbitmq:
addresses: 192.168.200.119:5672 #MQ IP 和 端口
username: admin #MQ登錄名
password: 123456 #MQ登錄密碼
virtual-host: test #MQ的虛擬主機名稱
10.build.gradle
group ‘rabbitmqtest‘
version ‘1.0-SNAPSHOT‘
apply plugin: ‘java‘
sourceCompatibility = 1.8
repositories {
mavenCentral()
}
dependencies {
testCompile group: ‘junit‘, name: ‘junit‘, version: ‘4.11‘
testCompile("org.springframework.boot:spring-boot-starter-test:1.3.5.RELEASE")
compile("org.springframework.boot:spring-boot-starter-web:1.3.5.RELEASE")
compile(group: ‘org.springframework.amqp‘, name: ‘spring-rabbit‘, version: "1.6.1.RELEASE")
}
11.settings.gradle
rootProject.name = ‘rabbitmqtest‘
頁面訪問 192.168.200.117:8000/test/send 可以看到控制臺有日誌輸出，發送的消息立即消費掉了
MQ的隊列裏面也是空的
如果把消費者的代碼註掉，再訪問剛才的 url 地址 隊列裏面就會多一條
123
springBoot+RabbitMQ例子