Spring Cloud如何开发消息微服务

这篇文章给大家分享的是有关Spring Cloud如何开发消息微服务的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

        我们需要在微服务客户端中实现消息生产者与消费者，先建立以下几个项目：

spring-server：Eureka服务器，端口8761，代码目录“codes\08\8.4\spring-server”。

spring-consumer：消息消费者，Eureka客户端，注册到Eureka，端口8080，代码目录“codes\08\8.4\spring-consumer”。

spring-producer：消息生产者，Eureka客户端，注册到Eureka，端口8081，代码目录“codes\08\8.4\spring-producer”。

        整个集群加上消息代理，结构如图8-10所示。

图8-10 程序结构

        由于Spring Cloud Stream帮我实现了与消息代者交互的功能，因此对于集群中的生产者与消费者来说，不需要关心外部使用的是哪一个消息框架，本小节的案例，默认使用RabbitMQ，默认情况下，会连接本地的5762端口，如果需要在微服务中修改RabbitMQ的连接信息，可使用以下配置：

spring:
  application:
    name: spring-producer
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

编写生产者

        在“spring-producer”项目中，加入以下依赖：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>

        主要引入“spring-coud-starter-stream-rabbit”依赖，该依赖会自动帮我们的项目引入“spring-cloud-stream”以及“spring-cloud-stream-binder”。

转载：感谢您对IDCBT博客网站平台的认可，以及对我们原创作品以及文章的青睐，非常欢迎各位朋友分享到个人站长或者朋友圈，但转载请说明文章出处“来源IDCBT博客”。

标签：

很赞哦！ ()