spring boot 实现 Stream 钉钉事件订阅
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 {//事件唯一IdString 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 arraylog.info("进入事件订阅:eventId "+eventId+"eventType"+eventType+"bornTime"+bornTime);//处理事件evetTypeEvent(eventId,eventType,bornTime,bizData);//消费成功return EventAckStatus.SUCCESS;} catch (Exception e) {//消费失败return EventAckStatus.LATER;}}}).build().start();
}