SpringBoot Kafka 통합 사용 및 설치 튜 토리 얼

전제 조건
SpringBoot 와 Kafka 를 알 았 다 고 가정 해 봐.
1、SpringBoot
SpringBoot 에 대해 잘 모 르 신다 면 DD 사내 와 순결 한 미소 의 시리즈 블 로 그 를 방문 해 보 세 요.
2、Kafka
Kafka 의 경우 제 가 이틀 전에 쓴 블 로 그 를 볼 수 있 습 니 다.Kafka 가 설치 하고 빠 른 입문 을 하면 가상 컴퓨터 를 켜 고 수 동 으로 환경 을 구축 하 세 요.조건 부 로 서버 를 사 세 요.
주의:반드시 직접 설치 하고 실천 해 야 합 니 다.그 다음 에 우 리 는 이 두 가 지 를 통합 시 킬 것 입 니 다.
프로젝트 생 성
프로젝트 전체 구조:

IDEA 를 사용 하여 SpringBoot 프로젝트 를 만 듭 니 다.이것 은 간단 합 니 다.여 기 는 너무 많은 설명 을 하지 않 습 니 다.
1.pom 파일 코드 는 다음 과 같 습 니 다.

<?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">
 <modelVersion>4.0.0</modelVersion>
 <groupId>com.zhisheng</groupId>
 <artifactId>kafka-learning</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <packaging>jar</packaging>
 <name>kafka-learning</name>
 <description>Demo project for Spring Boot + kafka</description>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.9.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <properties>
  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  <java.version>1.8</java.version>
 </properties>
 <dependencies>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
   <groupId>org.projectlombok</groupId>
   <artifactId>lombok</artifactId>
   <optional>true</optional>
  </dependency>
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
  </dependency>
  <dependency>
   <groupId>org.springframework.kafka</groupId>
   <artifactId>spring-kafka</artifactId>
   <version>1.1.1.RELEASE</version>
  </dependency>
  <dependency>
   <groupId>com.google.code.gson</groupId>
   <artifactId>gson</artifactId>
   <version>2.8.2</version>
  </dependency>
 </dependencies>
 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>
</project>

주로 spring-kafka,lombok,gs on 의존 도 를 도입 했다.
2.메시지 실체 클래스 Message.java 는 다음 과 같 습 니 다.

@Datapublic class Message { private Long id; //id
 private String msg; //  
 private Date sendTime; //   
}

3,메시지 전송 클래스 KafkaSender.java

@Component
@Slf4jpublic
class KafkaSender {

 @Autowired
 private KafkaTemplate<String, String> kafkaTemplate;
 private Gson gson = new GsonBuilder().create();

 //      
 public void send() {
  Message message = new Message();
  message.setId(System
    .currentTimeMillis());
  message.setMsg(UUID.randomUUID().toString());
  message.setSendTime(new Date())
  ;
  log.info("+++++++++++++++++++++ message = {}", gson.toJson(message));
  kafkaTemplate.send
    ("zhisheng", gson.toJson(message));
 }
}

이렇게 해서 메시지 코드 를 보 내 면 이 루어 집 니 다.
여기 서 관건 적 인 코드 는kafkaTemplate.send() 방법 입 니 다.zhisheng 은 Kafka 의 topic 입 니 다.이 topic 는 자바 프로그램 에서 Kafka 에 미리 설정 할 필요 가 없습니다.보 낼 때 자동 으로 설정 한 topic， gson.toJson(message)메시지 내용 을 만 들 기 때 문 입 니 다.여 기 는 잠시 이렇게 많이 말 했 습 니 다.자세 한 내용 은 모 르 겠 습 니 다.나중에 기회 가 있 으 면 안에 있 는 소스 코드 를 계속 읽 고 블 로 그 를 써 라.
4,메시지 수신 클래스 KafkaReceiver.java

