Spring Cloud微服务架构开发_全套PPT课件.ppt

8.4Stream的消费组和消息分区启动测试在RabbitMQ控制台查看效果启动项目stream-rabbitmq-provider，stream-rabbitmq-consumer和stream-rabbitMQ-consumer2，在RabbitMQ控制台的Queues查看消费组Stream，可以看到现在只有minestream.stream这一个队列了，可以印证了我们的消费组设置成功。8.4Stream的消费组和消息分区Stream的消息分区什么是Stream消息分区?在消费组中我们可以保证消息不会被重复消费，但是在同组下有多个实例的时候，我们无法确定每次处理消息的是不是被同一消费者消费，这就要使用到Stream的消息分区，消息分区的作用就是为了确保具有共同特征标识的数据由同一个消费者实例进行处理。8.4Stream的消费组和消息分区改造工程实现消息分区基本流程：改造提供者改造消费者启动测试8.2Stream快速入门测试项目确保RabbitMQ正常启动的情况下,启动项目stream-hello，stream-hello项目启动成功后，会在控制台打印以下启动日志内容。2019-10-2511:09:50.931INFO13660---[main]c.s.b.r.p.RabbitExchangeQueueProvisioner:declaringqueueforinbound:input.anonymous.Uni8EbkdTMWdEDe852UyIA,boundto:input2019-10-2511:09:50.967INFO13660--[main]o.s.a.r.c.CachingConnectionFactory:Creatednewconnection:rabbitConnectionFactory#30501e60:0/SimpleConnection@2a3194c6[delegate=amqp://guest@:5672/,localPort=52460]表示声明了一个名为input.anonymous.Uni8EbkdTMWdEDe852UyIA(随机生成)的队列表示使用guest用户创建了一个指向:5672地址的RabbitMQ连接8.2Stream快速入门在RabbitMQ控制台查看消息使用浏览器访问http://localhost:15672地址，登录成功后，选择导航栏中的Connections选项，我们可以在RabbitMQ控制台可以看到一条指向:5672地址的RabbitMQ连接，表明应用程序已和RabbitMQ建立连接。8.2Stream快速入门在RabbitMQ控制台查看消息在Queues选项中，可以看到Queues列表中新生成了一条名为input.anonymous.Uni8EbkdTMWdE852UyIA(随机生成)的队列。8.2Stream快速入门在RabbitMQ控制台查看消息应用程序在声明了一个随机队列之后，通过RabbitMessageChannelBinder将自己绑定为:5672的消费者。这些信息我们可以在RabbitMQ的控制台单击导航栏中的Channels选项查看。8.2Stream快速入门在RabbitMQ控制台查看消息在导航栏中的Queues选项，双击input.anonymous.Uni8EbkdTMWdEde852UyIA这条队列，进入这条队列的管理页面，通过Publishmessage功能来发送一条消息到该队列中。8.2Stream快速入门在Idea控制台查看消息在RabbitMQ控制台的队列管理页面我们使用Publishmessage功能发送了一条内容为“Sendamessage”的消息到队列中，我们可以在正在运行的stream-hello项目的控制台中看到会有日志输出。INFO6452---[bebsbZztvJREQ-1]c.i.streamhello.StreamHelloApplication:Received:Sendamessage该日志是通过stream-hello应用程序的SinkReceiver类中的receive()方法输出的，说明这条消息被stream-hello应用程序所消费。8.2Stream快速入门总结至此，第一个SpringCloudStream案例就完成了，但是我们会发现，此案例中并没有在配置文件