首页 / REDIS / 使用redis的发布订阅模式实现消息队列

使用redis的发布订阅模式实现消息队列

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了使用redis的发布订阅模式实现消息队列，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6430字，纯文字阅读大概需要10分钟。

内容图文

配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
    http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">

    <context:component-scan base-package=‘com.iwhere.redis.sub‘/>
    <!-- 获取配置资源 -->
<!--     <context:property-placeholder location="classpath:redis-context-config.properties" /> -->
    
    <!-- redis  START -->
    <bean id="propertyConfigurerRedis"class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
        <property name="order" value="1" />  
        <property name="ignoreUnresolvablePlaceholders" value="true" />  
        <property name="locations">  
            <list>  
                <value>classpath:redis-context-config.properties</value>  
            </list>  
        </property>  
    </bean>
      
        <!-- jedis pool配置 -->  
    <bean id="jedisPoolConfig"class="redis.clients.jedis.JedisPoolConfig">  
        <property name="maxTotal" value="${redis.maxActive}" />
        <property name="maxIdle" value="${redis.maxIdle}" />  
        <property name="maxWaitMillis" value="${redis.maxWait}" />  
        <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
    </bean>  
  
    <!-- spring data redis -->  
    <bean id="jedisConnectionFactory"class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">  
        <property name="usePool" value="false"></property>  
        <property name="hostName" value="${redis.host}" />  
        <property name="port" value="${redis.port}" />  
        <property name="password" value="${redis.pass}" />  
        <property name="timeout" value="${redis.timeout}" />  
<!--         <property name="database" value="${redis.default.db}"></property> -->         
         <constructor-arg index="0"ref="jedisPoolConfig" />  
    </bean>  
      
    <bean id="redisTemplate"class="org.springframework.data.redis.core.StringRedisTemplate">  
        <property name="connectionFactory"ref="jedisConnectionFactory"></property>
        <property name="keySerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        </property>
        <property name="valueSerializer">
            <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        </property>  
    </bean>
    <!-- redis  END -->
    
    <bean id="serialization"class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />  
  
    <bean id="messageDelegateListener"class="com.iwhere.redis.sub.MessageDelegateListenerImpl" />  
  
    <bean id="messageListener"class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">  
        <property name="delegate"ref="messageDelegateListener" />  
        <property name="serializer"ref="serialization" />  
    </bean>  
    
    <bean id=‘messageContainer‘class=‘org.springframework.data.redis.listener.RedisMessageListenerContainer‘
          destroy-method=‘destroy‘>
         <property name=‘connectionFactory‘ref=‘jedisConnectionFactory‘ />
        <property name=‘messageListeners‘>
             <map>
                <entry key-ref=‘messageListener‘>
                    <list>
                        <ref bean=‘amap‘ />
                    </list>
                    
                </entry>
            </map>
        </property>
    </bean>
    <!-- Channel设置 -->
<!--     <bean id=‘sendTopic‘class=‘org.springframework.data.redis.listener.ChannelTopic‘> -->
<!--           <constructor-arg value=‘send‘ /> -->
<!--     </bean> -->
    <!-- Channel设置 -->
    <bean id=‘amap‘class=‘org.springframework.data.redis.listener.ChannelTopic‘>
          <constructor-arg value=‘amap‘ />
    </bean>
</beans>

Demo演示：

消息发布端:

            package com.iwhere.testredis;

import org.junit.Before;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.redis.core.StringRedisTemplate;


            /*
            *
 * 测试redis做消息
 * @author 231
 *
 
            */
            public
            class
             TestRedis {

    
            private
             StringRedisTemplate redisTemplate;
    @Before
    
            public
            void
             before() {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:redis-context.xml");
        redisTemplate = context.getBean(StringRedisTemplate.class);
    }
    
    private String channel = "amap";
    /**
     * 测试连接
     */
    @Test
    publicvoid test1() {
        String message = "c26c4ac0-37a3-4277-9020-bfa274c058f5|526548902996869120|Success";
        redisTemplate.convertAndSend(channel, message);
        System.out.println("发送完成");
    }
}

消息接收端

            package com.iwhere.redis.sub;

import java.io.UnsupportedEncodingException;

