2020-06-24

SpringBoot——redis消息队列list（二十二）

前言

redis的lpush和rpop很适合作为一种轻量级的消息队列实现，这与redis的list列表有关，详情见

生产者

@Service
public class RedisProducerImpl implements RedisProducer {

    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public JsonResponse produce(String key, String msg) {
        Map<String, String> map = Maps.newHashMap();
        map.put("fileId", msg);
        redisTemplate.opsForList().leftPush(key, map);
        return JsonResponse.ok();
    }
}

消费者

@Service
public class RedisConsumer {

    private void processOrderImport() {
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.execute(() -> {
            while (true) {
                Object object = redisTemplate.opsForList().rightPop(RedisKey.orderImportKey, 1, TimeUnit.SECONDS);
                if (null == object) {
                    continue;
                }
                String msg = JSON.toJSONString(object);
                executorService.execute(*******);
            }
        });
    }
}

本文标题:SpringBoot——redis消息队列list（二十二）

文章作者:南有乔木

发布时间:2020-06-24, 14:48:01

最后更新:2020-06-29, 15:06:53

原始链接:http://yoursite.com/2020/06/24/SpringBoot%E2%80%94%E2%80%94redis%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97list%EF%BC%88%E4%BA%8C%E5%8D%81%E4%BA%8C%EF%BC%89/

许可协议: "署名-非商用-相同方式共享 4.0" 转载请保留原文链接及作者。