package com.tianbo.analysis.model;

import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Consumer;
import com.tianbo.analysis.service.rabbit.RabbitGetMessage;
import com.tianbo.util.RabitMq.ConnectionUtil;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

@Slf4j
public class RabbitMQ {

    public static String status = "not runing";

    private String queueName;

    private String exchangeName;

    private String routingKey;

    private  String mqIp;

    private  int mqPort;

    private  String mqVhost;

    private  String mqUsername;

    private  String mqPassword;

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public String getExchangeName() {
        return exchangeName;
    }

    public void setExchangeName(String exchangeName) {
        this.exchangeName = exchangeName;
    }

    public String getRoutingKey() {
        return routingKey;
    }

    public void setRoutingKey(String routingKey) {
        this.routingKey = routingKey;
    }

    public String getMqIp() {
        return mqIp;
    }

    public void setMqIp(String mqIp) {
        this.mqIp = mqIp;
    }

    public int getMqPort() {
        return mqPort;
    }

    public void setMqPort(int mqPort) {
        this.mqPort = mqPort;
    }

    public String getMqVhost() {
        return mqVhost;
    }

    public void setMqVhost(String mqVhost) {
        this.mqVhost = mqVhost;
    }

    public String getMqUsername() {
        return mqUsername;
    }

    public void setMqUsername(String mqUsername) {
        this.mqUsername = mqUsername;
    }

    public String getMqPassword() {
        return mqPassword;
    }

    public void setMqPassword(String mqPassword) {
        this.mqPassword = mqPassword;
    }

    public RabbitMQ(String mqIp, int mqPort, String mqVhost, String mqUsername, String mqPassword,String queueName) {
        this.mqIp = mqIp;
        this.mqPort = mqPort;
        this.mqVhost = mqVhost;
        this.mqUsername = mqUsername;
        this.mqPassword = mqPassword;
        this.queueName = queueName;
    }

    public void getResponseFromMq() {
        try {
            // 获取到连接以及mq通道
            Connection connection = ConnectionUtil.getConnection(
                    mqIp,
                    mqPort,
                    mqVhost,
                    mqUsername,
                    mqPassword);
            // 从连接中创建通道
            Channel channel = connection.createChannel();
            // 声明（创建）队列
//            channel.exchangeDeclare(exchangeName, BuiltinExchangeType.TOPIC,true);
//            channel.queueDeclare(queueName, true, false, false, null);
            channel.queueBind(queueName,exchangeName,routingKey);
            channel.basicQos(10);
            channel.basicConsume(queueName, false, new RabbitGetMessage(channel));
            status = "runing";
        }catch (IOException e){
            status = "not runing";
            e.printStackTrace();
            log.error("MQ服务器连接失败,连接不上服务器:{},异常退出",e.toString());
        }catch (TimeoutException e){
            status = "not runing";
            e.printStackTrace();
            log.error("MQ服务器连接失败,连接超时:{}，异常退出",e.toString());
        }
    }
}