Приложение Spring Boot не создает файл .jar

Question

Я работаю над загрузочным приложением Spring, которое создает TCP-сервер, реализованный с использованием Netty.Я создал приложение и протестировал его, и все работает нормально.

Проблема в том, что когда я хочу создать jar из источника, jar не создается. Сервер TCP запускается и отвечает на запросы клиентов, но jarне создается в целевой папке.

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication(scanBasePackages={"some.package"})
public class OtpServiceApplication implements ApplicationRunner
{
    @Autowired
    TcpServer tcpServer;

    @Override
    public void run(ApplicationArguments args) throws Exception
    {
        tcpServer.start();
    }

    public static void main(String[] args)
    {
        SpringApplication.run(OtpServiceApplication.class, args);
    }
}

Однако, когда я удаляю связанный с TCP код, jar создается успешно.

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication(scanBasePackages={"some.package"})
public class OtpServiceApplication 
{
//    @Autowired
//    TcpServer tcpServer;
//
//    @Override
//    public void run(ApplicationArguments args) throws Exception
//    {
//        tcpServer.start();
//    }

    public static void main(String[] args)
    {
        SpringApplication.run(OtpServiceApplication.class, args);
    }
}

Поэтому я предполагаю, что этоне проблема с моим POM-файлом или кодом, но это проблема в этом классе.Может кто-нибудь указать, как решить эту проблему?

Это мой класс TcpServer.

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.timeout.IdleStateHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Slf4j
@Service
public class TcpServer {

    @Autowired
    XmlProcessor xmlProcessor;

    @Autowired
    IdleSocketHandler idleSocketHandler;

    @Value("${request.timeout:5000}")
    String requestTimeout;

    @Value("${response.timeout:2000}")
    String responseTimeout;

    @Value("${message-listener.port}")
    String xmlListenerPort;

    @Value("${message-listener.ip}")
    String xmlListenerIp;

    private NioEventLoopGroup connectionAcceptorThreadGroup;
    private NioEventLoopGroup connectionProcessorThreadGroup;
    private ChannelFuture serverSocketFuture;

    @Async
    public void start() throws InterruptedException {

        log.info("Starting XML Listener on [{}:{}]", xmlListenerIp, xmlListenerPort);

        this.connectionAcceptorThreadGroup = new NioEventLoopGroup();
        this.connectionProcessorThreadGroup = new NioEventLoopGroup();

        final int resTimeout = Integer.valueOf(responseTimeout);

        final int reqTimeout = Math.min(Integer.valueOf(requestTimeout), (int) (resTimeout * 1.8));

        try {
            ServerBootstrap b = new ServerBootstrap();

            b.group(connectionAcceptorThreadGroup, connectionProcessorThreadGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) {
                            ch.pipeline().addLast("requestHandler", xmlProcessor);
                            ch.pipeline().addLast("idleStateHandler",
                                    new IdleStateHandler(reqTimeout, resTimeout, 0, TimeUnit.MILLISECONDS));
                            ch.pipeline().addLast("idleSocketHandler", idleSocketHandler);
                        }
                    })
                    .option(ChannelOption.SO_BACKLOG, 128)
                    .option(ChannelOption.SO_REUSEADDR,true)
                    .childOption(ChannelOption.SO_KEEPALIVE, true);

            serverSocketFuture = b.bind(xmlListenerIp, Integer.valueOf(xmlListenerPort)).sync();
            log.info("Server listening for transactions on {}:{}", xmlListenerIp, xmlListenerPort);
            serverSocketFuture.channel().closeFuture().sync();
        } finally {
            connectionProcessorThreadGroup.shutdownGracefully();
            connectionAcceptorThreadGroup.shutdownGracefully();
        }
    }
}

Answer 1

Вместо Autowiring получите контекст приложения, чтобы бин создавался следующим образом

ConfigurableApplicationContext applicationContext = 
SpringApplication.run(OtpServiceApplication.class, args);

TcpSrever tcpServer = applicationContext.getBean(TcpServer.class);

tcpServer.run()

Answer 2

Вы не можете использовать Autowire ниже класса, потому что перед автоматическим подключением любого класса он должен быть частью тех классов, которые следуют концепции стереотипа, поэтому создайте другой класс с @Component, @Servive ... и т. Д. В соответствии с вашей логикой, а затем выполните автоматическое подключение внутри этого класса..

    @Autowired
    TcpServer tcpServer;

Можете ли вы попытаться навязать этот класс где-нибудь еще, кроме основного, и попытаться создать банку.