欧美成人午夜免费全部完,亚洲午夜福利精品久久,а√最新版在线天堂,另类亚洲综合区图片小说区,亚洲欧美日韩精品色xxx

千鋒扣丁學(xué)堂Java培訓(xùn)之redis發(fā)布訂閱Java代碼實(shí)現(xiàn)過(guò)程解析

2019-09-17 14:09:54 4742瀏覽

今天千鋒扣丁學(xué)堂Java培訓(xùn)老師給大家分享一篇關(guān)于redis發(fā)布訂閱Java代碼實(shí)現(xiàn)過(guò)程解析的詳細(xì)介紹，首先Redis除了可以用作緩存數(shù)據(jù)外，另一個(gè)重要用途是它實(shí)現(xiàn)了發(fā)布訂閱(pub/sub)消息通信模式：發(fā)送者(pub)發(fā)送消息，訂閱者(sub)接收消息。

為了實(shí)現(xiàn)redis的發(fā)布訂閱機(jī)制，首先要打開(kāi)redis服務(wù)；其次，引入redis需要的jar包，在pom.xml配置文件加入以下代碼：

<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.1.0</version>
</dependency>

由于訂閱消息通道需要再tomcat啟動(dòng)時(shí)觸發(fā)，因此，需要?jiǎng)?chuàng)建一個(gè)listener監(jiān)聽(tīng)器，在監(jiān)聽(tīng)器里實(shí)現(xiàn)redis訂閱，在web.xml里配置監(jiān)聽(tīng)器如下：

<listener>
<listener-class>com.test.listener.InitListener</listener-class>
</listener>

一、訂閱消息（InitListener實(shí)現(xiàn)）

redis支持多通道訂閱，一個(gè)客戶端可以同時(shí)訂閱多個(gè)消息通道，如下代碼所示，訂閱了13個(gè)通道。由于訂閱機(jī)制是線程阻塞的，需要額外開(kāi)啟一個(gè)線程專門(mén)用于處理訂閱消息及接收消息處理。

