事件通知

使用工具类统一管理

/**
 * Redis发布工具类
 */
@Slf4j
@Component
@RequiredArgsConstructor
public class RedisPubUtil {
    private final RedisTemplate<String, String> redisTemplate;

    /**
     * 刷新本地缓存
     */
    public void ServerFlush() {
        redisTemplate.convertAndSend("service-launched", "来自网关中心的刷新本地缓存请求");
    }

    /**
     * 发送心跳请求
     */
    public void heartBeat() {
        redisTemplate.convertAndSend("heartBeat", "来自网关中心的心跳请求");
    }
}