热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Kafka是什么?RocketMQ在SpringBoot中怎么整合使用/Kafka在SpringBoot中简单配置使用

写在前面:继续记录自己的SpringBoot学习之旅,这次是SpringBoot应用相关知识学习记录。若看不懂则建议先看前几篇博客,详细代




写在前面:
继续记录自己的SpringBoot学习之旅,这次是SpringBoot应用相关知识学习记录。若看不懂则建议先看前几篇博客,详细代码可在我的Gitee仓库SpringBoot克隆下载学习使用!


3.5.4.5 SpringBoot整合RocketMQ

3.5.4.5.1 RocketMQ安装

  • 点击RockedMQ网站下载解压,这里选择4.9.2 Binary版本
  • 配置环境变量,默认端口号是9876,如图
    ![[Pasted image 20221117144535.png]]
    ![[Pasted image 20221117144433.png]]![[Pasted image 20221117144345.png]]
    在这里插入图片描述
  • 启动namespaceServer服务,点击bin里中的mqnamesrv,如图
    ![[Pasted image 20221117144937.png]]
    ![[Pasted image 20221117144951.png]]
  • 启动mqbroker服务,同上,点击mqbroker.cmd,如图![[Pasted image 20221117154514.png]]
    **注:**若报错则是jdk目录安装在C盘里的Program Files中,解决办法是打开打开runbroker.cmd,然后将‘%CLASSPATH%’加上英文双引号,如图![[Pasted image 20221117154616.png]]
  • 消息生产消费测试
    • 生产者测试,cmd命令输入tools tools org.apache.rockedmq.example.quickstart.Producer,如图即可![[Pasted image 20221117155437.png]]
    • 消费者测试,cmd命令输入tools org.apache.rocketmq.example.quickstart.Consumer,如图![[Pasted image 20221117155522.png]]

3.5.4.5.2 整合

  • SpringBoot添加坐标,在maven仓库搜索RocketMQ找到有Starter的,复制粘贴,如图![[Pasted image 20221117155924.png]]
  • 配置yml,如图
  • ![[Pasted image 20221117161540.png]]
  • 编辑实现类发送同步消息,并将之前实现类@Service注释掉,如下:

@Service
public class MessageServiceRocketmqImpl implements MessageService {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@Override
public void sendMessage(String id) {
System.out.println("待发送短信的订单已纳入处理队列(rocketmq),id: " + id);
rocketMQTemplate.convertAndSend("order_id",id);
}
@Override
public String doMessage() {
return null;
}
}

,运行后如图
在这里插入图片描述


  • 编写监听器,如下:

@Component
@RocketMQMessageListener(topic = "order_id",consumerGroup = "group_rocketmq_01")
public class MessageListener implements RocketMQListener<String> {
&#64;Override
public void onMessage(String id) {
System.out.println("已完成短信发送业务(rocketmq),id&#61;" &#43; id);
}
}

,运行后如图![[Pasted image 20221117163447.png]]


  • 编辑实现类发送异步消息&#xff0c;同上&#xff0c;更改如图![[Pasted image 20221117164111.png]]
    &#xff0c;运行如图![[Pasted image 20221117164133.png]]

3.5.4.6 SpringBoot整合kafka

3.5.4.6.1 Kafka安装

  • 点击Kafka网站下载版本&#xff0c;选择2.8.2版本
  • 下载后解压缩即可
  • 启动zookeeper服务&#xff0c;默认端口2181&#xff0c;CMD命令如下zookeeper-server-start.bat ../../config/zookeeper.properties&#xff0c;若报错命令行太长&#xff0c;使用短的文件名
  • 启动kafka服务&#xff0c;默认端口9092&#xff0c;命令kafka-server-start.bat ../../config/server.properties即可

3.5.4.6.2 kafka测试

  • 创建topic,cmd命令kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo,如图![[Pasted image 20221118190835.png]]
  • 查看topic,cmd命令kafka-topics.bat --zookeeper 127.0.0.1:2181 --list&#xff0c;如图![[Pasted image 20221118191050.png]]
  • 启动生产者&#xff0c;cmd命令kafka-console-producer.bat --broker-list localhost:9092 --topic demo
  • 启动消费者&#xff0c;cmd命令kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning
  • 生产者与消费者交互&#xff0c;生产者操作如图![[Pasted image 20221118193944.png]]
    &#xff0c;消费者如图
    ![[Pasted image 20221118193959.png]]

3.5.4.6.3 整合

  • 添加坐标&#xff0c;如下&#xff1a;


<dependency>
<groupId>org.springframework.kafkagroupId>
<artifactId>spring-kafkaartifactId>
dependency>

