发表新帖

redis发布用的是publish,订阅方法tool里没实现吗？

Blade 未结

关注举报

 1  180

chenlin556666@1 剑童 2025-02-10 13:53

一、该问题的重现步骤是什么？

BladeRedis 有发布没有订阅

二、你期待的结果是什么？实际看到的又是什么？

期待有对应的订阅方法

三、你正在使用的是什么产品，什么版本？在什么操作系统上？

4.4.0

四、请提供详细的错误堆栈信息，这很重要。

五、若有更多详细信息，请在下面提供。

1条回答

admin - BladeX作者

2025-02-10 14:18

大概用法如下

 @Slf4j
@Service
@RequiredArgsConstructor
public class ProductScriptServiceImpl implements IProductScriptService {
    
 
    private final RPubSubPublisher pubSubPublisher;
 
 
    @Override
    public void insertOrUpdate(ProductScriptEntity entity) {
       
       // 发送刷新事件
       pubSubPublisher.publish(IotCacheConstant.PRODUCT_SCRIPT_RELOAD, productKey);
    }
 
 
    /**
     * 更新产品脚本
     */
    @RPubSubListener(IotCacheConstant.PRODUCT_SCRIPT_RELOAD)
    public void subReloadEvent(RPubSubEvent<String> event) {
       String productKey = event.getMsg();
       
    }
 
}

                                          
          

                                
              
                       
                        作者追问:2025-02-10 14:38
                  
  
  多谢！


    

      
      

        
          官方产品
        
        BladeX 企业级开发平台
          BladeX 可视化数据大屏
        
      

        
            官方新品
        
              
         BladeX 物联网开发平台     
        
      
      
      

        热议问题
            
                  
         
          @Sensitive注解加上之后，通过Feign接口调用，如果使其不脱敏
           2
        
               
          3.2.0 token登录接口如何加密
           1
        
               
          配置某个租户(000000)可以看到所有租户的数据
           1
        
               
          boot项目，设置接口放行，无效
           1
        
               
          Spring AI 支持 Spring Boot 3.4.x。目前框架SpringBoot 为 3.2.12。需要升级
           1
        
               
          设备数据上报报错：Table does not exist
           1
        
               
          使用单点认证时，Session如何自动续期
           1
        
               
          这个业务是BIZ的业务，我把这个业务模块部署到另外一台服务器，报这个错误，但是我的本机是正常的
           1
        
               
          我的版本从3.2升级到了4.5，如何强制重新刷新整个系统的缓存呢？
           1
        
               
          机构授权有计划研发？
           1
        
                     
      
      


扫一扫访问 Blade技术社区 移动端






  
    






      Blade技术社区 2025 © 上海布雷德科技有限公司    
            沪ICP备2023009528号-1  
            
              苏公网安备 32041102000998号 
  



    
        
            

                
                首页
            

        
            
            
                
                问答

            
        
        
         
            
                
                文章

            
        
        
        
            
                
                提问

            
        
       
             
        
            
                
                专家

            
        
       
        
                    
                         
               
                
                我的

	@Slf4j
	@Service
	@RequiredArgsConstructor
	public class ProductScriptServiceImpl implements IProductScriptService {


	private final RPubSubPublisher pubSubPublisher;


	@Override
	public void insertOrUpdate(ProductScriptEntity entity) {

	// 发送刷新事件
	pubSubPublisher.publish(IotCacheConstant.PRODUCT_SCRIPT_RELOAD, productKey);
	}


	/**
	* 更新产品脚本
	*/
	@RPubSubListener(IotCacheConstant.PRODUCT_SCRIPT_RELOAD)
	public void subReloadEvent(RPubSubEvent<String> event) {
	String productKey = event.getMsg();

	}

	}