add rabbitmq

Author: keeleys

.gitignore

@@ -6,3 +6,5 @@ target
 log
 .idea
 *.iml
+build/
+.gradle/

build.gradle

@@ -28,13 +28,10 @@ subprojects { subproject ->
     repositories {
         mavenLocal()
         mavenCentral()
-        maven {url "http://maven.oschina.net/content/groups/public/"}
-        maven {url "http://repos.someok.com/release"}
     }
 
     dependencies {
-        // tag::jetty[]
-        compile("org.springframework.boot:spring-boot-starter-web")
+        compile("org.springframework.boot:spring-boot-starter-amqp")
     }
 }
 

gradle-consumer/build.gradle

@@ -0,0 +1,4 @@
+apply plugin: 'spring-boot'
+dependencies {
+    compile("org.springframework.boot:spring-boot-starter-web")
+}

gralde-provider/src/main/java/hello/Application.java renamed to gradle-consumer/src/main/java/com/ttianjun/Application.java

@@ -1,18 +1,15 @@
-package hello;
-
-/**
- * @user tianjun
- * @date 16/6/23
- */
+package com.ttianjun;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+/**
+ * @user tianjun
+ * @date 16/6/24
+ */
 @SpringBootApplication
 public class Application {
-
 	public static void main(String[] args) {
 		SpringApplication.run(Application.class, args);
 	}
-
-}
+}

gradle-consumer/src/main/java/com/ttianjun/config/MessageConfig.java

@@ -0,0 +1,45 @@
+package com.ttianjun.config;
+
+import com.ttianjun.listen.ListenDemo;
+import org.springframework.amqp.core.*;
+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.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @user tianjun
+ * @date 16/6/24
+ */
+@Configuration
+public class MessageConfig {
+	@Value("${default-exchange}")
+	private String exchange;
+
+	private final String queueName="queue-fanout";
+	@Bean
+	Queue queue() {
+		return new Queue(queueName, false);
+	}
+
+	@Bean
+	FanoutExchange exchange() {
+		return new FanoutExchange(exchange);
+	}
+
+	@Bean
+	Binding binding(Queue queue, FanoutExchange exchange) {
+		return BindingBuilder.bind(queue).to(exchange);
+	}
+
+	@Bean
+	SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, ListenDemo listenDemo) {
+		SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
+		container.setConnectionFactory(connectionFactory);
+		container.setQueueNames(queueName);
+		container.setMessageListener(new MessageListenerAdapter(listenDemo,"handleMessage"));
+		return container;
+	}
+}

gradle-consumer/src/main/java/com/ttianjun/listen/ListenDemo.java

@@ -0,0 +1,14 @@
+package com.ttianjun.listen;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @user tianjun
+ * @date 16/6/24
+ */
+@Component
+public class ListenDemo {
+	public void handleMessage(String message) {
+		System.out.println(message);
+	}
+}

gradle-consumer/src/main/resources/application.properties

@@ -0,0 +1,6 @@
+spring.rabbitmq.host=127.0.0.1
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=guest
+spring.rabbitmq.password=guest
+spring.rabbitmq.virtual-host=/
+default-exchange=amq.fanout

gralde-provider/build.gradle renamed to gradle-provider/build.gradle

@@ -0,0 +1,33 @@
+package hello;
+
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+
+@SpringBootApplication
+public class Application implements CommandLineRunner {
+
+	@Value("${default-exchange}")
+	private String exchange;
+
+	@Autowired
+	AnnotationConfigApplicationContext context;
+
+	@Autowired
+	RabbitTemplate rabbitTemplate;
+
+	public static void main(String[] args) throws InterruptedException {
+		SpringApplication.run(Application.class, args);
+	}
+
+	@Override
+	public void run(String... args) throws Exception {
+		System.out.println("Sending message...");
+		rabbitTemplate.convertAndSend(exchange,null,"Hello from RabbitMQ!");
+		context.close();
+	}
+}

gradle-provider/src/main/java/hello/Application.java

@@ -0,0 +1,6 @@
+spring.rabbitmq.host=127.0.0.1
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=guest
+spring.rabbitmq.password=guest
+spring.rabbitmq.virtual-host=/
+default-exchange=amq.fanout