您现在的位置是:主页 > 数据库技术 > 数据库技术
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”。
标签:很赞哦! ()