中文亚洲精品无码_熟女乱子伦免费_人人超碰人人爱国产_亚洲熟妇女综合网

當(dāng)前位置: 首頁 > news >正文

正規(guī)的培訓(xùn)行業(yè)網(wǎng)站開發(fā)seo關(guān)鍵詞如何布局

正規(guī)的培訓(xùn)行業(yè)網(wǎng)站開發(fā),seo關(guān)鍵詞如何布局,網(wǎng)站開發(fā)用qq登錄,WordPress贊賞代碼本人是C#出身的程序員,c#很簡單就能實(shí)現(xiàn),有需要的可以加我私聊。但是就目前流行的開發(fā)語言,尤其是面向web方向應(yīng)用的,我感覺就是Nodejs最簡單了。下面介紹: 本文將會(huì)介紹在windows環(huán)境下啟動(dòng)Kafka,并通過n…

本人是C#出身的程序員,c#很簡單就能實(shí)現(xiàn),有需要的可以加我私聊。但是就目前流行的開發(fā)語言,尤其是面向web方向應(yīng)用的,我感覺就是Nodejs最簡單了。下面介紹:

本文將會(huì)介紹在windows環(huán)境下啟動(dòng)Kafka,并通過nodejs作為客戶端,生產(chǎn)并消費(fèi)消息。

步驟一,Kafka需要java運(yùn)行時(shí),先安裝配置java環(huán)境。通過在命令行中輸入java -version確認(rèn)java是否成功安裝(可能需要查看windows的環(huán)境變量中是否有java)。

步驟二,Kafka官網(wǎng)下載最新版本的壓縮包(.tgz格式),并解壓。分別在兩個(gè)命令行里面啟動(dòng)zookeeper、kafka(解壓縮路徑下)

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

bin\windows\kafka-server-start.bat config\server.properties

說明一下zookeeper和kafka的關(guān)系:zookeeper是集群的調(diào)度者,kafka才是消息隊(duì)列。 zookeeper的默認(rèn)端口:2181,kafka的默認(rèn)端口:9092
相關(guān)配置可以在config文件下的server.properties和zookeeper.properties中找到

用記事本打開就可以編輯

建立data,logs,kafka-logs目錄,用于日志,備用。

消費(fèi)者客戶端需要的group.id可以在config->consumer.properties中找到。

步驟三,使用DOS的CMD管理員命令行方式測(cè)試生產(chǎn)者生產(chǎn)、消費(fèi)者消費(fèi)。
//創(chuàng)建一個(gè)topic:test
bin\windows\kafka-topics.bat --create --zookeeper?localhost:2181 --replication-factor 1 --partitions 1 --topic test

//查看topic
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

//創(chuàng)建生產(chǎn)者主題mytest
bin\windows\kafka-console-producer.bat --broker-list?localhost:9092 --topic test-nodetopic

//創(chuàng)建消費(fèi)者消費(fèi)mytest
bin\windows\kafka-console-consumer.bat?--bootstrap-server?localhost:9092 --topic test-nodetopic --from-beginning

步驟四,生產(chǎn)者發(fā)送消息
在生產(chǎn)者窗口,隨意輸入一條消息,可以在消費(fèi)者窗口看到該消息。

最后,使用nodejs訪問kafka? 首先安裝kafkajs

初始化項(xiàng)目

npm init -y

沒有安裝kafkajs的,在這里可以安裝,互聯(lián)網(wǎng)在線安裝。
npm install kafkajs

新建demo2023.js,輸入以下代碼

const { Kafka } = require('kafkajs')

const kafka = new Kafka({

??clientId: 'my-app',

??brokers: ['localhost:9092']

})

const producer = kafka.producer()

const consumer = kafka.consumer({ groupId: 'test-consumer-group' })

const run = async () => {

??// Producing

??await producer.connect()

??await producer.send({

????topic: 'test-nodetopic',

????messages: [

??????{ value: ' Hello KafkaJS user,I?am producer ! ' },

????],

??})

??// Consuming

??await consumer.connect()

??await consumer.subscribe({ topic: 'test-nodetopic', fromBeginning: true })

??await consumer.run({

????eachMessage: async ({ topic, partition, message }) => {

??????console.log({

????????partition,

????????offset: message.offset,

????????value: message.value.toString(),

??????})

????},

??})

}

run().catch(console.error)

最后執(zhí)行命令
node demo2023.js

http://www.risenshineclean.com/news/54361.html

相關(guān)文章:

  • 在中國做博彩網(wǎng)站違法嗎seo網(wǎng)站優(yōu)化服務(wù)商
  • wap asp網(wǎng)站模板下載淘寶怎樣優(yōu)化關(guān)鍵詞
  • 個(gè)人網(wǎng)站建立教程網(wǎng)站建設(shè)黃頁免費(fèi)觀看
  • 網(wǎng)站建設(shè)最好的公司網(wǎng)站域名費(fèi)一年多少錢
  • 廣州網(wǎng)站優(yōu)化關(guān)鍵詞排名最新疫情新聞100字
  • 長治制作公司網(wǎng)站的公司百度免費(fèi)推廣怎么操作
  • 可以做來電名片的網(wǎng)站seo高端培訓(xùn)
  • 怎么做網(wǎng)站首頁圖片不會(huì)失真云南今日頭條新聞
  • 內(nèi)容管理系統(tǒng)開源佛山網(wǎng)站建設(shè)十年樂云seo
  • 一個(gè)好的網(wǎng)站應(yīng)該具有什么西安百度推廣競價(jià)托管
  • 舉例說明網(wǎng)絡(luò)營銷的概念小紅書seo排名帝搜軟件
  • 網(wǎng)站建設(shè)商務(wù)的術(shù)語怎么注冊(cè)網(wǎng)站平臺(tái)
  • wordpress安裝顯示404寧波優(yōu)化網(wǎng)站排名軟件
  • 可信賴的深圳網(wǎng)站建設(shè)百度seo霸屏軟件
  • 門戶網(wǎng)站建設(shè)方案文檔如何自己建立一個(gè)網(wǎng)站
  • 京東商城企業(yè)網(wǎng)站建設(shè)分析收錄網(wǎng)
  • 網(wǎng)站內(nèi)的搜索怎么做的市場調(diào)研問卷
  • 網(wǎng)站標(biāo)題寫什么作用seo顧問服務(wù) 樂云踐新專家
  • 做了個(gè)網(wǎng)站 怎么做seo百度網(wǎng)盤網(wǎng)頁版登錄首頁
  • 空間網(wǎng)站鏈接怎么做淘寶店鋪買賣交易平臺(tái)
  • seo優(yōu)化方案書鄭州seo優(yōu)化推廣
  • 做網(wǎng)站-信科網(wǎng)絡(luò)軟文推廣網(wǎng)
  • 酒店網(wǎng)站素材百度電腦版網(wǎng)頁版入口
  • 建網(wǎng)站哪個(gè)好 優(yōu)幫云優(yōu)化公司結(jié)構(gòu)
  • 網(wǎng)上做網(wǎng)站 干對(duì)縫兒生意廣州seo公司品牌
  • 網(wǎng)站開發(fā)編程的工作方法可以看任何網(wǎng)站的瀏覽器
  • 做網(wǎng)站的網(wǎng)站怎么在網(wǎng)上做廣告宣傳
  • 甘肅農(nóng)村網(wǎng)站建設(shè)汽車seo是什么意思
  • 佛山網(wǎng)絡(luò)公司網(wǎng)站建設(shè)凡科建站登錄官網(wǎng)
  • 建設(shè)網(wǎng)站需要多久qq營銷軟件