欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Spring boot 整合KAFKA消息隊列的示例

 更新時間:2020年10月16日 11:33:50   作者:拾階求上  
這篇文章主要介紹了Spring boot 整合 KAFKA 消息隊列的示例,幫助大家更好的理解和使用spring boot框架,感興趣的朋友可以了解下

這里使用 spring-kafka 依賴和 KafkaTemplate 對象來操作 Kafka 服務。

一、添加依賴和添加配置項

1.1、在 Pom 文件中添加依賴

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
 </dependency>

1.2、添加配置項

spring:
 kafka:
 bootstrap-servers: 12.168.3.62:9092 # 指定kafka 代理地址,可以多個
 producer:
  retries: 2 # 寫入失敗時,重試次數(shù)。當retris為0時,produce不會重復。
  batch-size: 1000 #每次批量發(fā)送消息的數(shù)量,produce積累到一定數(shù)據(jù),一次發(fā)送
  buffer-memory: 33554432 # produce積累數(shù)據(jù)一次發(fā)送,緩存大小達到buffer.memory就發(fā)送數(shù)據(jù)
  acks: 0 #procedure要求leader在考慮完成請求之前收到的確認數(shù),用于控制發(fā)送記錄在服務端的持久化,如果設置為零,則生產者將不會等待來自服務器的任何確認。
  key-serializer: org.apache.kafka.common.serialization.StringSerializer #指定消息key和消息體的編解碼方式
  value-serializer: org.apache.kafka.common.serialization.StringSerializer

二、代碼編寫

2.1、添加一個消息類

package com.jsh.mgt.kafkaTemplate.kafka;

import java.util.Date;
import lombok.Data;

/**
 * @since 2020/5/21 14:13
 */
@Data
public class Message {
 private Long id; //id

 private String msg; //消息

 private Date sendTime; //時間戳
}

2.2、設置消息生產者

package com.jsh.mgt.kafkaTemplate.Controllers;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.jsh.mgt.kafkaTemplate.kafka.Message;
import java.util.Date;
import java.util.UUID;
import org.springframework.beans.factory.annotation.Autowired;
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;

/**
 * @since 2020/5/21 11:19
 */
@RestController
public class KafkaController {
 @Autowired
 private KafkaTemplate<String,Object> kafkaTemplate;

 private Gson gson = new GsonBuilder().create();

 @GetMapping("/kafka/{msg}")
 public Object test(@PathVariable("msg") String msg) {
 Message message = new Message();
 message.setId(System.currentTimeMillis());
 message.setMsg(UUID.randomUUID().toString()+ "-"+msg);
 message.setSendTime(new Date());
 kafkaTemplate.send("topic-create",gson.toJson(message));
 return "ok";
 }
}

以上就是Spring boot 整合 KAFKA 消息隊列的示例的詳細內容,更多關于Spring boot 整合消息隊列的資料請關注腳本之家其它相關文章!

相關文章

  • Java設計模式之java策略模式詳解

    Java設計模式之java策略模式詳解

    這篇文章主要介紹了Java經典設計模式之策略模式,簡單說明了策略模式的概念、原理并結合實例形式分析了java策略模式的具有用法與相關注意事項,需要的朋友可以參考下
    2021-09-09
  • 使用springboot單例模式與線程安全問題踩的坑

    使用springboot單例模式與線程安全問題踩的坑

    這篇文章主要介紹了使用springboot單例模式與線程安全問題踩的坑,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-08-08
  • Java面向對象之繼承性的實例代碼詳解

    Java面向對象之繼承性的實例代碼詳解

    這篇文章主要介紹了Java面向對象之繼承性,文中代碼簡單易懂,可以更好的幫助大家學習,有興趣的小伙伴快來了解下
    2020-05-05
  • 圖解Java排序算法之3種簡單排序

    圖解Java排序算法之3種簡單排序

    這篇文章主要為大家詳細介紹了Java排序算法之3種簡單排序,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-11-11
  • 基于java中集合的概念(詳解)

    基于java中集合的概念(詳解)

    下面小編就為大家?guī)硪黄趈ava中集合的概念(詳解)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-09-09
  • java中Integer包裝類裝箱的一個細節(jié)詳解

    java中Integer包裝類裝箱的一個細節(jié)詳解

    Java中的Integer是int的包裝類型,下面這篇文章主要給大家介紹了關于java中Integer包裝類裝箱的一個細節(jié)的相關資料,文中介紹的這個細節(jié)挺重要的,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起看看吧
    2018-07-07
  • Spring事件監(jiān)聽機制ApplicationEvent方式

    Spring事件監(jiān)聽機制ApplicationEvent方式

    這篇文章主要介紹了Spring事件監(jiān)聽機制ApplicationEvent方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-09-09
  • Java出現(xiàn)中文亂碼問題分析及解決方案

    Java出現(xiàn)中文亂碼問題分析及解決方案

    在Java開發(fā)中,處理中文亂碼是一個常見的問題,由于字符集和編碼的復雜性,開發(fā)者可能面臨各種導致亂碼的情況,正確地處理中文字符集對于確保應用程序的可靠性和國際化至關重要,本文給大家介紹了Java中文亂碼分析及解決方案,需要的朋友可以參考下
    2024-02-02
  • 五分鐘手擼一個Spring容器(萌芽版)

    五分鐘手擼一個Spring容器(萌芽版)

    Spring的兩大內核分別是IOC和AOP,其中最最核心的是IOC。這篇文章主要介紹了五分鐘,手擼一個Spring容器的相關知識,需要的朋友可以參考下
    2022-03-03
  • 論Java Web應用中調優(yōu)線程池的重要性

    論Java Web應用中調優(yōu)線程池的重要性

    這篇文章主要論述Java Web應用中調優(yōu)線程池的重要性,通過了解應用的需求,組合最大線程數(shù)和平均響應時間,得出一個合適的線程池配置
    2016-04-04

最新評論