import org.aspectj.bridge.Message;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.listener.ChannelTopic;


            /*
            * 
 * 
 
            */
            public
            class
             MessageDelegateListenerImpl implements MessageListener {
    
    @Autowired
    
            private
             ChannelTopic channelTopic;
    
    @Override
    
            public
            void onMessage(org.springframework.data.redis.connection.Message message, byte[] pattern) {

        byte[] bytes = message.getBody();// ""里面的参数为需要转化的编码，一般是ISO8859-1try {
            String str = new String(bytes, "utf-8");
            System.out.println("I am here" + str + ": " +  channelTopic.getTopic());
        } catch (UnsupportedEncodingException e) {
            // TODO Auto-generated catch block            e.printStackTrace();
        }
        System.out.println(message);
    }

}

redis的资源文件

#redis.host=dev.iwhere.com
redis.host=192.168.1.110
redis.port=6379
redis.pass=redis密码, 没有密码就注释掉
redis.default.db=0
redis.timeout=100000
redis.maxActive=300
redis.maxIdle=100
redis.maxWait=1000
redis.testOnBorrow=true

原文：http://www.cnblogs.com/wenbronk/p/6385952.html

内容总结

以上是互联网集市为您收集整理的使用redis的发布订阅模式实现消息队列全部内容，希望文章能够帮你解决使用redis的发布订阅模式实现消息队列所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1328824.html

来源：【匿名】

【下一篇】redis可以做什么？

更多 ►

【使用redis的发布订阅模式实现消息队列】教程文章相关的互联网学习教程文章

使用redis的发布订阅模式实现消息队列【代码】

配置文件<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http:/...

redis代替kafka做缓存队列

前言：刚上线elk一个月左右，使用的kafka作为缓存队列，但是不知道为何，中间发生过好几次，elk突然没数据了，长达好几天都没有，折腾了好久，好了，过几天又发生同样的状况。经查找，数据是有到达kafka，但是logstash读取不了。无奈之下，只能把kafka 更换为redis。 filebeat配置-------------filebeat: prospectors: - document_type: "web-hkgf-proxy-nginx-access" paths: - /data/logs/...

python 操作 redis + 消息队列使用例子【代码】

操作 redisimport redis redisPool = redis.ConnectionPool(host=‘192.168.100.50‘, port=6379, db=8) redis= redis.Redis(connection_pool=redisPool)redis.set(‘key‘,‘values‘) redis.get(‘com‘) redis.append(‘keys‘,‘values‘) redis.delete(‘keys‘)print(redis.getset(‘name‘,‘Mike‘)) #赋值name为Mike并返回上一次的value print(redis.mget([‘name‘,‘age‘])) #输出name键和age键的value print(redis...

Java利用Redis实现消息队列【代码】

应用场景为什么要用redis?二进制存储、java序列化传输、IO连接数高、连接频繁一、序列化　　这里编写了一个java序列化的工具,主要是将对象转化为byte数组,和根据byte数组反序列化成java对象; 主要是用到了ByteArrayOutputStream和ByteArrayInputStream; 注意:每个需要序列化的对象都要实现Serializable接口; 其代码如下: 1 package Utils;2 import java.io.*;3 /**4 * Created by Kinglf on 2016/10/17.5 */6 public class Objec...

[转载] 基于Redis实现分布式消息队列

转载自http://www.linuxidc.com/Linux/2015-05/117661.htm1、为什么需要消息队列？当系统中出现“生产“和“消费“的速度或稳定性等因素不一致的时候，就需要消息队列，作为抽象层，弥合双方的差异。举个例子：业务系统触发短信发送申请，但短信发送模块速度跟不上，需要将来不及处理的消息暂存一下，缓冲压力。再举个例子：调远程系统下订单成本较高，且因为网络等因素，不稳定，攒一批一起发送。再举个栗子，交互模块5：00到24...

redis适合做队列的几种方式总结

以下介绍redis的几种类型：List、Pub/Sub、Stream场景ListPub/SubStream阻塞式消费支持支持支持发布/订阅不支持支持支持重复消费不支持不支持支持持久化支持不支持支持消息堆积内存持续增长缓冲区溢出，消费者强制下线可控制队列最大长度消息会不会丢失Redis本身不保证数据完整性，存在数据丢失的可能消息积压能力Redis数据存储在内存，消息堆积对内存压力较大以上总结参考https://mp.weixin.qq.com/s/QQTG7RIOgSvSIueTqOHwww原文...

