开发者社区> 问答> 正文

钉钉开发stream模式推送服务端为什么一时推送成功一时不行?

钉钉开发stream模式推送服务端为什么一时推送成功一时不行?
代码:

import com.dingtalk.open.app.api.KeepAliveOption;
import com.dingtalk.open.app.api.OpenDingTalkClient;
import com.dingtalk.open.app.api.OpenDingTalkStreamClientBuilder;
import com.dingtalk.open.app.api.security.AuthClientCredential;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class EventListener {

    @Value("${dingtalk.app.client-id}")
    private String clientId;

    @Value("${dingtalk.app.client-secret}")
    private String clientSecret;

    @Bean(initMethod = "start")
    public OpenDingTalkClient configure(EventConsumer eventConsumer) {
        // 创建一个自定义的 KeepAliveOption 对象
        KeepAliveOption keepAliveOption = KeepAliveOption.create()
                .withKeepAliveIdleMill(60000L); // 设置心跳间隔为 60 秒

        // 构建 OpenDingTalkClient
        return OpenDingTalkStreamClientBuilder.custom()
                .credential(new AuthClientCredential(clientId, clientSecret))
                .registerAllEventListener(eventConsumer)
                .keepAlive(keepAliveOption)
                .maxConnectionCounts(2) // 增加最大连接数
                .connectTimeout(5000) // 增加连接超时时间
                .build();
    }
}

image.png

根据代码log.info("收到事件: {}", event);查看日志可知接收的消息一会儿有一会儿没有,甚至应该进来两条但实际只进来一条

展开
收起
游客j6bcvosoa5scu 2024-10-10 12:02:45 84 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
钉钉小程序——为工作方式插上翅膀 立即下载
钉钉客户端自动化的应用 立即下载
使命必达 —— 钉钉企业级 消息服务的机遇与挑战 立即下载