1: 参考链接   

https://open.dingtalk.com/document/orgapp/develop-stream-mode-push-server

2：钉钉开放平台订阅配置

配置之后运行一下上面提供的链接 里面的main方法，验证通道

3：订阅启动方式

EventListenerThread eventListenerThread = application.getBean(EventListenerThread.class); // 启动EventListenerThread eventListenerThread.start();

@Override public void run() {     OpenDingTalkStreamClientBuilder                                  .custom()                                  .credential(new AuthClientCredential(appKey, appSecret))                                  //注册事件监听                       .registerAllEventListener(new GenericEventListener() {                           public EventAckStatus onEvent(GenericOpenDingTalkEvent event) {                              try {                                  //事件唯一Id                                  String eventId = event.getEventId();                                  //事件类型                                  String eventType = event.getEventType();                                  //事件产生时间                                   Long bornTime = event.getEventBornTime();                                   //获取事件体                                  JSONObject bizData = event.getData();                                   log.info("当前时间"+ TimeUtils.date2Str(new Date()));                                  // Create InputStream from byte array                                  log.info("进入事件订阅:eventId "+eventId+"eventType"+eventType+"bornTime"+bornTime);                                   //处理事件                                   evetTypeEvent(eventId,eventType,bornTime,bizData);                                   //消费成功                                  return EventAckStatus.SUCCESS;                               } catch (Exception e) {                                  //消费失败                                 return EventAckStatus.LATER;                              }                          }                       })                                 .build().start(); }