书接前文，言归正转，前面说道springcloud在分布式下的配置问题，
ok,接下来说说消息队列的问题，就和相亲一样，我知道你的基本信息，我们还得见个面谈谈是吧，＝－＝，这样才知道我们合适不，
springcloud做消息队列的有两个东西rabbitmq和kafka,这里我说一下rabbitmq,kafka再说，哈哈，最近加班加疯了。
rabbitmq:兔子妈其，
怎么用?
step1:
安装erlang与rabbitmq,具体就百度好了。
安装完了执行：rabitmq-plugins enable rabbitmq_management;
访问：localhost:15672/可以看到我们的rabbitma_manager了
默认user:guest passwd:guest
我们配置一个user:springcloud,密码123456好了，测试使用
其中有:exchange,queue等东西
step2:
rabbitmq-product
配置文件
spring.application.name=rabbitmq-hello
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=springcloud
spring.rabbitmq.password=123456
config:配置rabbitmq的配置信息，以前博客有写，哈哈，就不多说啦
package com.example.rabbitmqserver.rabbittmq;
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");
}
}
product:搞一个hello队列出来，把一个字符串放进去
package com.example.rabbitmqserver.rabbittmq;
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 Sender {
@Autowired
private AmqpTemplate rabbitTemplate;
public void send() {
String context = "hello " + new Date();
System.out.println("Sender : " + context);
this.rabbitTemplate.convertAndSend("hello", context);
}
}
customer:使用rabbit的监听器监听helllo的队列，然后取东西出来
package com.example.rabbitmqserver.rabbittmq;
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 Receiver {
@RabbitHandler
public void process(String hello) {
System.out.println("Receiver : " + hello);
}
}
app:最后是我们的Application.java
package com.example.rabbitmqserver;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class RabbitmqServerApplication {
public static void main(String[] args) {
SpringApplication.run(RabbitmqServerApplication.class, args);
}
}
step3:跑起来吧。去rabbitmq manager中可以看到多出来链接条目
console中也显示啦helo队列的东西，脑补！！！！＝－＝
step$:rabbitmq可以和erukayuconfig结合起来。做到动态刷新，这个有时间再研究吧，哈哈
1:rabbit mq的安装：先去安装erlanng，再去apt-get install 安装一下rabbitma就成
2:rabbitmq的创建流程与组件:
以前的博客写了，就不说啦
//www.greatytc.com/p/c9d52f07eda6
3:rabbit server与rabbit client是异步的,可以在demo里面进行测试server与client分别关闭之后的情况，rabbitserver与rabbitclient的demo
4:eureka与rabbitmq，config的结合，在eureka client中有bus/refresh接口用于同步信息
5:使用bus/refresh接口实现所有的刷新，/bus/refresh?destinaation=*:*;用于指定刷新特殊的应用
6：架构优化：
method1:把configserver加入消息总线，
method2:bus/refresh不是发送到某个springboot而是发送到config server