RabbitMQ与Redis队列对比【图】

本文仅针对RabbitMQ与Redis做队列应用时的情况进行对比具体采用什么方式实现，还需要取决于系统的实际需求简要介绍 RabbitMQRabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。Redis是一个Key-Value的NoSQL数据库，开发维护很活跃，...

JavaWeb项目架构之Redis分布式日志队列【代码】【图】

架构、分布式、日志队列，标题自己都看着唬人，其实就是一个日志收集的功能，只不过中间加了一个Redis做消息队列罢了。前言为什么需要消息队列？当系统中出现“生产“和“消费“的速度或稳定性等因素不一致的时候，就需要消息队列，作为抽象层，弥合双方的差异。比如我们系统中常见的邮件、短信发送，把这些不需要及时响应的功能写入队列，异步处理请求，减少响应时间。如何实现？成熟的JMS消息队列中间件产品市面上有很多，但是基...

java redis使用之利用jedis实现redis消息队列

应用场景最近在公司做项目，需要对聊天内容进行存储，考虑到数据库查询的IO连接数高、连接频繁的因素，决定利用缓存做。从网上了解到redis可以对所有的内容进行二进制的存储，而java是可以对所有对象进行序列化的，序列化的方法会在下面的代码中提供实现。序列化这里我编写了一个java序列化的工具，主要是对对象转换成byte[]，和根据byte[]数组反序列化成java对象；主要是用到了ByteArrayOutputStream和ByteArrayInputStream；需要...

python 结合redis 队列做一个例子【代码】

结合redis 队列做了一个例子#!/usr/bin/env python # coding: utf-8 # @Time : 2018/12/21 0021 13:57 # @Site : # @File : demos.py # @Software: PyCharm import MySQLdb import redis import json import os, time import threading from multiprocessing import Pool, Process import os, time, random import sysreload(sys) sys.setdefaultencoding(‘utf8‘)class InsertData():def __init__(self):# 去掉一些无...

REDIS - 技术教程分类

Redis 教程 Redis 简介 Redis 安装 Redis 配置 Redis 数据类型 Redis 命令 Redis 键(key) Redis 字符串(String) Redis 哈希(Hash) Redis 列表(List) Redis 集合(Set) Redis 有序集合(sorted set) Redis HyperLogLog Redis 发布订阅 Redis 事务 Redis 脚本 Redis 连接 Redis 服务器 Redis GEO Redis Stream Redis 数据备份与恢复 Redis 安全 Redis 性能测试 Redis 客户端连接 Redis 分区 Redis 全部

REDIS - 最热教程

redis中批量删除key的方法 redis设置密码，取消密码 node.js利用redis数据库缓存数据 PHP swoole和redis异步任务实现方法分析 Laravel使用Redis共享Session步骤详解 mac下卸载干净redis 如何通过命令行修改redis的配置使用Port Forwarding连接k8s集群的pod（...实现商品秒杀之——Redis Watch机制 redis雪崩、穿透、击穿、热点分别代表什...

首页 / REDIS / 使用redis的发布订阅模式实现消息队列

使用redis的发布订阅模式实现消息队列

内容导读

内容图文

Demo演示：

内容总结

内容备注

内容手机端

【使用redis的发布订阅模式实现消息队列】教程文章相关的互联网学习教程文章

使用redis的发布订阅模式实现消息队列【代码】

redis代替kafka做缓存队列

python 操作 redis + 消息队列使用例子【代码】

Java利用Redis实现消息队列【代码】

[转载] 基于Redis实现分布式消息队列

redis适合做队列的几种方式总结

RabbitMQ与Redis队列对比【图】

JavaWeb项目架构之Redis分布式日志队列【代码】【图】

java redis使用之利用jedis实现redis消息队列

python 结合redis 队列做一个例子【代码】

RabbitMQ与Redis队列对比

rabbitmq和redis用作消息队列的区别

【高并发简单解决方案】redis缓存队列+mysql批量入库+php离线整合

缓存-php如何后台监控redis队列是否有值，有值执行脚本php如何后台监控redis队列是否有值，有值执行脚本

redis队列生成缓存的相关问题

REDIS - 相关标签

REDIS - 技术教程分类

REDIS - 最新教程

REDIS - 最热教程