SpringBoot-RabbitMQ 消息队列

声明

host:http://120.27.114.229
username:root 
password:root
port:5672
web management: http://120.27.114.229:15672

构建

需要

如何完成

使用Gradle构建

1.创建目录结构

└── src
 └── main
 └── java
 └── hello

2.创建Gradle配置文件build.gradle

buildscript {
 repositories {
 mavenCentral()
 }
 dependencies {
 classpath("org.springframework.boot:spring-boot-gradle-plugin:1.4.3.RELEASE")
 }
}
apply plugin: 'java'
apply plugin: 'eclipse'
apply plugin: 'idea'
apply plugin: 'org.springframework.boot'
jar {
 baseName = 'gs-messaging-rabbitmq'
 version = '0.1.0'
}
repositories {
 mavenCentral()
}
sourceCompatibility = 1.8
targetCompatibility = 1.8
dependencies {
 compile("org.springframework.boot:spring-boot-starter-amqp")
 testCompile("junit:junit")
}

使用Maven构建

1.创建目录结 构

└── src
 └── main
 └── java
 └── hello

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 <modelVersion>4.0.0</modelVersion>
 <groupId>org.springframework</groupId>
 <artifactId>gs-messaging-rabbitmq</artifactId>
 <version>0.1.0</version>
 <parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>1.4.3.RELEASE</version>
 </parent>
 <properties>
 <java.version>1.8</java.version>
 </properties>
 <dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-amqp</artifactId>
 </dependency>
 </dependencies>
 <build>
 <plugins>
 <plugin>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-maven-plugin</artifactId>
 </plugin>
 </plugins>
 </build>
</project>

使用IDE编译

1.建立RabbitMQ沙箱

brew install rabbitmq

rabbitmq-server

 RabbitMQ 3.1.3. Copyright (C) 2007-2013 VMware, Inc.
## ## Licensed under the MPL. See http://www.rabbitmq.com/
## ##
########## Logs: /usr/local/var/log/rabbitmq/rabbit@localhost.log
###### ## /usr/local/var/log/rabbitmq/rabbit@localhost-sasl.log
##########
 Starting broker... completed with 6 plugins.

rabbitmq:
 image: rabbitmq:management
 ports:
 - "5672:5672"
 - "15672:15672"

2.创建RabbitMQ消息订阅

package hello;
import java.util.concurrent.CountDownLatch;
import org.springframework.stereotype.Component;
@Component
public class Receiver {
 private CountDownLatch latch = new CountDownLatch(1);
 public void receiveMessage(String message) {
 System.out.println("Received <" + message + ">");
 latch.countDown();
 }
 public CountDownLatch getLatch() {
 return latch;
 }
}

3.注册监听并发布消息

package hello;
import org.springframework.amqp.core.Binding;
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.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class Application {
 final static String queueName = "spring-boot";
 
 final static String HOST = "120.27.114.229";
 final static String USERNAME = "root";
 
 final static String PASSWORD = "root";
 final static int PORT = 15672;
 
 @Bean
 Queue queue() {
 return new Queue(queueName, false);
 }
 @Bean
 TopicExchange exchange() {
 return new TopicExchange("spring-boot-exchange");
 }
 @Bean
 Binding binding(Queue queue, TopicExchange exchange) {
 return BindingBuilder.bind(queue).to(exchange).with(queueName);
 }
 @Bean 
 public ConnectionFactory connectionFactory() { 
 	 CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
 connectionFactory.setHost(HOST);
 connectionFactory.setPort(PORT);
 connectionFactory.setUsername(USERNAME);
 connectionFactory.setPassword(PASSWORD);
 connectionFactory.setVirtualHost("/");
 //必须要设置,消息的回掉
 connectionFactory.setPublisherConfirms(true); 
 return connectionFactory;
 } 
 @Bean
 SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
 MessageListenerAdapter listenerAdapter) {
 SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
 container.setConnectionFactory(connectionFactory);
 container.setQueueNames(queueName);
 container.setMessageListener(listenerAdapter);
 return container;
 }
 @Bean
 MessageListenerAdapter listenerAdapter(Receiver receiver) {
 return new MessageListenerAdapter(receiver, "receiveMessage");
 }
 public static void main(String[] args) throws InterruptedException {
 SpringApplication.run(Application.class, args);
 }
}

4.发送文本消息

package hello;
import java.util.concurrent.TimeUnit;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.stereotype.Component;
@Component
public class Runner implements CommandLineRunner {
 private final RabbitTemplate rabbitTemplate;
 private final Receiver receiver;
 private final ConfigurableApplicationContext context;
 public Runner(Receiver receiver, RabbitTemplate rabbitTemplate,
 ConfigurableApplicationContext context) {
 this.receiver = receiver;
 this.rabbitTemplate = rabbitTemplate;
 this.context = context;
 }
 @Override
 public void run(String... args) throws Exception {
 System.out.println("Sending message...");
 rabbitTemplate.convertAndSend(Application.queueName, "Hello from RabbitMQ!");
 receiver.getLatch().await(10000, TimeUnit.MILLISECONDS);
 context.close();
 }
}

5.启动应用

6.编译可执行的JAR包

java -jar build/libs/gs-messaging-rabbitmq-0.1.0.jar

java -jar target/gs-messaging-rabbitmq-0.1.0.jar

Sending message...
Received <Hello from RabbitMQ!>