Redis--消息队列
Posted fblogs
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Redis--消息队列相关的知识,希望对你有一定的参考价值。
1:18
1.什么是高并发系统的消息队列?
队列:对头+队列容器+对尾
消息队列(MessageQueue MQ):有一个队列容器,生产者(入队列),消费者(出队列)
2.使用消息队列的场景(使用消息队列的原因):
2.1 分布式场景
2.1.1 异步处理
多线程可以节省时间,但是会降低cpu吞吐量
用消息队列也可以减少时间的消耗,当创建失败的时候,可以用消息队列的持久化机制处理
2.1.2 应用解耦
利用消息队列将客户都按和库存系统解耦(消除强依赖)
2.1.3 流量削峰
限制流量(接受客户端请求服务将客户的请求保存到消息队列中,业务服务用自己的最大的吞吐量去消息队列中获取客户请求,如果不能正常取到的,通过消息队列返回给客户端)
2.1.4 异步事务
2.2 日志场景
2.2.1 优化日志传输,提升系统性能
2.3 即时通讯
2.3.1 聊天室
3. 实现消息队列的发手段:
3.1 RabbitMQ
3.2 ActiveMQ
3.3 RocketMQ
3.4 Kafka
3.5 Redis
3.6 ZeroMQ
3.7 阿里MNS
4.应用Redis的消息队列
4.1 redis应用环境:
4.1.1 redis
4.1.2 service.stock(下载serviceStock.redis.dll)
创建客户端:RedisClient client = new RedisClient("localhost:6379");
4.1.3 redis生产者(可以存放2的32次方-1的数据大约是40亿)
//Lpush()从左边插入数据
//Rpush()从右边插入数据
byte[] bytes = System.Text.Encoding.UTF8.GetBytes("tony");
client.Lpush(“tonytest”, bytes );
4.1.4 redis消费者
//队列是左边插入数据,右边取数据;右边插入数据,左边取数据
Byte[] bytes = redisClient.RPop("tonytest");
string value = System.Text.Encoding.UTF8.GetString(bytes);
4.1.5 消息队列的两种模式
4.1.5.1 推模式
这是指消费者在获取消息队列中的数据的时候,当数据没有的时候,会按照制定的时长阻塞线程,在阻塞的过程中如果消息队列中有数据的话会自动推送到消费者。
被动的接收数据
//BRPop()
//BRLop()
//Byte[] bytes = redisClient.BRPopValue("tonytest", 60);//阻塞60s
while(true)
{
Byte[] bytes = redisClient.BRPopValue("tonytest", 10);
if(bytes != null)
{
string value = System.Text.Encoding.UTF8.GetString(bytes);
Console.WriteLine(value);
}
else
{
Console.WriteLine("队列中没有数据");
}
}
4.1.5.2 拉模式
主动的去消息队列中获取数据
//RPOP()
//LPop()
//Byte[] bytes = redisClient.RPop("tonytest");
while(true)
{
Thread.sleep(1000);
Byte[] bytes = redisClient.RPop("tonytest");
if(bytes != null)
{
string value = System.Text.Encoding.UTF8.GetString(bytes);
Console.WriteLine(value);
}
else
{
Console.WriteLine("队列中没有数据");
}
}
总结:消息队列的生产者和消费者是一对一的
4.1.6 redis关闭
redisClient.Dispose()
4.1.6 准备异步处理,应用解
情景:异步实现创建订单,添加积分,发送短信
4.1.6.1在创建订单的服务中
//1.创建订单
//2.创建连接
RedisClient client = new RedisClient("localhost:6379");
//3.生产消息
//3.1积分消息
byte[] bytes = System.Text.Encoding.UTF8.GetBytes("订单号");
client.Lpush(“order_points”, bytes );
//3.2短信消息
byte[] bytes = System.Text.Encoding.UTF8.GetBytes("订单号");
client.Lpush(“order_sms”, bytes );
4.1.6.2在积分服务中:
//1.创建连接
RedisClient client = new RedisClient("localhost:6379");
while(true)
{
Byte[] bytes = redisClient.RPop("order_points");
if(bytes != null)
{
string value = System.Text.Encoding.UTF8.GetString(bytes);
Console.WriteLine($"获取到的积分消息:{value}");
//增加积分
OrderPoint p = new OrderPoint();
p.AddPoint(value);
Console.WriteLine(value);
}
else
{
Console.WriteLine("队列中没有数据");
}
}
4.1.6.3 在短信服务中消费短信消息
//1.创建连接
RedisClient client = new RedisClient("localhost:6379");
while(true)
{
Byte[] bytes = redisClient.RPop("order_sms");
if(bytes != null)
{
string value = System.Text.Encoding.UTF8.GetString(bytes);
Console.WriteLine($"获取到的积分消息:{value}");
//消费短信消息,发送短信
OrderSms p = new OrderSms();
p.SendSms(value);
Console.WriteLine(value);
}
else
{
Console.WriteLine("队列中没有数据");
}
}
以上是关于Redis--消息队列的主要内容,如果未能解决你的问题,请参考以下文章