使用方式

使用spring扫描实例, 实现PipelineProcess接口，指定泛型为ChatMessagePipelineModel。

目前只有调用sendChatMessageStream才会触发相应聊天事件。

@Slf4j
@Component
public class ChatInterceptor implements PipelineProcess<ChatMessagePipelineModel> {

    /**
     * 处理
     *
     * @param context 内容
     */
    @Override
    public void process(PipelineContext<ChatMessagePipelineModel> context) {
        log.debug("ChatInterceptor context:{}", context);
    }
}

自定义过滤

重写support方法，实现自定义过滤逻辑


@Slf4j
@Component
public class ChatInterceptor implements PipelineProcess<ChatMessagePipelineModel> {

    /**
     * 是否支持
     *
     * @param context 内容
     * @return 是否支持 true 支持 false 不支持
     */
    @Override
    public boolean support(PipelineContext<ChatMessagePipelineModel> context) {
        return "message_end".equals(context.getModel().getEvent());
    }

    /**
     * 处理
     *
     * @param context 内容
     */
    @Override
    public void process(PipelineContext<ChatMessagePipelineModel> context) {
        log.debug("ChatInterceptor context:{}", context);
    }
}

自定义执行顺序

重写order方法，返回排序值。越小越先执行。


@Slf4j
@Component
public class ChatInterceptor implements PipelineProcess<ChatMessagePipelineModel> {

    /**
     * 获取排序，越小越靠前
     *
     * @return 排序
     */
    @Override
    public Long order() {
        return 233L;
    }

    /**
     * 是否支持
     *
     * @param context 内容
     * @return 是否支持 true 支持 false 不支持
     */
    @Override
    public boolean support(PipelineContext<ChatMessagePipelineModel> context) {
        return "message_end".equals(context.getModel().getEvent());
    }

    /**
     * 处理
     *
     * @param context 内容
     */
    @Override
    public void process(PipelineContext<ChatMessagePipelineModel> context) {
        log.debug("ChatInterceptor context:{}", context);
    }
}