package com.tianbo.analysis.service.rabbit;

import com.rabbitmq.client.*;
import com.tianbo.analysis.handle.CustomResponseHandleThread;
import com.tianbo.analysis.task.XMLThreadPoolFactory;
import com.tianbo.util.RabitMq.MqResponse;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadPoolExecutor;

@Slf4j
public class RabbitGetMessage extends DefaultConsumer {

    private Channel ackChannel;
    /**
     * 初始化线程池
     */
    private static ThreadPoolExecutor threadPool = XMLThreadPoolFactory.instance();

    public RabbitGetMessage(Channel channel) {
        super(channel);
        this.ackChannel= channel;
    }


    @Override
    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
        String message = new String(body, StandardCharsets.UTF_8);
        log.info("消费状态:consumerTag->{},envelope->{},properties->{},body->{}",consumerTag,envelope,properties,message);
        ackChannel.basicAck(envelope.getDeliveryTag(),false);
        //过滤报文头部
//        message = message.replace("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"yes\"?>","");
        //todo：多线程处理消息
        handleMessage(message);

    }

    private void handleMessage(String message){
        CustomResponseHandleThread customResponseHandleThread = new CustomResponseHandleThread();
        customResponseHandleThread.setResponseMessage(message);
        try{
            threadPool.execute(customResponseHandleThread);
        }catch (RejectedExecutionException e){
            e.printStackTrace();
            log.error("线程池已满");
        }catch (Exception e){
            e.printStackTrace();
            log.error("线程池异常");
        }
    }

}