Redis实现简单消息队列


    public static void main(String[] args) {
        Jedis jedis = new Jedis("10.0.130.103",6379);
        jedis.lpush("task-queue", "123");//装入队列
        jedis.lpush("task-queue", "456");//装入队列

        //获取队列消息
        System.out.println(jedis.rpoplpush("task-queue", "tmp-queue"));
        //获取队列消息
        System.out.println(jedis.rpoplpush("task-queue", "tmp-queue"));
            // 将本次任务从暂存队列"tmp-queue"中清除
        jedis.rpop("tmp-queue");
        System.out.println("处理成功,被清除");
    }

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM