在spring中建立kafak生產者

2021-10-18 19:29:43 字數 1374 閱讀 8073

>

>

org.springframework.kafkagroupid

>

>

spring-kafkaartifactid

>

dependency

>

server.port=8089

#指定專案名

server.context-path=/gmall

#**********==== kafka ***************====

# 指定kafka **位址,可以多個

spring.kafka.bootstrap-servers=hadoop102:9092,hadoop103:9092,hadoop104:9092

# 指定訊息key和訊息體的編譯碼方式

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.stringserializer

spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.stringserializer

package com.atguigu.gmalllogger.controller;

import com.alibaba.fastjson.json;

import com.alibaba.fastjson.jsonobject;

import com.gmall.common.constansts.gmallconstants;

import lombok.extern.slf4j.slf4j;

import org.apache.log4j.logger;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.kafka.core.kafkatemplate;

import org.springframework.web.bind.annotation.restcontroller;

@restcontroller

@slf4j

//自動在容器中建立乙個記錄當前類資訊的logger,等價於 logger logger = logger.getlogger(maincontroller.class);

public

class

maincontroller

else

return

"success";}

}

在Spring中如何建立物件?

1.通過構造方法建立 1.1無參構造建立 預設情況。1.2有參構造建立 需要明確配置 構造方法過載時預設載入同參的最後乙個構造方法 1.2.1需要在類中提供有參構造方法。1.2.2.1如果設定的條件匹配多個構造方法,預設使用最後乙個構造方法。1.2.2.2 index 引數的索引,從 0 開始 1....

Spring 中建立通知

這些通知型別,結合方法呼叫連線點,可以完成90 的aop工作,對於剩下的不常用的10 我們可以依賴 aspectj來做。aspectj是什麼東西?沒用過。前置通知 介面 org.springframework.aop.methodbeforeadvice 說明 使用前置通知可以在連線點執行前進行自定...

spring中bean的建立

問題 1 bean 的建立時機 bean 是在什麼時候被建立的,有哪些規則?容器初始化的時候會預先對單例和非延遲載入的物件進行預先初始化。其他的都是延遲載入是在第一次呼叫getbean 的時候被建立。從 defaultlistablebeanfactory 的 preinstantiatesingl...