Python的消息队列包SnakeMQ使用初探(2)-木庄网络博客

读取本地一个1M的文件，然后发送给listener，然后listener发回一个hello的信息。

from netComm.snakemq import snakemqConnector

import time

import sys

import os

def received(ident, data):

     print(data)

 

if __name__ == "__main__":

     bob = snakemqConnector.SnakemqConnector('bob',"10.16.5.45",4002,True)

     bob.on_recv.add(received)

     bob.start()

     try:

         with open("testfile.txt",encoding='utf-8') as f:

              txt = f.read()

              for i in range(100):

                  bob.sendMsg("niess",txt.encode('utf-8'))

                  time.sleep(0.1)

     except Exception as e:

         print(e)

     time.sleep(5)

     bob.terminate()   

 

测试代码listener（testSnakeListener.py）：

from netComm.snakemq import snakemqListener

import time

 

def received(ident, data):

     filename = "log/recFile{0}.txt".format(time.strftime('%S',time.localtime()))

     file = open(filename,'w')

     file.writelines(data)

     file.close()

 

if __name__ == "__main__":

     niess = snakemqListener.SnakemqListener("niess","10.16.5.45",4002)

     niess.on_recv.add(received)

     niess.start()

     print("niess start...")

     time.sleep(60)

     niess.terminate()  

     print("niess end...")

标签：SQLite

返回前面的内容

android内置Sqlite的使用详细介绍

android开发之contentprovider的使用详解

Sqlite与mysql区别及优缺点介绍

Sqlite3 api 编程手册

关于centos 7下Sqlite3找不到的问题解决

Sqlite教程（五）：索引和数据分析清理

如何通过android stduio来编写一个完整的天气预报app

c#中嵌入Sqlite数据库的简单方法

Sqlite之c#版 system.data.Sqlite使用方法

更多相关阅读请进入《Sqlite》频道 >>