整合redis kafka es步驟

2021-10-04 19:12:02 字數 2821 閱讀 9968

一.整合kafka(生產者)步驟

1.匯入依賴(pom.xml)

2.編寫配置檔案,修改配置檔案的ip和埠號,修改主題(producer.xml)

3.如果再ssm專案中可以讓spring.xml來載入這個配置檔案

如果是再測試類中如何載入?

@runwith(springjunit4classrunner.class)

//載入生產者的配置

@contextconfiguration(「classpath:producer.xml」)

4.就可以在**中所需的位置進行注入:

@autowired

kafkatemplatekafkatemplate;

然後就可以直接呼叫send方法來傳送訊息 了!!(如果我們傳送的是物件,一般情況下,會把物件轉成json再傳送)

kafkatemplate.send(「cms_articles」,jsonstring);

三.整合redis的步驟

1.匯入依賴(pom.xml)

2.編寫配置檔案,修改ip和埠

3.讓spring.xml載入redis.xml

4.可以在**的位置注入redistemplate

5.就可對redis進行crud了

四.整合elasticsearch的步驟

1.匯入依賴(pom.xml)

2.編寫配置檔案(es.xml)

3.修改ip位址和埠號&&修改倉庫介面的包掃瞄位置

4.讓spring來載入es.xml

5.在第3步倉庫界麵包的位置,建立乙個倉庫介面***repository

6.讓倉庫介面繼承elasticsearchrepository,之後就自動具備了簡單的crud的方法

extends elasticsearchrepository

7.宣告實體類的各種註解(指定索引庫名,表名,主鍵,實體類屬性儲存引數)

//指定了庫名(庫名必須用純小寫的名字,不允許有特殊字元,否則就報錯),指定了表名

@document(indexname=「test_user」,type=「user」)

@id//指定name的值是否索引,2.是否儲存3.name的值的分詞方式 4.搜尋的關鍵字分詞的方式 5指定該字段的值以什麼樣的資料型別來儲存

@field(index=true,store=true,analyzer=「ik_smart」,searchanalyzer=「ik_smart」,type=fieldtype.text)

8可以在任意位置進行注入倉庫介面,也可以注入elasticsearchtemplate

@autowired

userrespository respository;

@autowired

elasticsearchtemplate elasticsearchtemplate;

就可以呼叫crud方法了

注意:如果要進行複雜點的查詢,此時,需要我們自定義方法.自定義方法的規則必須按照命名規則來進行為方法命名

具體示例:

list findbyname(string name);

//根據位址查詢

// listfindbyaddress(string address);

// // //根據位址和姓名查詢

// listfindbyaddressandname(string address,string name);

// //根據位址或姓名查詢

// listfindbyaddressorname(string address,string name);

//查詢id小於5的資料

// listfindbyidlessthan(int id);

//查詢**在多少-多少之間的

listfindbypricebetween(double money,double money)

cms系統中,實現搜尋(高亮顯示)

1.頁面層面->必須有搜尋框和搜尋按鈕

2.修改搜尋框的form表單的請求方式,和請求路徑

3.根據前台的form表達的請求方式,然後編寫後台controller層.(讓controller層的**,接收咱們的搜尋關鍵字)

4.由於咱們的搜尋資料是從es索引庫來查詢的,因此我們要做的事情:從mysql中查詢出來資料,然後儲存到es索引庫

es索引庫就有資料了

5.由於cms系統還有整合es技術呢,因此,我還要做一件事情:在cms系統中,整合es---->參考四

6.可以呼叫倉庫介面(findbytitle())實現普通搜尋(非高亮)

7.如果要實現高亮的話:呼叫高亮顯示的工具類

//1.搜尋需要的模板類 2.指定要操作的實體類型別 3.當前頁 4.每頁頁顯示多少條 5.是乙個string型別的陣列陣列裡存放的是:來進行搜尋的字段(必須和實體類中的字段保持一致) 6.指定要排序的字段 7.搜尋的關鍵字

pageinfoinfo = (pageinfo) hlutils.findbyhighlight(elasticsearchtemplate, cms_article.class, pagenum, pagesize, new string , 「id」, key);

=在專案部署的時候:如果是你認為你的步驟都對,專案也對,但是,訪問專案一直轉圈,訪問不了

有可能是你的windows上的mysql安裝的時候,不允許遠端使用者訪問(只允許localhost或者127.0.0.1來訪問)

只需要開啟小綠葉執行如下兩個命令:

grant all privileges on . to 『root』@』%』 identified by 『這個是你的mysql的密碼』;

flush privileges;

第五步 整合SpringTask(實現定時任務)

1 新增依賴 由於springtask已經存在於spring框架中,不需要額外新增依賴 2 新增spring task配置package com.hzf.mymall.config import org.springframework.context.annotation.configuration...

ShareSDK整合第三方登入和分享的步驟

分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!之前用過這個幾次了,而每次都沒有記錄一下具體的步驟,這次就寫一下吧 2 現在他們的服務特別人性化,解壓sdk之後會發現有乙個 雙擊此批處理檔案可以生成乙個快速整合sharesdk的目錄.bat 這樣乙個檔案,開啟之後按照提示輸入你的應用包名,他就會...

ShareSDK整合第三方登入和分享的步驟

之前用過這個幾次了,而每次都沒有記錄一下具體的步驟,這次就寫一下吧 2 現在他們的服務特別人性化,解壓sdk之後會發現有乙個 雙擊此批處理檔案可以生成乙個快速整合sharesdk的目錄.bat 這樣乙個檔案,開啟之後按照提示輸入你的應用包名,他就會給你生成乙個目錄,你直接拷貝到你的專案中就ok了,拷...