read change log and readme.md

wu_xinjun

2022-03-07 e1f883778b1a51241a018a7f0c5918f91026aae7

 src/engine/MessageThreads.py

@@ -13,13 +13,13 @@



class Message(object):
    def __init__(self,sender_id,sender_key,body,routing_key):
        self.sender_id = sender_id
        self.sender_key = sender_key
        self.body = body
        self.routing_key = routing_key

# class Message(object):
#     def __init__(self,sender_id,sender_key,body,routing_key):
#         self.sender_id = sender_id
#         self.sender_key = sender_key
#         self.body = body
#         self.routing_key = routing_key
# 根据新的数据结构改写run
class senderThread(threading.Thread):
    def __init__(self, MQparameters,input_msg_queue,sender_id,exchangeName,exchangeType):
        super(senderThread,self).__init__()
@@ -48,7 +48,6 @@
                        data= self.queue.get()
                        if isinstance(data, pb.CapturedData):
                            msg = pb.DataMessage()
                            msg.
                        else:
                            body = msg.body
                            routing_key = msg.routing_key
@@ -64,6 +63,7 @@
                    print(e)
                    break

# 根据新的数据结构改写run
class receiverThread(threading.Thread):
    def __init__(self, MQparameters,received_msg_queue,output_response_queue,exchangeName,exchangeType,receiver_id):
        super(receiverThread,self).__init__()
@@ -103,6 +103,7 @@
        raise NotImplementedError(
            "Need to implement the callback function")

# 根据rabbitmq重新设置消息参数
class device_state_senderThread(senderThread):
    def __init__(self, 
        MQparameters,
@@ -116,7 +117,7 @@
                    "device_state",
                    "fanout"
                   )

# 根据rabbitmq重新设置消息参数
class device_state_receiverThread(receiverThread):
    def __init__(self, 
        MQparameters,
@@ -135,7 +136,7 @@
        response_tag = f"{time.asctime()} received: {body}."
        print(response_tag)
        ch.basic_ack(delivery_tag = method.delivery_tag)

# 根据rabbitmq重新设置消息参数
class alarm_state_senderThread(senderThread):
    def __init__(self, 
        MQparameters,
@@ -149,7 +150,7 @@
                    "alarm_state",
                    "fanout"
                   )
    
    # 根据rabbitmq重新设置消息参数
class alarm_state_receiverThread(receiverThread):
    def __init__(self, 
        MQparameters,
@@ -168,7 +169,7 @@
        response_tag = f"{time.asctime()} received: {body}."
        print(response_tag)
        ch.basic_ack(delivery_tag = method.delivery_tag)

# 根据rabbitmq重新设置消息参数
class command_request_senderThread(senderThread):
    def __init__(self, 
        MQparameters,
@@ -182,7 +183,7 @@
                    "command_request",
                    "topic"
                   )

# 根据rabbitmq重新设置消息参数
class command_request_receiverThread(receiverThread):
    def __init__(self, 
        MQparameters,
@@ -206,7 +207,7 @@
        print(response_tag)
        self.response_queue.put(Message(self.receiver_id,self.receiver_id,response_tag,''))
        ch.basic_ack(delivery_tag = method.delivery_tag)

# 根据rabbitmq重新设置消息参数
class command_response_senderThread(senderThread):
    def __init__(self, 
        MQparameters,
@@ -220,7 +221,7 @@
                    "command_response",
                    "fanout"
                   )

# 根据rabbitmq重新设置消息参数
class command_response_receiverThread(receiverThread):
    def __init__(self, 
        MQparameters,
@@ -240,6 +241,7 @@
        ch.basic_ack(delivery_tag = method.delivery_tag)


# TODO
class image_data_senderThread(senderThread):
    def __init__(self, 
        MQparameters,
@@ -254,6 +256,9 @@
                    "fanout"
                   )

class image_data_receiverThread(receiverThread):
    pass