安裝kafka參見我的教程
/**
* 生產者
* author:chen
* date:2020.11.12
*///引入kafka-node
const kafka =
require
('kafka-node');
//建立連線
letgeneratekafkaconnection
=function
(host));
resolve
(client)
}catch(e
)})}
//建立生產者
letgenerateproducer
=function
(client));
producer.on(
'error'
,function
(err));
producer.
sendmessage
=(payloads)
=>)}
))}}
catch(e
)})}
module.exports=
//測試函式
async
function
main()
// ];
// await producer.sendmessage(payloads)
// console.log('成功傳送第',i,'條訊息')
// }
//定時生成訊息
let deal_id=
1000000001
let price=
14201
let index=
setinterval
(async()
=>
else
randomprice=randomprice.
tofixed(2
)let amount=math.
floor
(random*
100)
let payloads =
;await producer.
sendmessage
(payloads)
console.
log(
'生產者成功傳送訊息 '
,json
.stringify
(payloads))}
,1500)}
main
()
/**
* 消費者
* 執行**：node consumer.js
* author:chen
* date:2020.11.12
*///引入kafka-node
const kafka =
require
('kafka-node'
)//建立kafka連線
letgeneratekafkaconnection
=function
(host)
)resolve
(client)
}catch(e
)}))
}//建立消費者
letgeneratecomsumer
=function
(client,topic,messagehandler))if
(messagehandler instanceof
function
)else)}
resolve
(comsumer)
}catch(e
)}))
}module.exports=
//測試函式
async
function
main()
]//建立消費者，(messagehandler不寫預設列印訊息)
let comsumer=
await
generatecomsumer
(client,topic,
(message)
=>)}
main
()
壓力測試工具
webbench最多可以模擬3萬個併發連線去測試 的負載能力，比apache自帶的ab壓力測試工具好，安裝使用也特別方便。1 適用系統 linux 2 編譯安裝 引用 wget tar zxvf webbench 1.5.tar.gz cd webbench 1.5 make make instal...
http load測試工具
基於linux平台的一種效能測工具。以並行復用的方式執行，用以測試web伺服器的吞吐量與負載，測試web頁面的效能。優點1.基於命令列，簡單 易於上手 2.小巧輕便，解壓縮後不到100k 3.開源，免費 缺點1.僅適用於web頁面的效能測試，不適用於訪問資料庫 2.測試結果分析有限 3.平台依賴li...
安全測試工具
webscan 白盒測試工具 sofa 專案 功能 sofa 專案的 安全測試 使用場景 開發工程師在交付測試之前，需要使用此工具進行 安全測試，生成測試報告 2.hatrix 黑盒測試工具 半自動化測試 功能 web 安全黑盒測試，可以進行半自動化的測試 使用場景 測試工程師在測試階段進行安全測試...