@Component
@Slf4jpublic
class KafkaReceiver {
 @KafkaListener(topics = {"zhisheng"})
 public void listen(ConsumerRecord<?, ?> record) {
  Optional<?> kafkaMessage = Optional.ofNullable(record.value());
  if (kafkaMessage.isPresent()) {
   Object message = kafkaMessage.get();
   log.info("----------------- record =" + record);
   log.info("------------------ message =" + message);
  }
 }
}

클 라 이언 트 consumer 는 메 시 지 를 받 는 것 이 매우 간단 합 니 다.@KafkaListener 로 직접 주석 을 달 면 됩 니 다.감청 에 감청 하 는 topic 를 설정 합 니 다.topics 는 하나의 배열 이기 때문에 여러 테 마 를 연결 할 수 있 습 니 다.위의 코드 에서@KafkaListener(topics={"zhisheng","tian"}) 로 수정 하면 두 topic 의 메 시 지 를 동시에 감청 할 수 있 습 니 다.주의해 야 할 것 은:이 topic 은 메시지 발송 류 KafkaSender.java 에 설 치 된 topic 와 일치 해 야 합 니 다.
5.시작 클래스 KafkaApplication.java

@SpringBootApplicationpublic
class KafkaApplication {
 public static void main(String[] args) {
  ConfigurableApplicationContext context = SpringApplication.run(KafkaApplication.class, args);
  KafkaSender sender = context.getBean(KafkaSender.class);
  for (int i = 0; i < 3; i++) {   
   //                  
   sender.send();
   try {
    Thread.sleep(3000);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }
}

6.프로필 application.properties

#============== kafka ===================#   kafka     ，    
spring.kafka.bootstrap-servers=192.168.153.135:9092
##=============== provider =======================
#spring.kafka.producer.retries=0#            
spring.kafka.producer.batch-size=16384spring.kafka.producer.buffer-memory=33554432
##     key          
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
##=============== consumer =======================#        group id
spring.kafka.consumer.group-id=test-consumer-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=100
##     key          
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

spring.kafka.bootstrap-servers 뒤에 당신 이 설치 한 Kafka 의 기계 IP 주소 와 포트 번호 9092 를 설정 합 니 다.
만약 네가 단지 간단하게 통합 할 뿐 이 라면,다른 몇 가지 기본 값 을 사용 하면 된다.
Kafka 설정
설치 한 Kafka 디 렉 터 리 파일 아래:
시작 zk
패키지 에 설 치 된 스 크 립 트 를 사용 하여 단일 노드 Zookeeper 인 스 턴 스 를 시작 합 니 다.

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

Kafka 서비스 시작
kafka-server-start.sh 를 사용 하여 kafka 서 비 스 를 시작 합 니 다:

bin/kafka-server-start.sh config/server.properties

시작 성공 후!

제발 주의:가상 컴퓨터 나 서버 를 방화벽 을 닫 거나 Kafka 포트 9092 를 켜 는 것 을 기억 하 세 요.
운행 하 다.

나타 나 면 통합 이 성공 한 거 야!
--------------------------------------------------------------------------------
저희 가 Kafka 의 topic 리스트 를 보면...

bin/kafka-topics.sh --list --zookeeper localhost:2181

방금 우리 프로그램 에 있 는 zhishing 이 스스로 만 들 었 다 는 것 을 알 게 될 것 입 니 다.
총결산
위 에서 말씀 드 린 것 은 편집장 님 께 서 소개 해 주신 SpringBoot Kafka 통합 사용 및 설치 튜 토리 얼 입 니 다.도움 이 되 셨 으 면 좋 겠 습 니 다.궁금 한 점 이 있 으 시 면 메 시 지 를 남 겨 주세요.편집장 님 께 서 바로 답 해 드 리 겠 습 니 다.여기 서도 저희 사이트 에 대한 여러분 의 지지 에 감 사 드 립 니 다!
만약 당신 이 본문 이 당신 에 게 도움 이 된다 고 생각한다 면,전 재 를 환영 합 니 다.번 거 로 우 시 겠 지만 출처 를 밝 혀 주 십시오.감사합니다!