ToB企服应用市场:ToB评测及商务社交产业平台

标题: 消息中间件——RabbitMQ（十一）RabbitMQ整合Spring Cloud Stream实战！（ [打印本页]
作者: 宝塔山    时间: 2024-7-20 13:22
标题: 消息中间件——RabbitMQ（十一）RabbitMQ整合Spring Cloud Stream实战！（
2、定义Barista接口
/**

*/
public interface Barista {
String OUTPUT_CHANNEL = “output_channel”;
//注解@Output声明确它是一个输出范例的通道，名字是output_channel。这一名字与app1中通道名一致，表明注入了一个名字为output_channel的通道，范例是output，发布的主题名为mydest。
@Output(Barista.OUTPUT_CHANNEL)
MessageChannel logoutput();
}
3、定义RabbitmqSender类
//启动这个绑定
@EnableBinding(Barista.class)
@Service //注入到spring容器
public class RabbitmqSender {
//注入Barista
@Autowired
private Barista barista;
// 发送消息
public String sendMessage(Object message, Map<String, Object> properties) throws Exception {
try{
MessageHeaders mhs = new MessageHeaders(properties);
Message msg = MessageBuilder.createMessage(message, mhs);
boolean sendStatus = barista.logoutput().send(msg);
System.err.println(“--------------sending -------------------”);
System.out.println(“发送数据：” + message + ",sendStatus: " + sendStatus);
}catch (Exception e){
System.err.println(“-------------error-------------”);
e.printStackTrace();
throw new RuntimeException(e.getMessage());
}
return null;
}
}
4、application.properties
server.port=8001
server.servlet.context-path=/producer
spring.application.name=producer
spring.cloud.stream.bindings.output_channel.destination=exchange-3
group相称于RabbitMQ中Queue的名称

spring.cloud.stream.bindings.output_channel.group=queue-3
##以下为集群情况配置，rabbit_cluster与下面的spring.cloud.stream.binders.rabbit_cluster是对应的。
spring.cloud.stream.bindings.output_channel.binder=rabbit_cluster
spring.cloud.stream.binders.rabbit_cluster.type=rabbit
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.addresses=localhost:5672
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.username=user_cp
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.password=123456
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.virtual-host=/vhost_cp
2.1 消费端

1、pom.xml引入依靠
<?xml version="1.0" encoding="UTF-8"?> <project xmlns=“http://maven.apache.org/POM/4.0.0” xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
xsi:schemaLocation=“http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd”>
4.0.0
com.cp
rabbitmq-springcloudstream-consumer
0.0.1-SNAPSHOT
jar
rabbitmq-springcloudstream-consumer
rabbitmq-spring
org.springframework.boot
spring-boot-starter-parent
1.5.8.RELEASE
   
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
org.springframework.boot
spring-boot-starter-web
org.springframework.boot
spring-boot-starter
org.springframework.boot
spring-boot-starter-test
test
org.springframework.cloud
spring-cloud-starter-stream-rabbit
1.3.4.RELEASE
org.springframework.boot
spring-boot-starter-actuator
org.springframework.boot
spring-boot-maven-plugin
2、定义Barista接口
/**

*/
public interface Barista {
String INPUT_CHANNEL = “input_channel”;
//注解@Input声明确它是一个输入范例的通道，名字是Barista.INPUT_CHANNEL，也就是position3的input_channel。这一名字与上述配置app2的配置文件中position1应该一致，表明注入了一个名字叫做input_channel的通道，它的范例是input，订阅的主题是position2处声明的mydest这个主题
@Input(Barista.INPUT_CHANNEL)
SubscribableChannel loginput();
}
3、定义RabbitmqReceiver类
//启动binding
@EnableBinding(Barista.class)
@Service
public class RabbitmqReceiver {
@StreamListener(Barista.INPUT_CHANNEL)
public void receiver(Message message) throws Exception {
//手工签收必须要有channel与deliveryTag
Channel channel = (com.rabbitmq.client.Channel) message.getHeaders().get(AmqpHeaders.CHANNEL);
Long deliveryTag = (Long) message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);
System.out.println(“Input Stream 1 接受数据：” + message);
System.out.println(“消费完毕------------”);
//批量签收设置为false
channel.basicAck(deliveryTag, false);
}
}
4、application.properties
server.port=8002
server.context-path=/consumer
spring.application.name=consumer
spring.cloud.stream.bindings.input_channel.destination=exchange-3
spring.cloud.stream.bindings.input_channel.group=queue-3
spring.cloud.stream.bindings.input_channel.binder=rabbit_cluster
##默认监听数
spring.cloud.stream.bindings.input_channel.consumer.concurrency=1
##针对消费端channel举行设置，是否支持requeue，重回队列
spring.cloud.stream.rabbit.bindings.input_channel.consumer.requeue-rejected=false
##是否支持签收，签收模式：手工签收
spring.cloud.stream.rabbit.bindings.input_channel.consumer.acknowledge-mode=MANUAL
##服务重连
spring.cloud.stream.rabbit.bindings.input_channel.consumer.recovery-interval=3000
##是否持久化订阅
spring.cloud.stream.rabbit.bindings.input_channel.consumer.durable-subscription=true
##最大监听数
spring.cloud.stream.rabbit.bindings.input_channel.consumer.max-concurrency=5
##接纳rabbitmq方式，也可以接纳kafka
spring.cloud.stream.binders.rabbit_cluster.type=rabbit
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.addresses=localhost:5672
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.username=user_cp
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.password=123456
spring.cloud.stream.binders.rabbit_cluster.environment.spring.rabbitmq.virtual-host=/vhost_cp
3. 运行测试
3.1 运行消费端