  • 配置yml&#xff0c;如图![[Pasted image 20221118200846.png]]
  • 添加实现类与监听器&#xff0c;如图![[Pasted image 20221118200900.png]]
    添加监听器如图![[Pasted image 20221118200919.png]]
    &#xff0c;结果如图![[Pasted image 20221118201041.png]]
    ![[Pasted image 20221118201058.png]]






推荐阅读
  • 本文分享了一个关于在C#中使用异步代码的问题,作者在控制台中运行时代码正常工作,但在Windows窗体中却无法正常工作。作者尝试搜索局域网上的主机,但在窗体中计数器没有减少。文章提供了相关的代码和解决思路。 ... [详细]
  • 本文介绍了Redis的基础数据结构string的应用场景,并以面试的形式进行问答讲解,帮助读者更好地理解和应用Redis。同时,描述了一位面试者的心理状态和面试官的行为。 ... [详细]
  • 本文介绍了Oracle数据库中tnsnames.ora文件的作用和配置方法。tnsnames.ora文件在数据库启动过程中会被读取,用于解析LOCAL_LISTENER,并且与侦听无关。文章还提供了配置LOCAL_LISTENER和1522端口的示例,并展示了listener.ora文件的内容。 ... [详细]
  • XML介绍与使用的概述及标签规则
    本文介绍了XML的基本概念和用途,包括XML的可扩展性和标签的自定义特性。同时还详细解释了XML标签的规则,包括标签的尖括号和合法标识符的组成,标签必须成对出现的原则以及特殊标签的使用方法。通过本文的阅读,读者可以对XML的基本知识有一个全面的了解。 ... [详细]
  • 本文介绍了如何使用C#制作Java+Mysql+Tomcat环境安装程序,实现一键式安装。通过将JDK、Mysql、Tomcat三者制作成一个安装包,解决了客户在安装软件时的复杂配置和繁琐问题,便于管理软件版本和系统集成。具体步骤包括配置JDK环境变量和安装Mysql服务,其中使用了MySQL Server 5.5社区版和my.ini文件。安装方法为通过命令行将目录转到mysql的bin目录下,执行mysqld --install MySQL5命令。 ... [详细]
  • Java在运行已编译完成的类时,是通过java虚拟机来装载和执行的,java虚拟机通过操作系统命令JAVA_HOMEbinjava–option来启 ... [详细]
  • 本文讨论了Kotlin中扩展函数的一些惯用用法以及其合理性。作者认为在某些情况下,定义扩展函数没有意义,但官方的编码约定支持这种方式。文章还介绍了在类之外定义扩展函数的具体用法,并讨论了避免使用扩展函数的边缘情况。作者提出了对于扩展函数的合理性的质疑,并给出了自己的反驳。最后,文章强调了在编写Kotlin代码时可以自由地使用扩展函数的重要性。 ... [详细]
  • 本文介绍了在Linux下安装和配置Kafka的方法,包括安装JDK、下载和解压Kafka、配置Kafka的参数,以及配置Kafka的日志目录、服务器IP和日志存放路径等。同时还提供了单机配置部署的方法和zookeeper地址和端口的配置。通过实操成功的案例,帮助读者快速完成Kafka的安装和配置。 ... [详细]
  • 深入理解Kafka服务端请求队列中请求的处理
    本文深入分析了Kafka服务端请求队列中请求的处理过程,详细介绍了请求的封装和放入请求队列的过程,以及处理请求的线程池的创建和容量设置。通过场景分析、图示说明和源码分析,帮助读者更好地理解Kafka服务端的工作原理。 ... [详细]
  • 第四章高阶函数(参数传递、高阶函数、lambda表达式)(python进阶)的讲解和应用
    本文主要讲解了第四章高阶函数(参数传递、高阶函数、lambda表达式)的相关知识,包括函数参数传递机制和赋值机制、引用传递的概念和应用、默认参数的定义和使用等内容。同时介绍了高阶函数和lambda表达式的概念,并给出了一些实例代码进行演示。对于想要进一步提升python编程能力的读者来说,本文将是一个不错的学习资料。 ... [详细]
  • 本文介绍了在CentOS上安装Python2.7.2的详细步骤,包括下载、解压、编译和安装等操作。同时提供了一些注意事项,以及测试安装是否成功的方法。 ... [详细]
  • 本文介绍了Android中的assets目录和raw目录的共同点和区别,包括获取资源的方法、目录结构的限制以及列出资源的能力。同时,还解释了raw目录中资源文件生成的ID,并说明了这些目录的使用方法。 ... [详细]
  • 本文介绍了H5游戏性能优化和调试技巧,包括从问题表象出发进行优化、排除外部问题导致的卡顿、帧率设定、减少drawcall的方法、UI优化和图集渲染等八个理念。对于游戏程序员来说,解决游戏性能问题是一个关键的任务,本文提供了一些有用的参考价值。摘要长度为183字。 ... [详细]
  • 2021最新总结网易/腾讯/CVTE/字节面经分享(附答案解析)
    本文分享作者在2021年面试网易、腾讯、CVTE和字节等大型互联网企业的经历和问题,包括稳定性设计、数据库优化、分布式锁的设计等内容。同时提供了大厂最新面试真题笔记,并附带答案解析。 ... [详细]
  • ZooKeeper 学习
    前言相信大家对ZooKeeper应该不算陌生。但是你真的了解ZooKeeper是个什么东西吗?如果别人面试官让你给他讲讲ZooKeeper是个什么东西, ... [详细]
author-avatar
眼泪--保持微笑_572_205
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有