基於spring-redis釋出訂閱模式的實現

阿新 • • 發佈：2019-01-10

redis配置：
Java程式碼

<?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:context="http://www.springframework.org/schema/context"
xmlns:redis="http://www.springframework.org/schema/redis" xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/redis
http://www.springframework.org/schema/redis/spring-redis-1.0.xsd"
default-autowire="byName">
<context:property-placeholder location="classpath:redis.properties" />
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxIdle"

value="${redis.maxIdle}" />
<property name="maxTotal" value="${redis.maxTotal}" />
<property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
<property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
destroy-method="destroy">
<property name="poolConfig" ref="jedisPoolConfig"></property>
<property name="hostName" value="${redis.host}"></property>
<property name="port" value="${redis.port}"></property>
<property name="password" value="${redis.pass}"></property>
</bean>
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory"></property>
<property name="defaultSerializer">
<bean
class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
</bean>
<bean id="registerMessageListener" class="com.gc.biz.cache.listener.RegisterMessageListener">
<property name="redisTemplate" ref="redisTemplate"></property>
</bean>
<bean id="priDocMessageListener" class="com.gc.biz.cache.listener.PriDocRegActMsgListener">
<property name="redisTemplate" ref="redisTemplate"></property>
</bean>
<bean id="redisDAO" class="com.gc.biz.cache.impl.MessageDaoImpl">
<property name="redisTemplate" ref="redisTemplate" />
</bean>
<bean id="topicContainer"
class="org.springframework.data.redis.listener.RedisMessageListenerContainer"
destroy-method="destroy">
<property name="connectionFactory" ref="jedisConnectionFactory" />
<property name="taskExecutor">
<bean
class="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler">
<property name="poolSize" value="3"></property>
</bean>
</property>
<property name="messageListeners">
<map>
<entry key-ref="registerMessageListener">
<bean class="org.springframework.data.redis.listener.ChannelTopic">
<constructor-arg value="coupon|redenvelop|notify|points" />
</bean>
</entry>
<entry key-ref="priDocMessageListener">
<bean class="org.springframework.data.redis.listener.ChannelTopic">
<constructor-arg value="YZM|BG" />
</bean>
</entry>
</map>
</property>
</bean>
<bean id="springContext" class="com.gc.biz.cache.util.SpringContextHolder" />
<bean id="doctorDAO" class="com.gc.biz.cache.impl.DoctorDAOImpl" >
<property name="redisTemplate" ref="redisTemplate" />
</bean>
<bean id="remindDAO" class="com.gc.biz.cache.impl.RemindDAOImpl" />
<bean id="userDAO" class="com.gc.biz.cache.impl.UserDAOImpl" />
<bean id="userDataDAO" class="com.gc.biz.cache.impl.UserDataDAOImpl" />
</beans>

監聽器的實現：
Java程式碼

package com.gc.biz.cache.listener;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import org.apache.log4j.Logger;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.core.RedisTemplate;
import com.gc.apps.jsk.coupon.service.CouponService;
import com.gc.apps.jsk.coupon.service.impl.CouponServiceImpl;
import com.gc.apps.jsk.invitationcode.service.InvitationService;
import com.gc.apps.jsk.invitationcode.service.impl.InvitationServiceImpl;
import com.gc.apps.jsk.login.service.RegisterService;
import com.gc.apps.jsk.login.service.impl.RegisterServiceImpl;
import com.gc.apps.jsk.membership.service.MemberShipService;
import com.gc.apps.jsk.membership.service.impl.MemberShipServiceImpl;
import com.gc.biz.member.dbobj.MemberInfo;
import com.gc.common.util.StrUtil;
import com.gc.frame.core.db.DBTransaction;
import com.gc.frame.core.misc.StringUtil;
import com.google.gson.Gson;
public class RegisterMessageListener implements MessageListener {
private RedisTemplate<Serializable, Serializable> redisTemplate;
private static Logger logger = Logger.getLogger(RegisterMessageListener.class);
public void setRedisTemplate(RedisTemplate<Serializable, Serializable> redisTemplate) {
this.redisTemplate = redisTemplate;
}
@Override
public void onMessage(Message message, byte[] pattern) {
byte[] body = message.getBody();// 請使用valueSerializer
byte[] channel = message.getChannel();
// 請參考配置檔案，本例中key，value的序列化方式均為string。
// 其中key必須為stringSerializer。和redisTemplate.convertAndSend對應
String msgContent = (String) redisTemplate.getValueSerializer().deserialize(body);
String topic = (String) redisTemplate.getStringSerializer().deserialize(channel);
System.out.println(topic + ":" + msgContent);
Map<String, String> map = new Gson().fromJson(msgContent, Map.class);
String from = map.get("from");
if ("wx".equals(from)) {
doRegisterMsg_wx(topic, msgContent);
} else if ("app".equals(from)) {
doRegisterMsg(topic, msgContent);
}
}

訊息傳送介面的實現：
Java程式碼

package com.gc.biz.cache.impl;
import java.io.Serializable;
import org.springframework.data.redis.core.RedisTemplate;
import com.gc.biz.cache.dao.MessageDao;
public class MessageDaoImpl implements MessageDao{
private RedisTemplate<String , Object> redisTemplate = null;
public MessageDaoImpl() {
}
@Override
public void sendMessage(String channel, Serializable message) {
redisTemplate.convertAndSend(channel, message);
}
public RedisTemplate<String, Object> getRedisTemplate() {
return redisTemplate;
}
public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
this.redisTemplate = redisTemplate;
}
}