启动项目后，查看守控台是否生成了Exchange与Queue


启动项目后，SpringCloudStream生成了Exchange与Queue。
3.2 运行生产端测试代码

@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
@Autowired
private RabbitmqSender rabbitmqSender;
@Test
public void sendMessageTest1() throws InterruptedException {
自我介绍一下，小编13年上海交大结业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数Java工程师，想要提拔技能，每每是自己摸索发展大概是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学结果低效又漫长，而且极易遇到天花板技术停滞不前！
因此收集整理了一份《2024年Java开辟全套学习资料》，初志也很简朴，就是希望能够帮助到想自学提拔又不知道该从何学起的朋侪，同时减轻大家的负担。



既有适合小白学习的零根本资料，也有适合3年以上经验的小伙伴深入学习提拔的进阶课程，基本涵盖了95%以上Java开辟知识点，真正体系化！
由于文件比力大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习条记、源码课本、实战项目、讲授视频，并且会一连更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）
最后的内容

在开头跟大家分享的时间我就说，面试我是没有做好准备的，端赖平时的积聚，确实有点临时抱佛脚了，以至于我自己还是挺懊恼的。（准备好了大概可以拿个40k，没做准备只有30k+，你们懂那种感觉吗）
如何准备面试？
1、前期铺垫（技术沉积）
程序员面试其实是对于技术的一次摸底考试，你的技术牛逼，那你就是大爷。大厂对于技术的要求主要表现在：根本，原理，深入研究源码，广度，实战五个方面，也只有将原理理论联合实战才能把技术点吃透。
下面是我会看的一些资料条记，希望能帮助大家由浅入深，由点到面的学习Java，应对大厂面试官的灵魂追问
   这部分内容过多，小编只贴出部分内容展示给大家了，见谅见谅！
  




四部分，详细拆分并发编程——并发编程+模式篇+应用篇+原理篇





其他像Spring，SpringBoot，SpringCloud，SpringCloudAlibaba，Dubbo，Zookeeper，Kafka，RocketMQ，RabbitMQ，Netty，MySQL，Docker，K8s等等我都整理好，这里就不一一展示了。

2、狂刷面试题
技术主要是表现在平时的积聚实用，面试前准备两个月的时间再好好复习一遍，紧接着就可以刷面试题了，下面这些面试题都是小编精心整理的，贴给大家看看。
①大厂高频45道笔试题（智商题）

②BAT大厂面试总结（部分内容截图）


③面试总结


3、联合实际，修改简历
程序员的简历肯定要多下一些功夫，尤其是对一些字眼要再三斟酌，如“精通、熟悉、了解”这三者的区别肯定要区分清楚，否则就是在给自己挖坑了。当然不会包装，我可以将我的简历给你参考参考，如果还不够，那下面这些简历模板任你挑选：

以上分享，希望大家可以在金三银四跳槽季找到一份好工作，但万万也记住，技术肯定是平时工作种累计大概自学（或报班跟着老师学）通过实战累计的，万万不要临时抱佛脚。
别的，面试中遇到不会的题目不妨尝试讲讲自己的思路，由于有些题目不是观察我们的编程能力，而是逻辑头脑表达能力；最后平时要举行自我分析与评价，做好职业规划，不断摸索，进步自己的编程能力和抽象头脑能力。
《一线大厂Java面试题解析+核心总结学习条记+最新讲授视频+实战项目源码》，点击传送门即可获取！
982785)]
[外链图片转存中…(img-FM3HsOnK-1712483982786)]
③面试总结
[外链图片转存中…(img-7XZLjshl-1712483982786)]
[外链图片转存中…(img-wtdIi5qp-1712483982786)]
3、联合实际，修改简历
程序员的简历肯定要多下一些功夫，尤其是对一些字眼要再三斟酌，如“精通、熟悉、了解”这三者的区别肯定要区分清楚，否则就是在给自己挖坑了。当然不会包装，我可以将我的简历给你参考参考，如果还不够，那下面这些简历模板任你挑选：
[外链图片转存中…(img-QHLrFA2A-1712483982787)]
以上分享，希望大家可以在金三银四跳槽季找到一份好工作，但万万也记住，技术肯定是平时工作种累计大概自学（或报班跟着老师学）通过实战累计的，万万不要临时抱佛脚。
别的，面试中遇到不会的题目不妨尝试讲讲自己的思路，由于有些题目不是观察我们的编程能力，而是逻辑头脑表达能力；最后平时要举行自我分析与评价，做好职业规划，不断摸索，进步自己的编程能力和抽象头脑能力。
《一线大厂Java面试题解析+核心总结学习条记+最新讲授视频+实战项目源码》，点击传送门即可获取！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4