【飛凌嵌入式 OK3399-C 開發(fā)板試用體驗】(安裝RabbitMQ消息隊列服務(wù)】
原創(chuàng)
fcb5511
2020-09-30 13:29:00
RK3399
RK3399開發(fā)板
3399開發(fā)板
fcb5511
2020-09-30 13:29:00
RK3399
RK3399開發(fā)板
3399開發(fā)板
作者：fcb5511
提供兩種消息隊列服務(wù)安裝方式：
二、通過官方源碼以及binary包安裝
apt命令安裝方式獲取的erlang和rabbitmqserver版本一般比較低，erlang版本和rabbitmqserver版本如果匹配不好，在高并發(fā)，多連接的情況下，cpu以及內(nèi)存消耗較大（不知道現(xiàn)在最新安裝版本有沒有這個問題，有興趣的可以試一試），優(yōu)點是安裝和使用都很方便，下面是安裝和配置的各個步驟：
安裝RabbitMQServer需要的語言環(huán)境 erlang，執(zhí)行如下命令
1、apt-get installerlang-nox # 安裝erlang
2、erl # 查看relang語言版本，成功執(zhí)行則說明relang安裝成功
安裝RabbitMQServer消息隊列服務(wù)
apt-get install rabbitmq-server #安裝成功自動啟動
查看RabbitMQServer安裝狀態(tài)
systemctl status rabbitmq-server
啟用管理插件（可通過網(wǎng)頁登錄）
rabbitmq-plugins enable rabbitmq_management
在rk3399瀏覽器中輸入localhost:15672，登陸用戶名和密碼分別為”guest”、”guest”。
如果要實現(xiàn)局域網(wǎng)的其它計算機(jī)可訪問rk3399的MQ服務(wù)，需要給MQ服務(wù)添加管理員以及管理員權(quán)限。
新建admin用戶并賦予權(quán)限
1、rabbitmqctl add_useradmin admin
2、rabbitmqctl set_user_tagsadmin administrator
3、rabbitmqctl set_permissions-p / admin '.*' '.*' '.*'
局域網(wǎng)內(nèi)計算機(jī)瀏覽器輸入192.168.1.109:15672，用戶名和密碼分別為”admin”、”admin”
源碼編譯和binary安裝需要從erlang官網(wǎng)下載源碼自行編譯為arm64平臺的安裝包，rabbitmqserver可直接從官網(wǎng)下載binaray包，手動添加環(huán)境變量。這種安裝方式優(yōu)點是可以根據(jù)喜好安裝最新發(fā)布的版本。
從github獲取erlang源碼包
wget https://www.erlang.org/downloads/otp_src_22.1.tar.gz
解壓源碼包tar -zvxf otp_src_22.1.tar.gz #編譯&安裝 編譯前先安裝ssl相關(guān)的依賴庫，否則ok3399在啟動mq服務(wù)時會報錯apt-get install libssl-dev 接下來安裝erlangcd otp_src_22.1 ./otp_build autoconf./configure && make && sudo make install安裝不指定路徑會默認(rèn)安裝到/usr/local/lib/erlang/目錄下
rabbitmqserver二進(jìn)制包安裝
從github獲取安裝包
wget
https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.0/rabbitmq-server-generic-unix-3.8.0.tar.xz
解壓
tar -xvf rabbitmq-server-generic-unix-3.8.0.tar.xz
將解壓后的包放到/usr/local目錄
配置環(huán)境變量
vim /etc/profile 在后面添加如下命令：export PATH=$PATH:/usr/local/lib/erlang/bin:/usr/local/rabbitmq_server-3.8.0/sbin讓新加的環(huán)境變量有效source /etc/profile
用erl查看版本號
啟動rabbitmq-server
rabbitmq-plugins enable rabbitmq_management//允許網(wǎng)頁管理rabbitmq-server 或 rabbitmq-server -detached(后臺運(yùn)行)
新建admin用戶并賦予權(quán)限
1、rabbitmqctl add_useradmin admin
2、rabbitmqctl set_user_tagsadmin administrator
3、rabbitmqctl set_permissions-p / admin '.*' '.*' '.*'
至此，兩種方式安裝Rabbitmq服務(wù)完成。接下來用python來驗證一下功能，python實現(xiàn)一個消費者，一個生產(chǎn)者，生產(chǎn)間隔1秒鐘發(fā)送一幀數(shù)據(jù)，消費者從隊列取數(shù)據(jù)并打印。python使用rabbitmq需要引用pika庫，pika庫是獨立于python的第三方庫，需要使用pip命令安裝。
amqproducer.py程序：
import pika
import threading
import time
import signal
import os
class Producer(object):
def __init__(self, host='127.0.0.1', port=5672,
user='admin', passwd='admin',
exchange='test_exchange', routing_key='test_key',
exchange_type= 'fanout', exhcange_durable=False, exchange_autodelete=True
):
self.host=host
self.port=port
self.user=user
self.passwd=passwd
self.exchange=exchange
self.routing_key=routing_key
self.exchange_type=exchange_type
self.exhcange_durable=exhcange_durable
self.exchange_autodelete=exchange_autodelete
self.connection=None
self.channel=None
def CreateConnection(self):
try:
self.credentials=pika.PlainCredentials(self.user, self.passwd)
self.connection = pika.BlockingConnection(pika.ConnectionParameters(host = self.host, port = self.port, virtual_host = '/', credentials=self.credentials))
self.channel = self.connection.channel()
self.channel.exchange_declare(exchange_type=self.exchange_type, exchange = self.exchange, durable = self.exhcange_durable, auto_delete=self.exchange_autodelete)
except Exception as e:
print("occurring an exception when the producer executing the function 'CreateConnection()':", e)
def PublisMessage(self, Message):
try:
self.channel.basic_publish(exchange=self.exchange, routing_key=self.routing_key, properties=pika.BasicProperties(delivery_mode = 2), body=Message)
except Exception as e:
print("An exception occurred when publishing message:", e)
amqconsumer.py程序:
import pika
import time
class Consumer(object):
def __init__(self, host='127.0.0.1', port=5672,
user='admin', passwd='admin',
queue='test_queue', exchange='test_exchange', routing_key='test_key',
queue_exclusive=False, queue_durable=False, queue_autodelete=True,
exchange_type= 'fanout', exhcange_durable=False, exchange_autodelete=True
):
self.host=host
self.port=port
self.user=user
self.passwd=passwd
self.queue=queue
self.exchange=exchange
self.routing_key=routing_key
self.queue_exclusive=queue_exclusive
self.queue_durable=queue_durable
self.queue_autodelete=queue_autodelete
self.exchange_type=exchange_type
self.exhcange_durable=exhcange_durable
self.exchange_autodelete=exchange_autodelete
self.connection=None
self.channel=None
def CreateConnection(self):
try:
self.credentials=pika.PlainCredentials(self.user, self.passwd)
self.connection = pika.BlockingConnection(pika.ConnectionParameters(host = self.host, port = self.port, virtual_host = '/', credentials=self.credentials))
self.channel = self.connection.channel()
self.channel.queue_declare(queue=self.queue, durable=self.queue_durable, exclusive=self.queue_exclusive, auto_delete=self.queue_autodelete)
self.channel.exchange_declare(exchange_type=self.exchange_type, exchange = self.exchange, durable = self.exhcange_durable, auto_delete=self.exchange_autodelete)
self.channel.queue_bind(queue = self.queue, exchange = self.exchange, routing_key = self.routing_key)
self.channel.basic_consume(on_message_callback = self.on_response, auto_ack=True, queue=self.queue)
except Exception as e:
print("occurring an exception when the consumer RecvData:", e)
def on_response(self, ch, method, props, body):
#print(" [%s] Received %r" % (time.time(), body))
print(time.strftime('%H:%M:%S',time.localtime(time.time()))+': Get Message from '+self.host + ':'+body.decode())
def ProcessConsumeEventBlock(self):
try:
self.channel.start_consuming()
except Exception as e:
print('An exception occurred when executing consuming, the exception is:',e)
def ProcessConsumeEventNoneBlock(self):
try:
self.connection.process_data_events()
except Exception as e:
print('An exception occurred when executing consuming, the exception is:',e)
main.py程序:
import pika
import time
import threading
from amqconsumer import Consumer
from amqproducer import Producer
class ManageMent:
def __init__(self):
self.producer = Producer(host='localhost',user='guest',passwd='guest')
self.consumer = Consumer(host='localhost',user='guest',passwd='guest')
def CreateSever(self):
self.consumer.CreateConnection()
self.producer.CreateConnection()
def ProducerRun(self):
while True:
self.producer.PublisMessage('this message is used for testing RabbitMQ')
time.sleep(0.3)
def ConsumerRun(self):
self.consumer.ProcessConsumeEventBlock()
def Run1(self):
while True:
self.producer.PublisMessage('this message is used for test RabbitMQ')
self.consumer.ProcessConsumeEventNoneBlock()
time.sleep(1)
def Run(self):
self.Consumer_thread=threading.Thread(target=self.ConsumerRun)
self.Producer_thread=threading.Thread(target=self.ProducerRun)
self.Consumer_thread.start()
self.Producer_thread.start()
if __name__ == '__main__':
manage=ManageMent()
manage.CreateSever()
manage.Run()
最終運(yùn)行效果如圖
此貼為基礎(chǔ)功能，下次將mq數(shù)據(jù)與qt界面結(jié)合，實現(xiàn)動態(tài)的界面。
相關(guān)產(chǎn)品 >
-
FET3399-C核心板
飛凌RK3399安卓高性能核心板采用 采用六核Rockchip RK3399芯片，雙Cortex-A72大核+四Cortex-A53小核結(jié)構(gòu)，對整數(shù)、浮點、內(nèi)存等作了大幅優(yōu)化，在整體性能、功耗及核心面積三個方面提升。以下將對瑞芯微芯片RK3399參數(shù),RK3399核心板方案及其性能做具體介紹。如您對飛凌RK3399系列核心板有興趣，歡迎咨詢了解。
了解詳情
-
OK3399-C開發(fā)板
飛凌嵌入式RK3399安卓開發(fā)板主芯片采用高性能六核CPU Rockchip RK3399,GPU采用Mail-T860四核 GPU，RK3399作為目RK產(chǎn)品線中低功耗、高性能的代表，可滿足人臉識別設(shè)備、機(jī)器人、無人機(jī)、IoT物聯(lián)網(wǎng)領(lǐng)域應(yīng)用。飛凌RK3399開發(fā)板在整體性能、功耗及核心面積做了大幅度優(yōu)化，更加滿足工業(yè)設(shè)計需求。飛凌RK3399開發(fā)板為進(jìn)一步減少用戶二次開發(fā)難度，開放了底板原理圖，并提供了RK3399用戶手冊、芯片手冊，加上優(yōu)質(zhì)的技術(shù)服務(wù)，讓您的方案從構(gòu)思到上市時間縮短。
了解詳情
換一批