測試呼叫的方法：
Java程式碼

MessageDao dao = SpringContextHolder.getBean("redisDAO");
Map<String,String> map = new HashMap<String,String>();
map.put("1", "11111");
map.put("2", "22222");
dao.sendMessage("coupon", new Gson().toJson(map));
dao.sendMessage("redenvelop", new Gson().toJson(map));
dao.sendMessage("notify", new Gson().toJson(map));
map.put("UserBagID", "1");
map.put("CreateDate", "2016-06-01 16:51:35");
dao.sendMessage("iphone|xiaomi", new Gson().toJson(map));

注意：1、如果有多個專案同時使用此配置，只需要保留一個專案配置檔案有關注專案；2、此配置沒有考慮分散式部署的環境，如果要考慮從redis list和分散式鎖的方向考慮。

基於spring-redis釋出訂閱模式的實現

redis配置： Java程式碼 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"

RabbitMQ釋出訂閱模式實現

pom檔案： <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://mav

通過釋出訂閱模式實現的事件委託

關於這篇文章的背景之前瞭解到的事件代理不多，就像是一個dom將事件委託給另一個dom，又叫事件委託。後來做了個題目，要實現一個類似jquery的事件委託方法，然後認真的瞭解了一下。然後專注於實現，其實並沒有去看jquery的原始碼，hhh。釋出訂閱模式大概是目前前端框架使用的一種最常見的設計模式了，而

redis 釋出訂閱 python實現

一、首先實現一個redis類，提供給訂閱者和釋出者呼叫 import redis class RedisHelper: def __init__(self): # 連結服務端 self.__conn = redis.Redis(host='127.0.

redis 釋出訂閱模式及應用場景

一：命令簡介　　從redis手冊上面可以看到，其實“釋出、訂閱”模式才區區6個命令，下面聽我一一解說下哈~~~1. subscribeSUBSCRIBE channel [channel ...] 訂閱給定的一個或多個頻道的資訊。從上面的官方解釋上來看，它的玩法有

使用EventBus + Redis釋出訂閱模式提升業務執行效能

前言最近一直奔波於面試，面了幾家公司的研發。有讓我受益頗多的面試經驗，也有讓我感覺浪費時間的面試經歷~因為疫情原因，最近宅在家裡也沒事，就想著使用Redis配合事件匯流排去實現下具體的業務。需求一個簡單的電商，有幾個重要的需求點商品下單後TODO 儲存訂單資訊鎖定商

使用EventBus + Redis釋出訂閱模式提升業務執行效能(下)

前言上一篇部落格上已經實現了使用EventBus對具體事件行為的分發處理，某種程度上也算是基於事件驅動思想程式設計了。但是如上篇部落格結尾處一樣，我們原始碼的執行效率依然達不到心裡預期。在下單流程裡我們明顯可以將部分行為進行非同步處理，提升下單操作的執行效率。 Redis基礎命令 Redis有兩種方式可支援

spring-data-redis實現redis釋出訂閱

maven 依賴包 <properties> <spring.version>5.1.0.RELEASE</spring.version> </properties> <dependencies

