图书馆网站建设所需资料,网站手机版建设,钢城网站建设,山东室内设计学校前言 今天要分享的是基于Redisson实现信息发布与订阅#xff08;以前分享过直接基于redis的实现#xff09;#xff0c;如果你是在多服务间基于redisson做信息传递#xff0c;并且有服务压根就收不到信息#xff0c;那你一定要看完。 今天其实重点是避坑#xff0…前言 今天要分享的是基于Redisson实现信息发布与订阅以前分享过直接基于redis的实现如果你是在多服务间基于redisson做信息传递并且有服务压根就收不到信息那你一定要看完。 今天其实重点是避坑真正的集成使用就几步。 一、redission介绍 介绍的文字我都懒得写其实要我写详细我也是google下面直接贴图吧 介绍的挺详细的吧下面还有代码示例哦不得不说这个GPT插件挺好用的。 其实简单理解就一句话它就是redis的java客户端做了一层封装。
二、使用步骤
1.引入库
代码如下示例 !-- springboot redis集成 --dependencygroupIdorg.springframework.session/groupIdartifactIdspring-session-data-redis/artifactId/dependency!-- springBoot redisson redis支持 --dependencygroupIdorg.redisson/groupIdartifactIdredisson-spring-boot-starter/artifactIdversion3.24.3/version/dependency2.信息发布 /*** 告警监听器*/import cn.hutool.json.JSONUtil;
import org.redisson.api.RTopic;
import org.redisson.api.RedissonClient;
import org.redisson.codec.SerializationCodec;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.xx.xx.alarm.entity.Alarm;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;Component
public class AlarmListener{private static final Logger LOGGER LoggerFactory.getLogger(AlarmListener.class);Resourceprivate RedissonClient redisson;public static String WS_ALARM_LISTEN WS_ALARM_LISTEN;private RTopic topic;/*** 开启监听*/PostConstructvoid openReceiving() {topic redisson.getTopic(WS_ALARM_LISTEN, new SerializationCodec());}/*** 业务需要的地方可以直接待用**/public void sendNotice(Alarm alarm) {//redis 发广播try {//topic.publish(alarm);//屏蔽redisssion监听对class的差异String alarmStr JSONUtil.toJsonStr(alarm);topic.publish(alarmStr);} catch (Exception e) {LOGGER.error(sendNotice失败, e);}}}Alarm是告警实体对象大家根据自己的业务可能是其他对象。 3、信息订阅 /*** 告警监听器**/import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.xxxx.entity.Alarm;import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.redisson.api.RTopic;
import org.redisson.api.RedissonClient;
import org.redisson.api.listener.MessageListener;
import org.redisson.codec.SerializationCodec;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;
import javax.annotation.Resource;import java.util.List;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.stream.Collectors;Component
public class AlarmListener {private static final Logger LOGGER LoggerFactory.getLogger(AlarmListener.class);Resourceprivate RedissonClient redisson;public static String WS_ALARM_LISTEN WS_ALARM_LISTEN;private RTopic topic;/*** 开启监听*/PostConstructvoid openReceiving() {topic redisson.getTopic(WS_ALARM_LISTEN, new SerializationCodec());LOGGER.info(监听ws成功{}, topic);topic.addListener(String.class, (charSequence, msgStr) - {//TODO 收到消息去做自己的业务下面是我们业务的一个示例if (StringUtils.isNotEmpty(msgStr) JSONUtil.isJson(msgStr)) {Alarm alarm JSON.parseObject(msgStr, Alarm.class);send(alarm);}});}
}其实就这么简单如果是在一个服务里面用2个监听器是可以合并的。我这里是2个服务里面用。 就是因为在2个服务里面用不知道大家有没有发现topic的publish、addListener的特别之处可能大家在写的时候可以直接publish、addListener放入业务对象.class参数。我刚开始也是被坑在这里。一个服务里面publish信息了另一个服务里死活收不到用redis-cli去看发现信息又是放入了主题的监听的主题也与发布的一致。 补充redis-cli命令的使用
redis-cli -h redis服务ip -p 端口 -a 密码SUBSCRIBE topic名称我首先想到的是2边版本不一致于是把新搭建的流水服务的redisson-spring-boot-starter降版本结果还是一样。 然后就debug发现监听里的onMessage基类会做如下判断 这个除了判断channel频道收到的信息还会判断信息与添加监听addListener时传入的class是否可以转换。 网上好多都只提到publish、addListener但是压根记不会提到传入的class会干嘛知道问题原因后我们让数据回归本质直接用String这也就形成了我上面的2段。
总结
基于redisson实现信息发布订阅就是这么简单几下一定注意publish、addListener不要直接用业务对象尤其是不在一个服务里毕竟谁也不能保证对象名一样也不能保证包路径一样回归信息的本质用字符串靠谱如果是复杂的信息传递机制还是用专业的信息中间件 好了就写到这里希望可以帮到大家。
