基于python实现操作redis及消息队列
操作redis
importredis
redisPool=redis.ConnectionPool(host='192.168.100.50',port=6379,db=8)
redis=redis.Redis(connection_pool=redisPool)
redis.set('key','values')
redis.get('com')
redis.append('keys','values')
redis.delete('keys')
print(redis.getset('name','Mike'))#赋值name为Mike并返回上一次的value
print(redis.mget(['name','age']))#输出name键和age键的value
print(redis.setnx('newname','james'))#如果键值不存在，则赋值
print(redis.mset({'name1':'smith','name2':'curry'}))#批量赋值
print(redis.msetnx({'name3':'ltf','name4':'lsq'}))#不存在才批量赋值
print(redis.incr('age',1))#age对应的value加1
print(redis.decr('age',5))#age对应的value减5
print(redis.append('name4','isasb'))#在name4的value后追加isasb返回字符串长度
print(redis.substr('name',1,4))#截取键name
print(redis.sadd('tags','Book','Tea','Coffee'))#返回集合长度3
print(redis.srem('tags','Book'))#返回删除的数据个数
print(redis.spop('tags'))#随机删除并返回该元素
print(redis.smove('tags','tags1','Coffee'))
print(redis.scard('tags'))#获取tags集合的元素个数
print(redis.sismember('tags','Book'))#判断Book是否在tags的集合中
print(redis.sinter('tags','tags1'))#返回集合tags和集合tags1的交集
print(redis.sunion('tags','tags1'))#返回集合tags和集合tags1的并集
print(redis.sdiff('tags','tags1'))#返回集合tags和集合tags1的差集
print(redis.smembers('tags'))#返回集合tags的所有元素
print(redis.hset('price','cake',5))#向键名为price的散列表添加映射关系，返回1即添加的映射个数
print(redis.hsetnx('price','book',6))#向键名为price的散列表添加映射关系，返回1即添加的映射个数
print(redis.hget('price','cake'))#获取键名为cake的值返回5
print(redis.hmset('price',{'banana':2,'apple':3,'pear':6,'orange':7}))#批量添加映射
print(redis.hmget('price',['apple','orange']))#查询apple和orange的值输出b'3',b'7'
print(redis.hincrby('price','apple',3))#apple映射加3为6
print(redis.hexists('price','banana'))#在price中banana是否存在返回True
print(redis.hdel('price','banana'))#从price中删除banana返回1
print(redis.hlen('price'))#输出price的长度
print(redis.hkeys('price'))#输出所有的映射键名
print(redis.hvals('price'))#输出所有的映射键值
print(redis.hgetall('price'))#输出所有的映射键对
print(redis.rpush('list',1,2,3))#向键名为list的列表尾部添加1,2,3返回长度
print(redis.lpush('list',0))#向键名为list的列表头部添加0返回长度
print(redis.llen('list'))#返回列表的长度
print(redis.lrange('list',1,3))#返回起始索引为1终止索引为3的索引范围对应的列表
print(redis.lindex('list',1))#返回索引为1的元素-value
print(redis.lset('list',1,5))#将list的列表索引为1的重新赋值为5
print(redis.lpop('list'))#删除list第一个元素
print(redis.rpop('list'))#删除list最后一个元素
print(redis.blpop('list'))#删除list第一个元素
print(redis.brpop('list'))#删除最后一个元素
print(redis.rpoplpush('list','list1'))#删除list的尾元素并将其添加到list1的头部
消息队列使用例子
importredis
importjson
redisPool=redis.ConnectionPool(host='192.168.100.50',port=6379,db=8)
client=redis.Redis(connection_pool=redisPool)
#顺序插入五条数据到redis队列，sort参数是用来验证弹出的顺序
whileTrue:
num=0
foriinrange(0,100):
num=num+1
#paramsinfo
params_dict={"name":f"test{num}","sort":num}
client.rpush("test",json.dumps(params_dict))
#查看目标队列数据
result=client.lrange("test",0,100)
print(result)
importtime
time.sleep(10)
importredis
importtime
importmultiprocessing
importtime
importos
importrandom
redisPool=redis.ConnectionPool(host='192.168.100.50',port=6379,db=8)
client=redis.Redis(connection_pool=redisPool)
deftest1(msg):
t_start=time.time()
print("%s开始执行，进程号为%d"%(msg,os.getpid()))
time.sleep(random.random()*2)
t_stop=time.time()
print("%s执行完成，耗时%.2f"%(msg,t_stop-t_start))
whileTrue:
number=client.llen('test')
print("现在的队列任务条数是",number)
p=100
ifnumber>p-1:
print("-----start-----")
a=[]
foriinrange(p):
result=client.lpop("test")
a.append(result)
print("每10条读取一次",a)
po=multiprocessing.Pool(p)
foriinrange(0,p):
#Pool().apply_async(要调用的目标,(传递给目标的参数元祖,))
#每次循环将会用空闲出来的子进程去调用目标
po.apply_async(test1,(a[i],))
po.close()#关闭进程池，关闭后po不再接收新的请求
po.join()#等待po中所有子进程执行完成，必须放在close语句之后
print("-----end-----")
time.sleep(2)
elifnumber0:
print("-----start-----")
a=[]
foriinrange(number):
a=[]
result=client.lpop("test")
a.append(result)
print("小于10条的读取一次",a)
po=multiprocessing.Pool(number)
foriina:
#Pool().apply_async(要调用的目标,(传递给目标的参数元祖,))
#每次循环将会用空闲出来的子进程去调用目标
po.apply_async(test1,(a,))
po.close()#关闭进程池，关闭后po不再接收新的请求
po.join()#等待po中所有子进程执行完成，必须放在close语句之后
print("-----end-----")
time.sleep(2)
elifnumber==0:
print("没有任务需要处理")
time.sleep(2)
else:
time.sleep(2)
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。