package cn.stylefeng.guns.modular.WebSocket;

import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

//@Component
public class TcpTest implements ApplicationRunner {

    public void run(ApplicationArguments args) throws Exception {
        //采用TelnetClient方式链接
//        TelnetClient tcpNet = new TelnetClient();
        //采用Socket方式链接
        Socket tcpNet = new Socket();
        try {
//            tcp访问地址和端口
            //采用TelnetClient方式链接
//            tcpNet.connect("127.0.0.1", 30311);
//            InputStream inputStream = tcpNet.getInputStream();
            //采用Socket方式链接
            tcpNet = new Socket("192.168.0.235", 60000);
            InputStream inputStream = tcpNet.getInputStream();
            byte[] b = new byte[1024];
            int size;
            while (true) {
                System.out.println("----------获取TCP信息开始----------");
                size = inputStream.read(b);
                String aa = new String(b, 0, size);
                System.out.println("tcp获取字符长度:" + size);
                System.out.println("tcp获取的条码：" + aa);
                //建立客户端信息输出流（客户端向服务端发送信息）
                OutputStream pt = tcpNet.getOutputStream();
                String printText = "客户端已成功接收信息！";
                pt.write(printText.getBytes());
                if(size>7){
                    WebSocketService.sendMessage("badao",aa);
                }else {
                    WebSocketService.sendMessage("badao2",aa);
                }
            }

        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("++++++故障重新访问++++");
            //断开tcp后自动重新链接
            //断开后两秒后重新链接tcp  Socket方式
            tcpNet.connect(tcpNet.getRemoteSocketAddress(), 2000);
            //断开后重新链接tcp  TelnetClient方式
            //tcpNet.disconnect();
        }
    }


}