package com.example.mina.config;

import com.example.mina.box1.Rbm3000VirtualBoxHander;
import com.example.mina.property.Rbm3000VitualBoxProperties;
import lombok.extern.slf4j.Slf4j;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;
import java.net.InetSocketAddress;

/**
 * @author 杜云山
 * @date 21/03/05
 */
@Slf4j
@Configuration(proxyBeanMethods = false)
public class Rbm3000VirtualBoxConfiguration {

    private final Rbm3000VitualBoxProperties rbm3000VitualBoxProperties;

    public Rbm3000VirtualBoxConfiguration(Rbm3000VitualBoxProperties rbm3000VitualBoxProperties) {
        this.rbm3000VitualBoxProperties = rbm3000VitualBoxProperties;
    }


    @PostConstruct
    public void init() {

        if (!rbm3000VitualBoxProperties.getEnable()) {
            log.info("Rbm3000Virtual服务端 配置未开启");
            return;
        }

        if (rbm3000VitualBoxProperties.getPort() == null) {
            log.info("Rbm3000Virtual服务端 端口未配置");
            return;
        }

        try {
            NioSocketAcceptor acceptor = new NioSocketAcceptor();
            acceptor.setHandler(new Rbm3000VirtualBoxHander());
            acceptor.setReuseAddress(true);
            acceptor.bind(new InetSocketAddress(rbm3000VitualBoxProperties.getPort()));
            log.info("Rbm3000Virtual服务端已经启动,监听端口: {}", rbm3000VitualBoxProperties.getPort());
        } catch (Exception e) {
            log.error("无法启动Rbm3000Virtual服务端, {}", e.getMessage(), e);
        }
    }

}