最近寫了個kafka的接收消息的功能,需要使用回調(diào)處理收到的消息。
為永興等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù),及永興網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站設(shè)計、成都網(wǎng)站建設(shè)、永興網(wǎng)站設(shè)計,以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達到每一位用戶的要求,就會得到認可,從而選擇與我們長期合作。這樣,我們也可以走得更遠!
一個是基本的回調(diào),一個是使用接口功能實現(xiàn)回調(diào),對接口是個很好的學(xué)習(xí)。
1.正常回調(diào)
kafka的接收消息處。收到消息后,使用傳入的Onmessage進行處理。
調(diào)用kafka接收消息的單元,并在調(diào)用方寫好回調(diào)
在調(diào)用方實現(xiàn)回調(diào)需要執(zhí)行的方法
感覺還是使用基本回調(diào)相對簡單點,接口就當(dāng)學(xué)習(xí)了。
另外跨包的接口的方法要大寫!定位了好久發(fā)現(xiàn)個入門的問題。
用于在開發(fā)階段,服務(wù)端接口沒有正式完成之前,模擬接口請求,便于客戶端測試。
建立一個文件夾(Config),放置所有的接口文件
將接口按如下json格式存儲到成文件,一個接口對應(yīng)一個文件
如登錄接口:./Config/login.json
定義接口
讀取所有的接口配置文件
上一章節(jié)介紹了使用echo啟動一個http服務(wù)器并提供一個簡單的GET接口,這一章對請求與響應(yīng)做一下詳細的講解。
了解請求與響應(yīng)之前首先要知道ehco框架提供了一個Context接口,Context 表示當(dāng)前 HTTP 請求的上下文,我們需要知道的是Context的實現(xiàn)結(jié)構(gòu)體context,context中包含了請求(request)、響應(yīng)(response)以及參數(shù)等結(jié)構(gòu)體,context是一個內(nèi)部結(jié)構(gòu)體,但是對外提供了訪問的方法,我們可以在開發(fā)中使用context提供的方法做很多事情,比如獲取請求路徑、客戶端ip、請求參數(shù)等等。
request是包含了當(dāng)前請求信息的結(jié)構(gòu)體,我們從中可以獲取到前后端約定好的參數(shù)來作出相應(yīng)的業(yè)務(wù)邏輯,這下面開始模擬請求
首先模擬一個添加用戶的POST請求,這里使用了c.bind()這個方法,這個方法起到的作用是把表單參數(shù)或者JSON參數(shù)綁定至對應(yīng)的結(jié)構(gòu)體(這里必須是指針類型),字段需要一一對應(yīng),也就是說前端需要傳遞的表單或JSON參數(shù)名為name、age、gender才能綁定到結(jié)構(gòu)體中。
接下來模擬一個GET請求用來獲取用戶信息
response是包含了返回信息的結(jié)構(gòu)體,echo提供了多種類型的返回結(jié)果
上面編寫了處理請求的handler,這里介紹一下如何把handler注冊到路由中,這里對應(yīng)的就是上面handler。
goget請求可以接受結(jié)構(gòu)體。
接收者是結(jié)構(gòu)體時,可以是結(jié)構(gòu)體類型、結(jié)構(gòu)體指針類型。調(diào)用時不區(qū)分調(diào)用者是結(jié)構(gòu)體還是結(jié)構(gòu)體指針,go語言會自動轉(zhuǎn)化為對應(yīng)的結(jié)構(gòu)體或結(jié)構(gòu)體指針。
在正常的測試中,當(dāng)我們需要進行接口測試時,通常使用接口調(diào)試工具,如postman進行接口測試
目前我在嘗試使用Go語言進行接口測試,使用的庫均為Go自帶的庫。
注:當(dāng)前采用的接口為時事新聞接口,每天可以請求100次,需要的同學(xué),可以自行使用。