springcloud实战之13 rabbitmq消息总线（bus）

Bertha 。 2022-06-03 06:59 124阅读 0赞

rabbitmq是实现了高级消息队列协议（amqp）的开源消息代理软件，也成为面向消息的中间件。RabbitMQ服务器是用高性能，可伸缩而闻名的Erlang语言编写而成的，其集群和故障转移是构建在开放电信平台框架上的。

RabbitMQ的安装这里不重复说明，可以参考[centos7自学之7-rabbitmq的安装与配置][centos7_7-rabbitmq],这里介绍spring cloud使用RabbitMQ。

## 创建工程（springcloud-server-bus-rabbitmq） ##

### 添加依赖 ###

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath />
    </parent>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Edgware.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <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>
    </dependencies>

### 创建入口类 ###

@SpringBootApplication
    public class SpringCloudServerBusRabbitmq { 
        public static void main(String[] args) {
            new SpringApplicationBuilder(SpringCloudServerBusRabbitmq.class)
                    .web(true)
                    .run(args)
                    ;
        }
    }

### 创建配置文件 ###

spring:
      rabbitmq:
        host: 192.168.175.128
        port: 5672
        username: admin
        password: admin
      application:
        name: springcloud-server-bus-rabbitmq

### 创建配置类 ###

@Configuration
    public class RabbitMqConfig { 
    
        public static final String queueName = "springcloud-server-bus-rabbitmq" ;
        public Queue rabbitMqQueue(){
            return new Queue(queueName);
        }
    }

### 创建生产者 ###

@Component
    public class Prodecer { 
    
        private final Logger _logger = LoggerFactory.getLogger(this.getClass()) ;
        @Autowired
        private AmqpTemplate rabbitMqTemplate ;
    
        public void send(){
            String context = "hello" + new Date() ;
            _logger.info("正在向队列发送消息：{}",context);
            this.rabbitMqTemplate.convertAndSend(RabbitMqConfig.queueName,context);
        }
    }

### 创建消费者 ###

@Component
    @RabbitListener(queues = RabbitMqConfig.queueName)
    public class Consumer { 
        private final Logger _logger = LoggerFactory.getLogger(this.getClass()) ;
    
        @RabbitHandler
        public void consumer(String message){
            _logger.info("从队列获取到的消息:{}",message);
        }
    }

### 创建web接口 ###

@Controller
    @RequestMapping("/api/rest")
    public class RestfulController { 
    
        @Autowired
        Prodecer prodecer ;
        @GetMapping("/message")
        public void message(){
            prodecer.send();
        }
    }

### 创建结构图如下 ###

![这里写图片描述][SouthEast]

## 运行项目 ##

启动springcloud-server-bus-rabbitmq。

调用服务：[http://localhost:8080/api/rest/message][http_localhost_8080_api_rest_message]，其效果如下图。

![这里写图片描述][SouthEast 1]

## 源码 ##

[springcloud-server-bus-rabbitmq][]

## 历史文章 ##

[springcloud实战之1 技术选型：dubbo还是springcloud][springcloud_1 _dubbo_springcloud]

[springcloud实战之2 服务注册与发现（eureka实现）][springcloud_2 _eureka]

[springcloud实战之3 高可用服务注册中心（eureka集群）][springcloud_3 _eureka]

[springcloud实战之5 服务消费者（ribbon）][springcloud_5 _ribbon]

[springcloud实战之6 服务消费者（Feign）][springcloud_6 _Feign]

[springcloud实战之7 断路器（Hystrix）][springcloud_7 _Hystrix]

[springcloud实战之8 断路器-仪表盘-单例监控（Hystrix）][springcloud_8 _-_-_Hystrix]

[springcloud实战之9断路器-集群监控（turbine）][springcloud_9_-_turbine]

[springcloud实战之10 分布式配置中心（config）][springcloud_10 _config]

[springcloud实战之11路由网关（zuul）][springcloud_11_zuul]

[springcloud实战之12 路由网关拦截器][springcloud_12]

[centos7_7-rabbitmq]: http://blog.csdn.net/u012806787/article/details/78671942
[SouthEast]: /images/20220603/a494a485df744ea69910ef0364054281.png
[http_localhost_8080_api_rest_message]: http://localhost:8080/api/rest/message
[SouthEast 1]: /images/20220603/473e1d00129d41b3a5cab6041a88dfce.png
[springcloud-server-bus-rabbitmq]: https://github.com/shiyuan2he/springcloud/tree/master/springcloud-server-bus-rabbitmq
[springcloud_1 _dubbo_springcloud]: http://blog.csdn.net/u012806787/article/details/78789312
[springcloud_2 _eureka]: http://blog.csdn.net/u012806787/article/details/78790958
[springcloud_3 _eureka]: http://blog.csdn.net/u012806787/article/details/78793639
[springcloud_5 _ribbon]: http://blog.csdn.net/u012806787/article/details/78796605
[springcloud_6 _Feign]: http://blog.csdn.net/u012806787/article/details/78798951
[springcloud_7 _Hystrix]: http://blog.csdn.net/u012806787/article/details/78801119
[springcloud_8 _-_-_Hystrix]: http://blog.csdn.net/u012806787
[springcloud_9_-_turbine]: http://blog.csdn.net/u012806787/article/details/78862637
[springcloud_10 _config]: http://blog.csdn.net/u012806787/article/details/78803198
[springcloud_11_zuul]: http://blog.csdn.net/u012806787/article/details/78863867
[springcloud_12]: http://blog.csdn.net/u012806787/article/details/78864281