Spring Boot项目配置Genesys PSDK的AsyncInvoker实现事件监听求助

你已经创建的MessageHandler无法正常接收事件，核心原因是未给PSDK协议层绑定异步调用器，事件分发链路未打通，可按以下步骤完成配置：

1. 配置Spring Boot内置线程池 #

先在配置类中声明可复用的线程池Bean，用于承载PSDK的事件调度任务：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;

@Configuration
public class PSDKConfig {
    @Bean("psdkTaskExecutor")
    public Executor psdkTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心线程数可根据实际事件并发量调整
        executor.setCorePoolSize(4);
        executor.setMaxPoolSize(8);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("psdk-event-");
        executor.initialize();
        return executor;
    }
}

2. 实现PSDK AsyncInvoker接口 #

自定义调用器实现类，将Spring线程池注入，对接PSDK的事件调度逻辑：

import com.genesyslab.platform.commons.protocol.AsyncInvoker;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
import java.util.concurrent.Executor;

@Component
public class SpringPSDKAsyncInvoker implements AsyncInvoker {
    private final Executor psdkExecutor;

    @Autowired
    public SpringPSDKAsyncInvoker(@Qualifier("psdkTaskExecutor") Executor psdkExecutor) {
        this.psdkExecutor = psdkExecutor;
    }

    @Override
    public void invoke(Runnable runnable) {
        // 直接将PSDK的事件处理任务交给Spring线程池执行
        psdkExecutor.execute(runnable);
    }
}

3. 绑定调用器到TServer协议实例 #

在你初始化TServer连接的逻辑中，注册调用器和MessageHandler后再启动连接：

import com.genesyslab.platform.openmedia.protocol.tserver.TServerProtocol;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

@Component
public class TServerClient {
    @Autowired
    private SpringPSDKAsyncInvoker asyncInvoker;
    @Autowired
    private YourCustomMessageHandler messageHandler; // 你自己实现的MessageHandler
    private TServerProtocol tServerProtocol;

    @PostConstruct
    public void initTServerConnection() {
        // 此处省略TServer协议的基础配置（端点、用户名、密码等）初始化逻辑
        tServerProtocol = new TServerProtocol(...);
        // 绑定异步调用器
        tServerProtocol.setInvoker(asyncInvoker);
        // 注册消息处理器
        tServerProtocol.addListener(messageHandler);
        // 启动连接
        try {
            tServerProtocol.open();
        } catch (Exception e) {
            // 连接异常处理逻辑
            e.printStackTrace();
        }
    }
}

重要提示：您需要知晓事件处理逻辑将通过协议调用器执行，请结合应用的实际需求配置合适的调用器。

配置注意事项 #

• 若需要保证事件消费的顺序性，可将psdkTaskExecutor的核心线程数设置为1，避免多线程消费打乱事件先后顺序
• MessageHandler内部的业务逻辑需要自行捕获异常，避免未处理的异常打断线程池的任务调度
• 线程池的大小、队列容量参数需要根据业务峰值的事件吞吐量调整，避免事件丢弃或资源耗尽

内容的提问来源于stack exchange，提问作者Shrijan Tiwari