如何使用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消息队列,如需转载请自行联系原博主。

时间: 2024-10-25 08:32:15

如何使用Jedis操作Redis消息队列的相关文章

Redis消息队列

Redis的消息队列使用简单,没有什么配置,比ActiveMQ要轻量级太多,当然功能也比较简单,如果只需要简单的订阅以及发布,可以考虑使用它. 订阅操作 命令为:subscribe [channel] [channel] ..,如[代码1]所示,即成功订阅频道[redis.blog]. 发布操作 命令为publish [channel] [message],如[代码2]所示,[图1]为订阅的客户端展示效果. [代码1]: subscribe "redis. blog" [代码2] pu

Redis 消息队列介绍

Redis的消息队列使用简单,没有什么配置,比ActiveMQ要轻量级太多,当然功能也比较简单,如果只需要简单的订阅以及发布,可以考虑使用它. 订阅操作 命令为:subscribe [channel] [channel] ..,如[代码1]所示,即成功订阅频道[redis.blog]. 发布操作 命令为publish [channel] [message],如[代码2]所示,[图1]为订阅的客户端展示效果. [代码1]: subscribe "redis. blog" [代码2] pu

spring mvc redis消息队列

通常情况下,为了提高系统开发的灵活性和可维护度,我们会采用消息队列队系统进行解耦.下面是一个采用spring redis实现的消息队列实例,但此实例会由于网络延迟和阻塞等情况导致消息处理的延时,因而不能确保消息处理的顺序,所以使用时需要注意. pom.xml中添加如下配置 添加版本配置 <properties> <jedis.version>2.8.1</jedis.version> <spring-data-redis.version>1.7.2.RELE

Java中使用Jedis操作Redis

使用Java操作Redis需要jedis-2.1.0.jar,下载地址:http://files.cnblogs.com/liuling/jedis-2.1.0.jar.zip 如果需要使用Redis连接池的话,还需commons-pool-1.5.4.jar,下载地址:http://files.cnblogs.com/liuling/commons-pool-1.5.4.jar.zip 1 package com.test; 2 3 import java.util.HashMap; 4 im

PHP下操作Linux消息队列完成进程间通信的方法_php技巧

关于Linux系统进程通信的概念及实现可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/ 关于Linux系统消息队列的概念及实现可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/part4/ PHP的sysvmsg模块是对Linux系统支持的System V IPC中的System V消息队列函数族的封装.我们需要利用sysvmsg模块提供的函数来进进程间通信.先来看一段示例代码_1:

【Redis】Java中使用Jedis操作Redis(Maven导入包)、创建Redis连接池

转载请注明出处http://blog.csdn.net/qq_26525215 本文源自[大学之旅_谙忆的博客] 如果我们使用Java操作Redis 需要确保已经安装了 redis 服务及 Java redis 驱动. Maven项目可以直接在pom.xml中加入jedis包驱动: <!-- https://mvnrepository.com/artifact/redis.clients/jedis --> <dependency> <groupId>redis.cli

vc操作微软消息队列的方法

定义 IMSMQQueuePtr qDest; // Represents Destination Queue IMSMQQueueInfoPtr qInfo; //Represents an open instance of the destination queue IMSMQQueueInfoPtr qRead; IMSMQMessagePtr qMsg; //Represents the message 初始化 qDest = NULL; CoInitialize(NULL); try{

Jedis 操作redis 序列化存储对象

在Jedis开发中,我们很多时候希望直接把一个对象放到Redis中,然后在需要的时候取出来.Redis的key和value都支持二进制安全的字符串,存储Java对象不是问题,下面我们看一下如何来实现. 1要存储的对象 现在写一个很土的Java Bean,包含两个字段,id和name,类名叫做Person.为了实现序列化需求,该类实现Serializable接口. Java public class Person implements Serializable { private int id;

PHP memcache实现消息队列实例

现在memcache在服务器缓存应用比较广泛,下面我来介绍memcache实现消息队列等待的一个例子,有需要了解的朋友可参考. memche消息队列的原理就是在key上做文章,用以做一个连续的数字加上前缀记录序列化以后消息或者日志.然后通过定时程序将内容落地到文件或者数据库. php实现消息队列的用处比如在做发送邮件时发送大量邮件很费时间的问题,那么可以采取队列. 方便实现队列的轻量级队列服务器是: starling支持memcache协议的轻量级持久化服务器 https://github.co