redis实现发布订阅

代码应用：

jedisclent类中的方法

long Publish(String EventCode,String paramJson);

实现类中的方法：

ProdDto s = prodDtoMapper.prodList(b.getBusinessid());
HashMap<String, Object> dataInfo = new HashMap<String, Object>();
HashMap<String, Object> data = new HashMap<String, Object>();
HashMap<String, Object> ddata = new HashMap<String, Object>();
HashMap<String, Object> dddata = new HashMap<String, Object>();
dataInfo.put("RISK_INFO", s);
data.put("ORG_CODE", s.getORG_CODE());
data.put("SALEAREA", s.getSALEAREA());
ddata.put("SALABLE_ORG_LIST", data);
dddata.put(s.getSALABLE_ORG_LIST(), ddata);
mqBaseDto.setData(dataInfo);
mqBaseDto.setTransTime(DatetimeUtils.nowString());
JSONObject mqBasejson = JSONObject.fromObject(mqBaseDto);
long a = jedisClient.Publish("prodList", mqBasejson.toString());

cmd中 要启动监听：

 subscribe  prodList

subscribe 是命令

prodlist 是调用publish方法中的key值