如何使用Jedis操作Redis消息队列-阿里云开发者社区

开发者社区> 青夜之衫> 正文

如何使用Jedis操作Redis消息队列

简介:
+关注继续查看

资源链接

Jedis的jar包
Commons-io的jar包

使用方法

代码样例如下,使用前,注意打开redis的server程序。

代码样例

package RedisExample;

import redis.clients.jedis.Jedis;

public class TestRedis {
    public static void main(String[] args) {
        Jedis redis = new  Jedis("localhost");  
//      SimpleExample(redis);
        
//      ListExample(redis,20000);
        
        PublishExample(redis,20000);
    }
    //简单添加信息
    public static void SimpleExample(Jedis redis){
        redis.set("key1", "I am value 1");  
        String ss = redis.get("key1");  
        System.out.println(ss);
    }
    //队列添加信息
    public static void ListExample(Jedis redis,int number){
        String messageStr = "";
        int count = 0;
        while(count++ < number){
            messageStr =  "this is "+count+" message!";
            redis.rpush("logstash-test-list",messageStr);
            System.out.println(messageStr);
        }
    }
    //发布订阅
    public static void PublishExample(Jedis redis,int number){
        String messageStr = "";
        int count = 0;
        while(count++ < number){
            messageStr =  "this is "+count+" message!";
            redis.publish("logstash-test-list",messageStr);
            System.out.println(messageStr);
        }
    }
}
本文转自博客园xingoo的博客,原文链接:如何使用Jedis操作Redis消息队列,如需转载请自行联系原博主。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Discord 公司如何使用 Cassandra 存储上亿条线上数据
Discord 是一款国外的类似 YY 的语音聊天软件。Discord 语音聊天软件及我们的 UGC 内容的增长速度比想象中要快得多。随着越来越多用户的加入,带来了更多聊天消息。2016 年 7 月,每天大约有 4 千万条消息;2016 年 12 月,每天超过亿条。
4305 0
c#常见stream操作
原文: c#常见stream操作   常见并常用的stream一共有 文件流(FileStream), 内存流(MemoryStream), 压缩流(GZipStream), 加密流(CrypToStream), 网络流(NetworkStream); 1.
981 0
如何使用SecureCRT连接ubuntu
1. 首先要明白什么是ssh? 可以把ssh看做是telnet的加强版,telnet的密码和信息都是不加密的,而ssh则加密。 .2. 开启ubuntu上的ssh功能 先安装,安装后就自动开启了.
880 0
完整的个人博客指南:如何使用WordPress启动和发展个人博客
完整的个人博客指南:如何使用WordPress启动和发展个人博客 互联网上有足够的空间供所有人使用。人们喜欢分享想法,塑造他们的想法,甚至可能覆盖全球观众。如何让自己走上实现这一切的道路?一次,如何创建个人博客?由于几个原因,博客非常有效。
1483 0
SpringBoot如何使用JPA操作数据库?
介绍如何在SpringBoot中使用JPA,并介绍JPA的相关知识点和原理
2944 0
如何使用RDS创建Hive元数据库
1. 问题背景 E-MapReduce中支持的Hive,会默认在Master节点的Mysql数据库中记录元数据信息。通常,用户会将数据存储在E-MapReduce的HDFS中,使用Hive处理HDFS中的数据。当集群释放时,节点的所有数据包括HDFS数据和Hive元数据都会被删除。前面我撰文说过,
4707 0
+关注
1040
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载