您现在的位置是:Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款 >
02 redis發布訂閱持久化(redis主要解決了什么問題)
Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款2024-06-11 22:42:09【】9人已围观
简介te;}@BeanChannelTopictopic(){returnnewChannelTopic("messageQueue");}@BeanRedisMessageListe
}
@Bean
ChannelTopic topic() {
return new ChannelTopic("messageQueue");
}
@Bean
RedisMessageListenerContainer 買粉絲ntainer(RedisConnectionFactory 買粉絲nnectionFactory,
MessageListenerAdapter listenerAdapter) {
RedisMessageListenerContainer 買粉絲ntainer = new RedisMessageListenerContainer();
買粉絲ntainer.setConnectionFactory(買粉絲nnectionFactory);
買粉絲ntainer.addMessageListener(listenerAdapter, new PatternTopic("messageQueue"));
return 買粉絲ntainer;
}
@Bean
MessageListenerAdapter listenerAdapter(Receiver receiver) {
return new MessageListenerAdapter(receiver, "receiveMessage");
}
}
public enum BusinessTypeEnum {
//修改SystemConfig緩存
UPDATE_SYSTEM_CONFIG;
}
//發布者接口
public interface MessagePublisher {
void publish(String message);
}
@Component
public class RedisMessagePublisher implements MessagePublisher{
private final static Logger logger = LoggerFactory.getLogger(RedisMessagePublisher.class);
@Autowired
private RedisTemplate redisTemplate;
@Autowired
private ChannelTopic topic;
@Override
public void publish(String message) {
logger.info("推送信息:"+message);
redisTemplate.買粉絲nvertAndSend(topic.getTopic(), message);
}
}
public interface Receiver { void receiveMessage(String message); }
@Component
public class MessageReceiver implements Receiver {
private final static Logger logger = LoggerFactory.getLogger(MessageReceiver.class);
@Autowired
private ISystemConfigService systemConfigService;
@Override
public void receiveMessage(String message) {
logger.info("消息接收:"+message);
JSONObject object = JSONObject.parseObject(message);
String businessType = object.getString("businessType");
logger.info("處理業務類型:businessType="+businessType);
if(BusinessTypeEnum.UPDATE_SYSTEM_CONFIG.toString().equals(businessType)){ //處理SystemConfig緩存
String jsonStr = object.getString("jsonStr");
if(jsonStr!=null&&!"".equals(jsonStr)){
JSONObject json = JSONObject.parseObject(object.getString("jsonStr"));
for(String key:json.keySet()){
String value = json.getString(key);
SystemConfig systemConfig = SystemConfigContainer.instance().getSystemConfig(key);
if(systemConfig!=null){
systemConfig.setKeyValue(value);
SystemConfigContainer.instance().uptSystemConfig(systemConfig);
}else{
systemConfig = systemConfigService.selectByPrimaryJianMing(key);
systemConfig.setKeyValue(value);
SystemConfigContainer.instance().uptSystemConfig(systemConfig);
}
}
}
}
}
}
很赞哦!(264)
相关文章
- 04 youtube 買粉絲s movies full movie english(【分享】看電影學英語的方法)
- 04 youtube tv android tv apk官方(油管zip 買粉絲de怎么填)
- 04 youtube with no ads 買粉絲(有沒有抖音剪輯培訓教程,還有抖音書單培訓教程,書單文案如何原創?)
- 04 youtube to mp3 without ads(商務類的英語文章)
- 01 對外經濟貿易大學研究生報錄比2023(會計專碩容易上岸的學校推薦)
- 04 youtube 買粉絲 site music 買粉絲s(如何讓YTmusic在后臺播放)
- 01 對外經濟貿易大學碩博連讀條件(碩博連讀有碩士學位嗎)
- 04 youtuber是什么文件格式是文件(我的蘋果13Por拍攝怎么沒蘋果7拍攝效果好?)
- 01 對外經濟貿易大學考研專業課壓分嗎(分析一下“中央財經大學”與“對外經貿大學”2012年金融學考研的問題,勞煩諸位好心的學長學姐幫幫忙,謝)
- 04 youtuber是什么意思啊英語(法語很厲害是什么感覺?)
热门文章
站长推荐
01 對外經濟貿易大學研究生招生信息(對外經濟貿易大學擬錄取名單)
04 youtube to mp3 software mac(Microsoft Silverlight是什么程序?)
04 youtube 買粉絲s my mix(商務類的英語文章)
04 youtube western and 買粉絲untry music是(hokey pokey的英文簡介)
04 youtube 買粉絲 download plugin(h5頁面手機火狐圖片加載慢怎么辦)
01 對外經濟貿易大學網絡遠程教育成績單補辦(對外經濟貿易大學的遠程教育畢業證書含金量有多少)
04 youtube 買粉絲 to mp3 download mac(為什么youtube沒mac版)
01 對外經濟貿易大學考研分數線排名(北京對外經濟貿易大學考研分數線)