springboot整合redis實現訊息釋出訂閱模式-雙通道(跨多伺服器)

基礎配置參考https://blog.csdn.net/llll234/article/details/80966952 查看了基礎配置那麼會遇到一下幾個問題： 1.實際應用中可能會訂閱多個通道，而一下這種寫法不太通用container.addMessageListener

redis之mq實現釋出訂閱模式

示例程式碼-github 概述 Redis不僅可作為快取伺服器，還可用作訊息佇列，本示例演示如何使用redis實現釋出/訂閱訊息佇列。在Redis中，釋出者沒有將訊息傳送給特定訂閱者的程式。相反，釋出的訊息被描述為通道，而不知道(如果有的話)可能有哪些訂閱者。訂閱者表示對一個或多個主題感興趣，只

js 實現釋出訂閱模式

/* Pubsub */ function Pubsub(){ 　　//存放事件和對應的處理方法　　this.handles = {}; } Pubsub.prototype = { 　　//傳入事件型別type和事件處理handle 　　on: function (type, handle) { 　　　　

Redis釋出訂閱實現原理

釋出訂閱中使用到的命令就只有三個：PUBLISH,SUBSCRIBE,PSUBSCRIBE PUBLISH 用於釋出訊息 SUBSCRIBE 也叫頻道訂閱，用於訂閱某一特定的頻道 PSUBSCRIBE 也叫模式訂閱，用於訂閱某一組頻道，使用glob的方式，比如xxx-*可以匹配xxx-a，和xxx-b,xx

Redis研究（十六）—釋出/訂閱模式

在上一篇中我們寫了Redis的任務佇列。除了實現任務佇列外，Redis還提供了一組命令可以讓開發者實現“釋出/訂閱”（publish/subscribe）模式。“釋出/訂閱”模式同樣可以實現程序間的訊息傳遞，其原理是這樣的：

學習筆記-js釋出/訂閱模式的簡單實現

Publish/Subscribe(釋出/訂閱模式): 在《Javascript設計模式》一書中，這兩種模式還是有些區別的。書中原話如下： * Observer模式要求希望接收到主題通知者的觀察者必須訂閱內容改變的事件 * Subscribe/Publis

使用Spring配置ActiveMQ的釋出訂閱模式

通過Spring對ActiveMQ進行配置開發，釋出訂閱模式，支援訊息的持久化。需要Spring2.5版本以上，如果有多個訂閱者，每個訂閱者需要指定不同的 clientId 。釋出者的配置 <?xml version="1.0" encoding="UTF-8"

釋出訂閱模式簡單實現

程式碼 export default class Oberver { // 定義一個事件容器 event = {} subscribe (type, fn) { // 訊息型

15天玩轉redis —— 第九篇釋出/訂閱模式

本系列已經過半了，這一篇我們來看看redis好玩的釋出訂閱模式，其實在很多的MQ產品中都存在這樣的一個模式，我們常聽到的一個例子就是郵件訂閱的場景，什麼意思呢，也就是說100個人訂閱了你的部落格，如果博主發表了文章，那麼100個人就會同時收到通知郵件，除了這個場景還能找到

ActiveMQF釋出訂閱模式及Spring整合

Topic主題釋出和訂閱訊息前面講的案例都是點對點的訊息，即一個生產者傳送的一條訊息只能被一個消費者消費，然後就移除了。而t

我在生產專案裡是如何使用Redis釋出訂閱的？（二）Java版程式碼實現（含原始碼）

上篇文章講了在實際專案裡的哪些業務場景用到Redis釋出訂閱，這篇文章就講一下，在Java中如何實現的。圖解程式碼結構釋出訂閱的理論以及使用場景大家都已經有了大致瞭解了，但是怎麼用程式碼實現釋出訂閱呢？在這裡給大家分享一下實現方式。我們以上篇文章的第三種使用場景為例

vue非父子元件間的傳值 Bus/匯流排機制/釋出訂閱模式/觀察者模式

Bus/匯流排機制/釋出訂閱模式/觀察者模式我們需要將一個元件的子元件的資料傳遞給另一個元件的子元件 ① 將Vue的例項賦值給Vue.prototype.bus，這樣只要我們之後呼叫new Vue()或者建立元件的時候，每一個元件上都會有Bus這個屬性，因為每一個元件或者Vue這個例項

基於spring-redis釋出訂閱模式的實現

相關推薦