您现在的位置是:Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款 >
02 redis發布訂閱持久化(Spring Boot使用Redis進行消息的發布訂閱 原創)
Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款2024-06-11 07:22:09【】5人已围观
简介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);
}
}
}
}
}
}
很赞哦!(92)
相关文章
- youtube music download pc apple官網登錄(今日新聞淺談:Youtube Music 也加入串流音樂服務大混戰)
- youtube music download free mp3歌曲免費下載網址(youtube music下載的文件在哪里)
- 08 警察叔叔進課堂幼兒園買粉絲(幼兒園關于警察叔叔本領大是什么歌)
- youtube music download offline(如何讓YTmusic在后臺播放)
- youtube music download online playlist翻譯(youtube music下載的文件在哪里)
- 08 西雙版納三顆糖國際貿易有限公司(保護環境 人人有則)
- 08 網織紅細胞形態學特征(IDA的血象和骨髓象特征是什么)
- youtube music download pc app store(在國外用什么軟件下載音樂)
- youtube music download pc apple music網頁版(現在什么手機系統是最精簡的?)
- youtube music download online mp3轉換器官網(今日新聞淺談:Youtube Music 也加入串流音樂服務大混戰)
热门文章
站长推荐
08 網紅臉真的好看嗎作文(個個整的驚艷,表面“美若天仙”,其實是歪瓜裂棗的女明星你認為都有誰?)
08 紹興貿易公司排名(紹興發展為什么不如寧波?)
08 網織紅細胞計數2.1正常嗎(平均紅細胞血紅蛋白含量高于參考值)
youtube music download for macbook(今日新聞淺談:Youtube Music 也加入串流音樂服務大混戰)
08 美國服務貿易結構(美國是如何促進服務貿易出口的,為什么美國貿易能夠迅速發展)
youtube music download mp3 freecheck論文查重專業版(youtube music下載的文件在哪里)
youtube music download mp3 apk下載站(今日新聞淺談:Youtube Music 也加入串流音樂服務大混戰)
08 自由貿易港英語演講(海南外國語職業學院專業有哪些?專業介紹)