diff --git a/README.md b/README.md index dd5b2324e03c39a3dba4431e784bfc7832961102..68f283b17c52eda68f1709d15181cca9887ffe3d 100644 --- a/README.md +++ b/README.md @@ -12,7 +12,7 @@ Spring boot使用的各种示例，以最简单、最实用为标准 - [spring-boot-mybaits-xml](https://github.com/ityouknow/spring-boot-starter/tree/master/spring-boot-mybatis-xml)：xml配置版本 -- [spring-boot-rabbitmq-simple](https://github.com/ityouknow/spring-boot-starter/tree/master/spring-boot-rabbitmq-simple)：spring boot和rabbitmq简单应用 +- [spring-boot-rabbitmq](https://github.com/ityouknow/spring-boot-starter/tree/master/spring-boot-rabbitmq)：spring boot和rabbitmq简单应用 diff --git a/spring-boot-rabbitmq-simple/pom.xml b/spring-boot-rabbitmq/pom.xml similarity index 92% rename from spring-boot-rabbitmq-simple/pom.xml rename to spring-boot-rabbitmq/pom.xml index 890f266d643610bef39f56617f70d2ad861302e4..b4de1e355798f5c1f287061068fd47798462d8c9 100644 --- a/spring-boot-rabbitmq-simple/pom.xml +++ b/spring-boot-rabbitmq/pom.xml @@ -4,17 +4,17 @@ 4.0.0 com.neo - spring-boot-rabbitmq-simple + spring-boot-rabbitmq 1.0.0 jar - spring-boot-rabbitmq-simple + spring-boot-rabbitmq Demo project for Spring Boot and rabbitmq org.springframework.boot spring-boot-starter-parent - 1.4.1.RELEASE + 1.4.2.RELEASE diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/Application.java b/spring-boot-rabbitmq/src/main/java/com/neo/Application.java similarity index 100% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/Application.java rename to spring-boot-rabbitmq/src/main/java/com/neo/Application.java diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/model/User.java b/spring-boot-rabbitmq/src/main/java/com/neo/model/User.java new file mode 100644 index 0000000000000000000000000000000000000000..f4eec95e41a0bd9f5f4d3ef984b9d81c73277a28 --- /dev/null +++ b/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 + '\'' + + '}'; + } +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/FanoutRabbitConfig.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/FanoutRabbitConfig.java new file mode 100644 index 0000000000000000000000000000000000000000..4fe21fa9f97433bd4b929731096fdcd91828202a --- /dev/null +++ b/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); + } + +} diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/RabbitConfig.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/RabbitConfig.java similarity index 82% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/RabbitConfig.java rename to spring-boot-rabbitmq/src/main/java/com/neo/rabbit/RabbitConfig.java index 28b60537113fe2af20302ff87a713e1ff076e422..d5d649b5c0c1cd6da4f3c59979c372b9769efdae 100644 --- a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/RabbitConfig.java +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/RabbitConfig.java @@ -13,11 +13,15 @@ public class RabbitConfig { return new Queue("hello"); } - @Bean public Queue neoQueue() { return new Queue("neo"); } + @Bean + public Queue objectQueue() { + return new Queue("object"); + } + } diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/TopicRabbitConfig.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/TopicRabbitConfig.java new file mode 100644 index 0000000000000000000000000000000000000000..7bd2a096cfceb6443115d512e809fb822b754fc8 --- /dev/null +++ b/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.#"); + } +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverA.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverA.java new file mode 100644 index 0000000000000000000000000000000000000000..256de2eee06e7ff85da528e0c59bb401b3338e51 --- /dev/null +++ b/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); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverB.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverB.java new file mode 100644 index 0000000000000000000000000000000000000000..a721da6844464ee15554df01a8ddb6c63c98c0fb --- /dev/null +++ b/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); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverC.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutReceiverC.java new file mode 100644 index 0000000000000000000000000000000000000000..aceef8b081f24d0cafe60fa1db0b24c2dbc59f86 --- /dev/null +++ b/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); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutSender.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/fanout/FanoutSender.java new file mode 100644 index 0000000000000000000000000000000000000000..2fa62d39cb33adfc33f12477a94d07d1af7ca6df --- /dev/null +++ b/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); + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloReceiver.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloReceiver.java similarity index 83% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloReceiver.java rename to spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloReceiver.java index 7a5fe935b36cfc9d3cde4d9820b03a67147a0778..2d59b17401812785b56aded72bb0fa501c1d22d3 100644 --- a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloReceiver.java +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloReceiver.java @@ -1,4 +1,4 @@ -package com.neo.rabbit; +package com.neo.rabbit.hello; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; @@ -13,7 +13,7 @@ public class HelloReceiver { @RabbitHandler public void process(String hello) { - System.out.println("Receiver : " + hello); + System.out.println("Receiver : " + hello); } } diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloSender.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloSender.java similarity index 94% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloSender.java rename to spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloSender.java index 547050c5b5e5e076919fa61d241059ec24bf915e..05fc740ac9e64719e8101861f0a8d16e10d93fc3 100644 --- a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/HelloSender.java +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/hello/HelloSender.java @@ -1,4 +1,4 @@ -package com.neo.rabbit; +package com.neo.rabbit.hello; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate; diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoReceiver.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver1.java similarity index 73% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoReceiver.java rename to spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver1.java index d615ba5e538223c5ece99e4a6b1275a73189aeb4..c352fbeb5a252ef57609308ccb431fe1dc28f43f 100644 --- a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoReceiver.java +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver1.java @@ -1,4 +1,4 @@ -package com.neo.rabbit; +package com.neo.rabbit.many; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; @@ -6,11 +6,11 @@ import org.springframework.stereotype.Component; @Component @RabbitListener(queues = "neo") -public class NeoReceiver { +public class NeoReceiver1 { @RabbitHandler public void process(String neo) { - System.out.println("Receiver : " + neo); + System.out.println("Receiver 1: " + neo); } } diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver2.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoReceiver2.java new file mode 100644 index 0000000000000000000000000000000000000000..d7cbdd758c7060750bc5f80dc0973ee743b2d326 --- /dev/null +++ b/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); + } + +} diff --git a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoSender.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender.java similarity index 66% rename from spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoSender.java rename to spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender.java index 6841018188eee5f26c2552d8a8f95485e5b0cea0..755918fb688c4f6b38a90690010954fab78d5b46 100644 --- a/spring-boot-rabbitmq-simple/src/main/java/com/neo/rabbit/NeoSender.java +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender.java @@ -1,20 +1,18 @@ -package com.neo.rabbit; +package com.neo.rabbit.many; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import java.util.Date; - @Component public class NeoSender { @Autowired private AmqpTemplate rabbitTemplate; - public void send() { - String context = "neo test queue"; - System.out.println("Sender : " + context); + public void send(int i) { + String context = "spirng boot neo queue"+" ****** "+i; + System.out.println("Sender1 : " + context); this.rabbitTemplate.convertAndSend("neo", context); } diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender2.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender2.java new file mode 100644 index 0000000000000000000000000000000000000000..e34cce6472c5c7f8861e174579838e5147ee3aa9 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/many/NeoSender2.java @@ -0,0 +1,19 @@ +package com.neo.rabbit.many; + +import org.springframework.amqp.core.AmqpTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +@Component +public class NeoSender2 { + + @Autowired + private AmqpTemplate rabbitTemplate; + + public void send(int i) { + String context = "spirng boot neo queue"+" ****** "+i; + System.out.println("Sender2 : " + context); + this.rabbitTemplate.convertAndSend("neo", context); + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectReceiver.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectReceiver.java new file mode 100644 index 0000000000000000000000000000000000000000..b97f8a026664df568ba9a245766865e7e7ec98e0 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectReceiver.java @@ -0,0 +1,17 @@ +package com.neo.rabbit.object; + +import com.neo.model.User; +import org.springframework.amqp.rabbit.annotation.RabbitHandler; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.stereotype.Component; + +@Component +@RabbitListener(queues = "object") +public class ObjectReceiver { + + @RabbitHandler + public void process(User user) { + System.out.println("Receiver object : " + user); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectSender.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectSender.java new file mode 100644 index 0000000000000000000000000000000000000000..9c7aba9277636b8fdbef79bc8140f261492348f5 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/object/ObjectSender.java @@ -0,0 +1,21 @@ +package com.neo.rabbit.object; + +import com.neo.model.User; +import org.springframework.amqp.core.AmqpTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.Date; + +@Component +public class ObjectSender { + + @Autowired + private AmqpTemplate rabbitTemplate; + + public void send(User user) { + System.out.println("Sender object: " + user.toString()); + this.rabbitTemplate.convertAndSend("object", user); + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver.java new file mode 100644 index 0000000000000000000000000000000000000000..14523941adf0eab46c3878a41565594b45fbfc13 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver.java @@ -0,0 +1,16 @@ +package com.neo.rabbit.topic; + +import org.springframework.amqp.rabbit.annotation.RabbitHandler; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.stereotype.Component; + +@Component +@RabbitListener(queues = "topic.message") +public class TopicReceiver { + + @RabbitHandler + public void process(String message) { + System.out.println("Topic Receiver1 : " + message); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver2.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver2.java new file mode 100644 index 0000000000000000000000000000000000000000..9ea81d7fe86e4e50ba962d68e75e03a871946f29 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicReceiver2.java @@ -0,0 +1,16 @@ +package com.neo.rabbit.topic; + +import org.springframework.amqp.rabbit.annotation.RabbitHandler; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.stereotype.Component; + +@Component +@RabbitListener(queues = "topic.messages") +public class TopicReceiver2 { + + @RabbitHandler + public void process(String message) { + System.out.println("Topic Receiver2 : " + message); + } + +} diff --git a/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicSender.java b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicSender.java new file mode 100644 index 0000000000000000000000000000000000000000..8f17c34e3dcf502293c1e9578cc3f380540f3be3 --- /dev/null +++ b/spring-boot-rabbitmq/src/main/java/com/neo/rabbit/topic/TopicSender.java @@ -0,0 +1,33 @@ +package com.neo.rabbit.topic; + +import org.springframework.amqp.core.AmqpTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.Date; + +@Component +public class TopicSender { + + @Autowired + private AmqpTemplate rabbitTemplate; + + public void send() { + String context = "hi, i am message all"; + System.out.println("Sender : " + context); + this.rabbitTemplate.convertAndSend("topicExchange", "topic.1", context); + } + + public void send1() { + String context = "hi, i am message 1"; + System.out.println("Sender : " + context); + this.rabbitTemplate.convertAndSend("topicExchange", "topic.message", context); + } + + public void send2() { + String context = "hi, i am messages 2"; + System.out.println("Sender : " + context); + this.rabbitTemplate.convertAndSend("topicExchange", "topic.messages", context); + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq-simple/src/main/resources/application.properties b/spring-boot-rabbitmq/src/main/resources/application.properties similarity index 50% rename from spring-boot-rabbitmq-simple/src/main/resources/application.properties rename to spring-boot-rabbitmq/src/main/resources/application.properties index e9897cd2c36b3f8f906d122e4cebb045c1b77f46..da5cc5ed068b6a9c9d254f4035a90bcbe6d520ad 100644 --- a/spring-boot-rabbitmq-simple/src/main/resources/application.properties +++ b/spring-boot-rabbitmq/src/main/resources/application.properties @@ -1,6 +1,6 @@ -spring.application.name=spirng-boot-rabbitmq +spring.application.name=spirng-boot-rabbitmq-example -spring.rabbitmq.host=localhost +spring.rabbitmq.host=192.168.0.86 spring.rabbitmq.port=5672 spring.rabbitmq.username=admin spring.rabbitmq.password=123456 diff --git a/spring-boot-rabbitmq-simple/src/test/java/com/neo/ApplicationTests.java b/spring-boot-rabbitmq/src/test/java/com/neo/ApplicationTests.java similarity index 100% rename from spring-boot-rabbitmq-simple/src/test/java/com/neo/ApplicationTests.java rename to spring-boot-rabbitmq/src/test/java/com/neo/ApplicationTests.java diff --git a/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/FanoutTest.java b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/FanoutTest.java new file mode 100644 index 0000000000000000000000000000000000000000..d9ee0afd958258ca916e544a71a5c18dbfd1f96e --- /dev/null +++ b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/FanoutTest.java @@ -0,0 +1,24 @@ +package com.neo.rabbitmq; + +import com.neo.rabbit.fanout.FanoutSender; +import com.neo.rabbit.topic.TopicSender; +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; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class FanoutTest { + + @Autowired + private FanoutSender sender; + + @Test + public void fanoutSender() throws Exception { + sender.send(); + } + + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq-simple/src/test/java/com/neo/rabbitmq/RabbitMqTest.java b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/HelloTest.java similarity index 64% rename from spring-boot-rabbitmq-simple/src/test/java/com/neo/rabbitmq/RabbitMqTest.java rename to spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/HelloTest.java index 4634888dffd933605b36c8c14fdaedb2de8ef488..f790b0452b62c0a0d957a71fb70c27a5636b5ff8 100644 --- a/spring-boot-rabbitmq-simple/src/test/java/com/neo/rabbitmq/RabbitMqTest.java +++ b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/HelloTest.java @@ -1,8 +1,6 @@ package com.neo.rabbitmq; -import com.neo.rabbit.HelloSender; -import com.neo.rabbit.NeoReceiver; -import com.neo.rabbit.NeoSender; +import com.neo.rabbit.hello.HelloSender; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; @@ -11,22 +9,15 @@ import org.springframework.test.context.junit4.SpringRunner; @RunWith(SpringRunner.class) @SpringBootTest -public class RabbitMqTest { +public class HelloTest { @Autowired private HelloSender helloSender; - @Autowired - private NeoSender neoSender; - @Test public void hello() throws Exception { helloSender.send(); } - @Test - public void neo() throws Exception { - neoSender.send(); - } } \ No newline at end of file diff --git a/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ManyTest.java b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ManyTest.java new file mode 100644 index 0000000000000000000000000000000000000000..08c701cfdbd138c8fa175f1e147a35f7bbb40615 --- /dev/null +++ b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ManyTest.java @@ -0,0 +1,35 @@ +package com.neo.rabbitmq; + +import com.neo.rabbit.many.NeoSender; +import com.neo.rabbit.many.NeoSender2; +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; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class ManyTest { + @Autowired + private NeoSender neoSender; + + @Autowired + private NeoSender2 neoSender2; + + @Test + public void oneToMany() throws Exception { + for (int i=0;i<100;i++){ + neoSender.send(i); + } + } + + @Test + public void manyToMany() throws Exception { + for (int i=0;i<100;i++){ + neoSender.send(i); + neoSender2.send(i); + } + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ObjectTest.java b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ObjectTest.java new file mode 100644 index 0000000000000000000000000000000000000000..e36daf7ed6daaf0bc593d0b584f63f0eff971869 --- /dev/null +++ b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/ObjectTest.java @@ -0,0 +1,26 @@ +package com.neo.rabbitmq; + +import com.neo.model.User; +import com.neo.rabbit.object.ObjectSender; +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; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class ObjectTest { + + @Autowired + private ObjectSender sender; + + @Test + public void sendOject() throws Exception { + User user=new User(); + user.setName("neo"); + user.setPass("123456"); + sender.send(user); + } + +} \ No newline at end of file diff --git a/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/TopicTest.java b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/TopicTest.java new file mode 100644 index 0000000000000000000000000000000000000000..d69a5b85ea1567d830ecc62bc25044f9a28b5372 --- /dev/null +++ b/spring-boot-rabbitmq/src/test/java/com/neo/rabbitmq/TopicTest.java @@ -0,0 +1,32 @@ +package com.neo.rabbitmq; + +import com.neo.rabbit.topic.TopicSender; +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; + +@RunWith(SpringRunner.class) +@SpringBootTest +public class TopicTest { + + @Autowired + private TopicSender sender; + + @Test + public void topic() throws Exception { + sender.send(); + } + + @Test + public void topic1() throws Exception { + sender.send1(); + } + + @Test + public void topic2() throws Exception { + sender.send2(); + } + +} \ No newline at end of file