海城seo网站排名优化推广,餐饮网站建设教程,重庆手机网站推广资料,网络建设与运维初级使用Spring-Kafka快速发送/接受Kafka消息示例代码#xff0c;项目结构是最基础的SpringBoot结构#xff0c;提前安装好Kafka#xff0c;确保Kafka已经正确启动
pom.xml#xff0c;根据个人情况更换springboot、java版本等
?xml version1.0 encoding项目结构是最基础的SpringBoot结构提前安装好Kafka确保Kafka已经正确启动
pom.xml根据个人情况更换springboot、java版本等
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.4.1/versionrelativePath/ !-- lookup parent from repository --/parentgroupIdorg.example/groupIdartifactIdkafka-study/artifactIdversion0.0.1-SNAPSHOT/versionnamekafka-study/namedescriptionkafka-study/descriptionurl/licenseslicense//licensesdevelopersdeveloper//developersscmconnection/developerConnection/tag/url//scmpropertiesjava.version21/java.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter/artifactId/dependencydependencygroupIdorg.springframework.kafka/groupIdartifactIdspring-kafka/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.springframework.kafka/groupIdartifactIdspring-kafka-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactIdversionRELEASE/versionscopecompile/scope/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project
application.properies
spring.application.namekafka-study
server.port8081
spring.kafka.producer.bootstrap-servers127.0.0.1:9092启动类
package org.example.kafkastudy;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;SpringBootApplication
public class KafkaStudyApplication {public static void main(String[] args) {SpringApplication.run(KafkaStudyApplication.class, args);}}
Controller
package org.example.kafkastudy.controller;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;/*** KafkaController* date 2024/12/26*/
RestController
public class KafkaController {private final Logger logger LoggerFactory.getLogger(KafkaController.class);Autowiredprivate KafkaTemplateObject, Object template;GetMapping(/send/{input})public void sendFoo(PathVariable String input) {this.template.send(topic_input, input);}KafkaListener(id webGroup, topics topic_input)public void listen(String input) {logger.info(input value: {} , input);}}
启动主启动类浏览器调用接口localhost:8081/send/xxxx将执行向Kafka的topic_input主题发送xxxx内容同时控制台中可看到有xxxx内容的打印测试成功
