add Spring Boot 3.0 RabbitMQ examples

README.md

@@ -33,6 +33,7 @@ Spring Boot 使用的各种示例，以最简单、最实用为标准，此开
 - [spring-boot-thymeleaf](https://github.com/ityouknow/spring-boot-examples/tree/master/spring-boot-thymeleaf)：Spring Boot 3.0 Thymeleaf 语法、布局使用示例
 - [spring-boot-jpa](https://github.com/ityouknow/spring-boot-examples/tree/master/spring-boot-jpa)：Spring Boot 3.0 Jpa 操作、多数据源使用示例
 - [spring-boot-mybatis](https://github.com/ityouknow/spring-boot-examples/tree/master/spring-boot-mybatis)：Spring Boot 3.0 Mybatis 注解、xml 使用、多数据源使用示例
+- [spring-boot-rabbitmq](https://github.com/ityouknow/spring-boot-examples/tree/master/spring-boot-rabbitmq)：Spring Boot 3.0 RabbitMQ 各种常见场景使用示例
 
 ---
 

spring-boot-rabbitmq/pom.xml

@@ -0,0 +1,58 @@
+<?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>com.neo</groupId>
+	<artifactId>spring-boot-rabbitmq</artifactId>
+	<version>1.0.0</version>
+	<packaging>jar</packaging>
+
+	<name>spring-boot-rabbitmq</name>
+	<description>Demo project for Spring Boot and rabbitmq</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>3.0.0</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>17</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-amqp</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.junit.vintage</groupId>
+			<artifactId>junit-vintage-engine</artifactId>
+			<scope>test</scope>
+			<exclusions>
+				<exclusion>
+					<groupId>org.hamcrest</groupId>
+					<artifactId>hamcrest-core</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+
+</project>

spring-boot-rabbitmq/src/main/java/com/neo/RabbitMQApplication.java

@@ -0,0 +1,12 @@
+package com.neo;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class RabbitMQApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(RabbitMQApplication.class, args);
+	}
+}

spring-boot-rabbitmq/src/main/java/com/neo/model/User.java

@@ -0,0 +1,37 @@
+package com.neo.model;
+
+import java.io.Serializable;
+
+/**
+ * Created by summer on 2016/11/29.
+ */
+public class User implements Serializable{
+
+    private String name;
+
+    private String pass;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getPass() {
+        return pass;
+    }
+
+    public void setPass(String pass) {
+        this.pass = pass;
+    }
+
+    @Override
+    public String toString() {
+        return "User{" +
+                "name='" + name + '\'' +
+                ", pass='" + pass + '\'' +
+                '}';
+    }
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/FanoutRabbitConfig.java

@@ -0,0 +1,49 @@
+package com.neo.rabbit;
+
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.FanoutExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class FanoutRabbitConfig {
+
+    @Bean
+    public Queue AMessage() {
+        return new Queue("fanout.A");
+    }
+
+    @Bean
+    public Queue BMessage() {
+        return new Queue("fanout.B");
+    }
+
+    @Bean
+    public Queue CMessage() {
+        return new Queue("fanout.C");
+    }
+
+    @Bean
+    FanoutExchange fanoutExchange() {
+        return new FanoutExchange("fanoutExchange");
+    }
+
+    @Bean
+    Binding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) {
+        return BindingBuilder.bind(AMessage).to(fanoutExchange);
+    }
+
+    @Bean
+    Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) {
+        return BindingBuilder.bind(BMessage).to(fanoutExchange);
+    }
+
+    @Bean
+    Binding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) {
+        return BindingBuilder.bind(CMessage).to(fanoutExchange);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/RabbitConfig.java

@@ -0,0 +1,27 @@
+package com.neo.rabbit;
+
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class RabbitConfig {
+
+    @Bean
+    public Queue helloQueue() {
+        return new Queue("hello");
+    }
+
+    @Bean
+    public Queue neoQueue() {
+        return new Queue("neo");
+    }
+
+    @Bean
+    public Queue objectQueue() {
+        return new Queue("object");
+    }
+
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/TopicRabbitConfig.java

@@ -0,0 +1,41 @@
+package com.neo.rabbit;
+
+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.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class TopicRabbitConfig {
+
+    final static String message = "topic.message";
+    final static String messages = "topic.messages";
+
+    @Bean
+    public Queue queueMessage() {
+        return new Queue(TopicRabbitConfig.message);
+    }
+
+    @Bean
+    public Queue queueMessages() {
+        return new Queue(TopicRabbitConfig.messages);
+    }
+
+    @Bean
+    TopicExchange exchange() {
+        return new TopicExchange("topicExchange");
+    }
+
+    @Bean
+    Binding bindingExchangeMessage(Queue queueMessage, TopicExchange exchange) {
+        return BindingBuilder.bind(queueMessage).to(exchange).with("topic.message");
+    }
+
+    @Bean
+    Binding bindingExchangeMessages(Queue queueMessages, TopicExchange exchange) {
+        return BindingBuilder.bind(queueMessages).to(exchange).with("topic.#");
+    }
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverA.java

@@ -0,0 +1,16 @@
+package com.neo.rabbit.fanout;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "fanout.A")
+public class FanoutReceiverA {
+
+    @RabbitHandler
+    public void process(String message) {
+        System.out.println("fanout Receiver A  : " + message);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverB.java

@@ -0,0 +1,16 @@
+package com.neo.rabbit.fanout;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "fanout.B")
+public class FanoutReceiverB {
+
+    @RabbitHandler
+    public void process(String message) {
+        System.out.println("fanout Receiver B: " + message);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverC.java

@@ -0,0 +1,16 @@
+package com.neo.rabbit.fanout;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "fanout.C")
+public class FanoutReceiverC {
+
+    @RabbitHandler
+    public void process(String message) {
+        System.out.println("fanout Receiver C: " + message);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutSender.java

@@ -0,0 +1,19 @@
+package com.neo.rabbit.fanout;
+
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class FanoutSender {
+
+	@Autowired
+	private AmqpTemplate rabbitTemplate;
+
+	public void send() {
+		String context = "hi, fanout msg ";
+		System.out.println("Sender : " + context);
+		this.rabbitTemplate.convertAndSend("fanoutExchange","", context);
+	}
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloReceiver.java

@@ -0,0 +1,19 @@
+package com.neo.rabbit.hello;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Component
+@RabbitListener(queues = "hello")
+public class HelloReceiver {
+
+    @RabbitHandler
+    public void process(String hello) {
+        System.out.println("Receiver  : " + hello);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloSender.java

@@ -0,0 +1,22 @@
+package com.neo.rabbit.hello;
+
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+@Component
+public class HelloSender {
+
+	@Autowired
+	private AmqpTemplate rabbitTemplate;
+
+	public void send() {
+		String context = "hello " + new Date();
+		System.out.println("Sender : " + context);
+		this.rabbitTemplate.convertAndSend("hello", context);
+	}
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver1.java

@@ -0,0 +1,16 @@
+package com.neo.rabbit.many;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "neo")
+public class NeoReceiver1 {
+
+    @RabbitHandler
+    public void process(String neo) {
+        System.out.println("Receiver 1: " + neo);
+    }
+
+}

spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver2.java

@@ -0,0 +1,16 @@
+package com.neo.rabbit.many;
+
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@RabbitListener(queues = "neo")
+public class NeoReceiver2 {
+
+    @RabbitHandler
+    public void process(String neo) {
+        System.out.println("Receiver 2: " + neo);
+    }
+
+}