Recently, I'm going to do something like chat software. After a lot of testing, I've done this thing.
Performance is 13 times faster than py direct circular transmission
pip install redisGroupMsg
push msg
from redisGroupMsg import redisMessage
r = redisMessage()
if __name__ == '__main__':
for a in range(1,10):
e = "id:"+str(a)
# add queue of group
# r.addGroup("test",e)
# send message in group queue
# r.sendGroup("test",e)
# remove queue on group
r.removeGroup("test",e)
pop msg
from redisGroupMsg import redisMessage
r = redisMessage()
if __name__ == '__main__':
conn = r.conn
msg = conn.rpop("id:1")
print(msg)