您现在的位置是:主页 > 数据库技术 > 数据库技术

Spring Cloud如何开发消息微服务

IDCBT2021-12-25服务器技术人已围观

简介这篇文章给大家分享的是有关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”。

    标签:

    很赞哦! ()

本栏推荐