Redis除了可以用作緩存數(shù)據(jù)外，另一個(gè)重要用途是它實(shí)現(xiàn)了發(fā)布訂閱(pub/sub)消息通信模式：發(fā)送者(pub)發(fā)送消息，訂閱者(sub)接收消息诬留。
為了實(shí)現(xiàn)redis的發(fā)布訂閱機(jī)制缨睡，首先要打開redis服務(wù)；其次徘铝，引入redis需要的jar包耳胎，在pom.xml配置文件加入以下代碼：
redis.clients
jedis
2.1.0
由于訂閱消息通道需要再tomcat啟動(dòng)時(shí)觸發(fā)，因此惕它，需要?jiǎng)?chuàng)建一個(gè)listener監(jiān)聽器怕午，在監(jiān)聽器里實(shí)現(xiàn)redis訂閱，在web.xml里配置監(jiān)聽器如下：
com.test.listener.InitListener
一淹魄、訂閱消息（InitListener實(shí)現(xiàn)）
redis支持多通道訂閱郁惜，一個(gè)客戶端可以同時(shí)訂閱多個(gè)消息通道，如下代碼所示甲锡，訂閱了13個(gè)通道兆蕉。由于訂閱機(jī)制是線程阻塞的，需要額外開啟一個(gè)線程專門用于處理訂閱消息及接收消息處理缤沦。
publicclassInitListenerimplements ServletContextListener{
? ? privateLogger logger = Logger.getLogger(InitListener.class);
? ? @Override
? ? publicvoid contextInitialized(ServletContextEvent sce) {
? ? ? ? logger.info("啟動(dòng)tomcat");// 連接redisMap proMap = PropertyReader.getProperties();
? ? ? ? finalString url = proMap.get("redis.host");
? ? ? ? finalInteger port = Integer.parseInt(proMap.get("redis.port"));finalClassPathXmlApplicationContext classPathXmlApplicationContext =newClassPathXmlApplicationContext("classpath*:applicationContext.xml");
? ? ? ? finalRedisSubListener redisSubListener = (RedisSubListener) classPathXmlApplicationContext.getBean("redisSubListener");
? ? ? ? // 為防止阻塞tomcat啟動(dòng)虎韵，開啟線程執(zhí)行newThread(new Runnable(){?
? ? ? ? ? ? publicvoid run(){?
? ? ? ? ? ? ? ? // 連接redis,建立監(jiān)聽Jedis jedis =null;
? ? ? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? ? ? //解碼資源更新通知,畫面選看回復(fù),畫面選看停止回復(fù),預(yù)案啟動(dòng),預(yù)案停止,輪切啟動(dòng),輪切停止,預(yù)案啟動(dòng)回復(fù),預(yù)案停止回復(fù),輪切啟動(dòng)回復(fù),輪切停止回復(fù),監(jiān)視屏分屏狀態(tài)通知,畫面狀態(tài)通知String[] channels =newString[] { "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配置文件里接入以下配置：
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?
RedisMessageServiceImpl用于處理接收的redis消息。
二缸废、發(fā)布消息
publicclass RedisPublishUtil {
? ? privateLogger logger = Logger.getLogger(RedisPublishUtil.class);
? ? publicstatic Jedis pubJedis;
? ? privatestaticMap proMap = PropertyReader.getProperties();
? ? privatestaticfinalString redisPort = proMap.get("redis.port");
? ? privatestaticString url = proMap.get("redis.host");
? ? privatestaticfinalintport = Integer.parseInt(redisPort);
? ? publicvoid setPubJedis(Jedis jedis) {
? ? ? ? RedisPublishUtil.pubJedis = jedis;
? ? }public Jedis getPubJedis() {
? ? ? ? if(pubJedis ==null) {
? ? ? ? ? ? createJedisConnect();
? ? ? ? }
? ? ? ? // 返回對(duì)象return pubJedis;
? ? }
? ? public Jedis createJedisConnect(){
? ? ? ? // 連接redislogger.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ā)布接口
? ? publicvoid 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);
? ? ? ? }
? ? }
}
publicclass PropertyReader {
? ? privatestaticLogger logger = Logger.getLogger(PropertyReader.class);
? ? /*? ? * 獲得數(shù)據(jù)庫鏈接的配置文件
? ? */publicstaticMap getProperties(){
? ? ? ? logger.info("讀取redis配置文件開始测萎。。梁钾。");
? ? ? ? Properties prop =new Properties();? ?
? ? ? ? Map proMap? =newHashMap();
? ? ? ? try {
? ? ? ? ? ? //讀取屬性文件redis.propertiesInputStream in= PropertyReader.class.getClassLoader().getResourceAsStream("redis.properties");?
? ? ? ? ? ? prop.load(in);? ? ///加載屬性列表Iterator 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;
? ? } ? ? ? ? ? ? ? ? ? ? ??歡迎工作一到五年的Java工程師朋友們加入Java群：?741514154
群內(nèi)提供免費(fèi)的Java架構(gòu)學(xué)習(xí)資料（里面有高可用冒嫡、高并發(fā)、高性能及分布式四苇、Jvm性能調(diào)優(yōu)孝凌、Spring源碼，MyBatis月腋，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多個(gè)知識(shí)點(diǎn)的架構(gòu)資料）合理利用自己每一分每一秒的時(shí)間來學(xué)習(xí)提升自己蟀架，不要再用"沒有時(shí)間“來掩飾自己思想上的懶惰！趁年輕榆骚，使勁拼片拍，給未來的自己一個(gè)交代！