public class InitListener implements ServletContextListener{
  private Logger logger = Logger.getLogger(InitListener.class);  
  @Override
  public void contextInitialized(ServletContextEvent sce) {
    logger.info("啟動(dòng)tomcat");// 連接redis
    Map<String, String> proMap = PropertyReader.getProperties();
    final String url = proMap.get("redis.host");
    final Integer port = Integer.parseInt(proMap.get("redis.port"));
    final ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("classpath*:applicationContext.xml");
    final RedisSubListener redisSubListener = (RedisSubListener) classPathXmlApplicationContext.getBean("redisSubListener");
    // 為防止阻塞tomcat啟動(dòng)，開(kāi)啟線程執(zhí)行
    new Thread(new Runnable(){ 
      public void run(){ 
        // 連接redis,建立監(jiān)聽(tīng)
        Jedis jedis = null;
        while(true){
          //解碼資源更新通知,畫(huà)面選看回復(fù),畫(huà)面選看停止回復(fù),預(yù)案啟動(dòng),預(yù)案停止,輪切啟動(dòng),輪切停止,預(yù)案啟動(dòng)回復(fù),預(yù)案停止回復(fù),輪切啟動(dòng)回復(fù),輪切停止回復(fù),監(jiān)視屏分屏狀態(tài)通知,畫(huà)面狀態(tài)通知
          String[] channels = new String[] { "decodeResourceUpdateNtf", "tvSplitPlayRsp","tvSplitPlayStopRsp",
              "planStartStatusNtf", "planStopStatusNtf", "pollStartStatusNtf", "pollStopStatusNtf",
              "planStartRsp","planStopRsp","pollStartRsp","pollStopRsp","tvSplitTypeNtf","tvSplitStatusNtf"};
          try{
            jedis = new Jedis(url,port);
            logger.info("redis請(qǐng)求訂閱通道");
            jedis.subscribe(redisSubListener,channels);
            logger.info("redis訂閱結(jié)束");
          }catch(JedisConnectionException e){
            logger.error("Jedis連接異常,異常信息 :" + e);
          }catch(IllegalStateException e){
             logger.error("Jedis異常,異常信息 :" + e);
          }          
          try {
            Thread.sleep(1000);
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
          if(jedis != null){
            jedis = null;
          }
        }
      }})
    .start();
  }

最后在spring配置文件里接入以下配置：

<!-- redis -->
   <bean id="redisMessageService" class="com.test.service.impl.RedisMessageServiceImpl" scope="singleton">
     <property name="webSocketService"><ref local="webSocketService" /></property>
     <property name="tvSplitStatusDao" ref="tvSplitStatusDao"></property>
   </bean>
   <bean id="redisSubListener" class="com.test.common.RedisSubListener" scope="singleton">
     <property name="redisMessageService"><ref local="redisMessageService" /></property>
   </bean>

RedisMessageServiceImpl用于處理接收的redis消息。

二、發(fā)布消息

public class RedisPublishUtil {
  private Logger logger = Logger.getLogger(RedisPublishUtil.class);
  public static Jedis pubJedis;
  private static Map<String, String> proMap = PropertyReader.getProperties();
  private static final String redisPort = proMap.get("redis.port");
  private static String url = proMap.get("redis.host");
  private static final int port = Integer.parseInt(redisPort);
   
  public void setPubJedis(Jedis jedis) {
    RedisPublishUtil.pubJedis = jedis;
  }
   
  public Jedis getPubJedis() {
    if (pubJedis == null) {
      createJedisConnect();
    }
    // 返回對(duì)象
    return pubJedis;
  }
   
  public Jedis createJedisConnect(){
    // 連接redis
    logger.info("===創(chuàng)建連接jedis=====");
    try {
      pubJedis = new Jedis(url, port);
    } catch (JedisConnectionException e) {
      logger.error("Jedis連接異常,異常信息 :" + e.getMessage());
      try {
        Thread.sleep(1000);
        logger.info("發(fā)起重新連接jedis");
        createJedisConnect();
      } catch (InterruptedException except) {
        except.printStackTrace();
      }
    }
    // 返回對(duì)象
    return pubJedis;
  }
  //公共發(fā)布接口
  public void pubRedisMsg(String msgType,String msg){
    logger.info("redis準(zhǔn)備發(fā)布消息內(nèi)容：" + msg);
    try {
      this.getPubJedis().publish(msgType, msg);
 
    } catch (JedisConnectionException e) {
      logger.error("redis發(fā)布消息失敗！", e);
      this.setPubJedis(null);
      logger.info("重新發(fā)布消息，channel="+msgType);
      pubRedisMsg(msgType, msg);
    }
  }
}

public class PropertyReader {
 
   private static Logger logger = Logger.getLogger(PropertyReader.class);
   
  /*
   * 獲得數(shù)據(jù)庫(kù)鏈接的配置文件
   */
  public static Map<String,String> getProperties(){
    logger.info("讀取redis配置文件開(kāi)始。。。");
     
     Properties prop = new Properties();   
     
     Map<String,String> proMap = new HashMap<String,String>();
      
    try {
       //讀取屬性文件redis.properties
      InputStream in= PropertyReader.class.getClassLoader().getResourceAsStream("redis.properties"); 
       
      prop.load(in);   ///加載屬性列表
      Iterator<String> it=prop.stringPropertyNames().iterator();
      while(it.hasNext()){
        String key=it.next();
        proMap.put(key, prop.getProperty(key));
      }
      in.close();
      logger.info("讀取redis配置文件成功。。。");
    } catch (Exception e) {
      logger.error("讀取redis配置文件異常！", e);
      e.printStackTrace();
    }
    return proMap;
  }
}

以上就是關(guān)于千鋒扣丁學(xué)堂Java培訓(xùn)之redis發(fā)布訂閱Java代碼實(shí)現(xiàn)過(guò)程解析的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，想了解更多關(guān)于Java開(kāi)發(fā)方面內(nèi)容的小伙伴，請(qǐng)關(guān)注扣丁學(xué)堂Java培訓(xùn)官網(wǎng)、微信等平臺(tái)，扣丁學(xué)堂IT職業(yè)在線學(xué)習(xí)教育有專業(yè)的Java講師為您指導(dǎo)，此外扣丁學(xué)堂老師精心推出的Java視頻教程定能讓你快速掌握J(rèn)ava從入門(mén)到精通開(kāi)發(fā)實(shí)戰(zhàn)技能。扣丁學(xué)堂Java技術(shù)交流群：850353792。

                          

     【關(guān)注微信公眾號(hào)獲取更多學(xué)習(xí)資料】        【掃碼進(jìn)入JavaEE/微服務(wù)VIP免費(fèi)公開(kāi)課】  

查看更多關(guān)于“Java開(kāi)發(fā)資訊”的相關(guān)文章>>