【十九】初学Kafka并实战整合SpringCloudStream进行使用

小z666

发布于 2024-06-21 17:51:43

690

发布于 2024-06-21 17:51:43

文章被收录于专栏：javajava

一、下载安装Kafka

要进行kafka的学习，首先肯定得安装kafka了。安装地址如下：

Apache Kafka

很慢，可以去找百度云资源。

1、下载Scala版本的，可以直接使用。

watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCPeuKZgA==,size_20,color_FFFFFF,t_70,g_se,x_16

，然后点击链接进行下载。

2、解压后得到如下：

3、进入kafka安装目录：

4、执行命令启动zookeeper和kafka，需要先启动zookeeper，再启动kafka（kafka安装后，默认带了一个zookeeper），都有一套默认配置，此处就不修改配置了，直接使用默认配置启动，命令如下：

启动zookeeper： bin\windows\zookeeper-server-start.bat config\zookeeper.properties 启动kafka： bin\windows\kafka-server-start.bat config\server.properties 注意：是在bin目录上级执行的。此处是在windows上的启动命令，linux的不一样，后面有机会再学习。

表示两者已经启动成功了，下面可以开启构建项目了。

注意：zookeeper默认占用端口号：2181，kafka占用9092，注意跑之前看看端口是否被占用，否则出现端口冲突问题。

二、构建父子工程

为了测试消费者服务和生产者服务，所以父子工程就长这样：

上次整合RabbitMQ时就建立了这个，此处直接拿来用了。

三、使用SpringCloudStream默认的信道实现消息传递

下面通过SpringCloudSteam实现Kafka，最基本的一个使用流程，差不多是下面这个样子（可能描述不准确）：

如图可知，大概的一个流程就是（只学习了最基本的使用）：

构建消息生产者
指定消息输入通道，并指定该通道指向的Topic
构建消息消费者
指定消息输出通道，并指定该通道订阅哪一个Topic
构建消费者监听器，监听指定的输出通道，并获取消息进行消费

大概流程就是这样，下面开始具体操作。

本节实现功能：生成订单时，创建订单记录并通知买家（通过邮件和短信）。

先准备“构建材料”，在父模块引入所需jar包：

<dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-stream-kafka</artifactId>
     <version>3.0.3.RELEASE</version>       
</dependency>

增加这一个Jar包即可。

重点！！！：此处有个大坑，仍旧是版本问题，我目前的版本是这样的（这种我自己没问题）：

2.3.*和3.0.*，试了很多版本组合都会运行时报错，不是找不到这个类就是找不到哪个类，后面再去研究一下版本匹配问题。

3.1 构建生产者服务

依赖导入完成就开始构建生产者服务。

3.1.1 修改配置文件

主要是绑定SpringCloudStream的输入信道以及指定kafka的服务器地址。

上图的output是Stream自带的消息输入信道，从最开始的流程图可以得知，需要新建topic和信道的绑定关系，上图的意思就是在output信道绑定上stream-demo这个topic，content-type是指发送的消息的格式，若想在消费端进行消息类型的转换，最好使用application/json类型。

注意：上图的output输入信道是stream自带的，还自带了一个输出信道input。