基于Redis的阻塞队列实现（基于Redis阻塞队列）

通常情况下，队列是一种常用的数据结构，它可以实现先进先出(FIFO)的数据存储和访问策略。 Redis是一个开源的内存键值数据库，可以实现非常高效的读写性能。因此，将它用于实现阻塞队列是很有意义的。

成都创新互联公司专注于企业成都全网营销推广、网站重做改版、潍坊网站定制设计、自适应品牌网站建设、HTML5、商城网站建设、集团公司官网建设、成都外贸网站建设、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为潍坊等各大城市提供网站开发制作服务。

我们需要使用Redis的list结构来实现队列。可以使用 lpush 和 rpop 命令将元素插入队列和移出队列。下面是具体的实现代码：

// 向队列中添加元素

// 添加的元素将放置在队列的左侧

// element: 想要添加的元素

// queueName: 队列的名字

public void lpush(string element, String queueName) {

redisTemplate.boundListOps(queueName).leftPush(element);

}

// 从队列中移出元素

// 被移出的元素将在队列的右侧

// queueName: 队列的名字

public String rpop(String queueName) {

return (String) redisTemplate.boundListOps(queueName).rightPop();

}

另一个很重要的点是阻塞队列的实现，这里使用Redis的BRPOPLPUSH 命令实现，该命令将阻塞队列的取出和插入操作合并在一起，如果队列中没有元素，则线程会阻塞，直到队列中有元素。下面是具体实现代码：

// 从一个队列中取出一个元素，并插入另一个队列中

// element: 将要添加到队列中的元素

// fromQueueName: 源队列名称

// toQueueName: 目标队列名称

public void brpoplpush(String element, String fromQueueName, String toQueueName) {

redisTemplate.execute(new RedisCallback() {

@Override

public Void doInRedis(RedisConnection redisConnection) throws DataAccessException {

redisConnection.rPopLPush(fromQueueName.getBytes(), toQueueName.getBytes());

return null;

}

});

}

基于Redis的阻塞队列的实现非常简单高效，此外，它还可以满足大多数常见队列需求，是一种优秀的解决方案。

香港服务器选创新互联，2H2G首月10元开通。
创新互联（www.cdcxhl.com）互联网服务提供商,拥有超过10年的服务器租用、服务器托管、云服务器、虚拟主机、网站系统开发经验。专业提供云主机、虚拟主机、域名注册、VPS主机、云服务器、香港云服务器、免备案服务器等。

网站标题：基于Redis的阻塞队列实现（基于Redis阻塞队列）
本文来源：http://www.shufengxianlan.com/qtweb/news18/48468.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联