Step 1: 下載最新的安裝包

$wget https://github.com/downloads/adyliu/jafka/jafka-1.0.tgz 

$tar xzf jafka-1.0.tgz 

$cd jafka-1.0 

可選配置，設定一個環境變數。 $export $JAFKA_HOME=/opt/apps/jafka-1.0 以下假設所有操作目錄都在$JAFKA_HOME下。

執行JafkaMQ很簡單，執行命令： 

$ bin/server.sh conf/server.properties
 

Step 2: 啟動服務端[這一步不寫也能完成，只是多餘的]

這裡啟動一個單程序的服務端，使用預設的配置啟動即可。由於一些路徑使用了相對路徑，因此需要在jafka的主目錄下執行。

$bash bin/server-single.sh config/server-single.properties 

預設情況下，無需任何配置即可執行服務端。這時服務端會將9092埠繫結到所有網絡卡上。

Step 3: 傳送訊息

使用自帶的小命令列就可以傳送簡單的文字訊息。

$bin/producer-console.sh --broker-list 0:localhost:9092 --topic demo 

> Welcome to jafka 

> 中文中國 
 

producer-console.sh有一些引數，這可以通過執行下面的命令得到。 $bin/producer-console.sh

傳送訊息只需要在提示符號'>'輸入文字即可，沒有出錯意味著傳送成功，直接回車或者輸入CTRL+C退出程式。

Step 4: 啟動消費者

現在是時候消費剛才傳送的訊息。

同樣Jafka自帶一個小程式能夠消費簡單的文字訊息。

$bin/simple-consumer-console.sh --topic demo --server jafka://localhost:9092 

[1] 26: Welcome to jafka 

[2] 48: 中文中國 

連線上服務端後，立即就看到有訊息消費了。預設情況下simple-consumer-console.sh輸出訊息的序號（實際上不存在）以及訊息的下一個偏移量(offset)。

解壓縮後只需要執行上面三條命令就可以完成簡單的訊息傳送和接受演示。這就是一個簡單的訊息系統。

Step 5: 手動編碼

我們希望利用提供的API手動編碼能夠傳送和接受一些訊息。

訊息傳送者

首先寫一個簡單的訊息傳送者。