package com.dy.pmsTest; 
 | 
  
 | 
import com.dy.pmsTest.tcpClient.TcpClUnit; 
 | 
import com.dy.pmsTest.tcpClient.TcpClUnitConfigVo; 
 | 
import org.springframework.boot.CommandLineRunner; 
 | 
import org.springframework.boot.SpringApplication; 
 | 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
 | 
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; 
 | 
import org.springframework.context.annotation.ComponentScan; 
 | 
import org.springframework.context.annotation.FilterType; 
 | 
  
 | 
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class}) //禁止启动数据库连接池 
 | 
@ComponentScan(basePackages = {"com.dy.common", "com.dy.pmsGlobal", "com.dy.pmsTest"}, 
 | 
        excludeFilters = { 
 | 
                @ComponentScan.Filter(type = FilterType.REGEX, pattern = { 
 | 
                        //以下写正则表达式,需要对目标类的完全限定名完全匹配,否则不生效 
 | 
                        "com.dy.common.aop..*", 
 | 
                        "com.dy.common.dataSource..*", 
 | 
                        "com.dy.common.mybatis..*", 
 | 
                        "com.dy.common.webFilter..*", 
 | 
                        "com.dy.common.webListener..*", 
 | 
                        "com.dy.pmsGlobal..*" 
 | 
                }) 
 | 
        } 
 | 
) 
 | 
public class PmsTestApplication implements CommandLineRunner { 
 | 
  
 | 
    public static void main(String[] args) { 
 | 
        SpringApplication.run(PmsTestApplication.class, args); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * Spring容器启动完成后,执行下面方法 
 | 
     * @param args 参数 
 | 
     * @throws Exception 异常 
 | 
     */ 
 | 
    @Override 
 | 
    public void run(String... args) throws Exception { 
 | 
        try{ 
 | 
            //等待数据库初始化完成 
 | 
            Thread.sleep(1000L); 
 | 
        }catch (Exception e){ 
 | 
            e.printStackTrace(); 
 | 
        } 
 | 
        finally { 
 | 
            this.start() ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    private void start(){ 
 | 
        try { 
 | 
            // /////////////// 
 | 
            // TCP 模块 
 | 
            TcpClUnitConfigVo tcpVo = new TcpClUnitConfigVo(); 
 | 
            tcpVo.mwServerIp = "127.0.0.1"; 
 | 
            tcpVo.mwServerPort = 65533; 
 | 
            tcpVo.connectTimeout = 1000; 
 | 
            AdapterImp_TcpClUnit tcpAdap = new AdapterImp_TcpClUnit(); 
 | 
            tcpAdap.setConfig(tcpVo); 
 | 
            TcpClUnit tcpUnit = TcpClUnit.getInstance(); 
 | 
            tcpUnit.setAdapter(tcpAdap); 
 | 
            tcpUnit.start((obj) -> { 
 | 
            }); 
 | 
        }catch (Exception e){ 
 | 
            e.printStackTrace(); 
 | 
        } 
 | 
    } 
 | 
} 
 |