使用@Async多线程处理sip消息

648540858

2021-11-17 80bfd9ce026e67dd2eb86c519b5b1b70e3cc7d12

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java

@@ -36,9 +36,9 @@
    @Autowired
    private SipSubscribe sipSubscribe;

    @Autowired
    @Qualifier(value = "taskExecutor")
    private ThreadPoolTaskExecutor poolTaskExecutor;
//    @Autowired
//    @Qualifier(value = "taskExecutor")
//    private ThreadPoolTaskExecutor poolTaskExecutor;

    /**
     * 添加 request订阅
@@ -71,9 +71,8 @@
     * @param requestEvent RequestEvent事件
     */
    @Override
    @Async
    public void processRequest(RequestEvent requestEvent) {

        poolTaskExecutor.execute(() -> {
            String method = requestEvent.getRequest().getMethod();
            ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method);
            if (sipRequestProcessor == null) {
@@ -81,7 +80,6 @@
                return;
            }
            requestProcessorMap.get(method).process(requestEvent);
        });

    }

@@ -90,18 +88,9 @@
     * @param responseEvent responseEvent事件
     */
    @Override
    @Async
    public void processResponse(ResponseEvent responseEvent) {
        logger.debug(responseEvent.getResponse().toString());
//        CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
//        String method = cseqHeader.getMethod();
//        ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
//        if (sipRequestProcessor == null) {
//            logger.warn("不支持方法{}的response", method);
//            return;
//        }
//        sipRequestProcessor.process(responseEvent);

        poolTaskExecutor.execute(() -> {
            Response response = responseEvent.getResponse();
            logger.debug(responseEvent.getResponse().toString());
            int status = response.getStatusCode();
@@ -138,7 +127,6 @@
                    }
                }
            }
        });


    }