package com.mes.job;
|
|
|
import com.mes.glassinfo.service.GlassInfoService;
|
import lombok.SneakyThrows;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.net.InetSocketAddress;
|
import java.net.Socket;
|
|
public class BarcodeReadThread extends Thread{
|
|
public BarcodeReadThread(String ip,Integer port,Downpush downpush)
|
{
|
this.ip=ip;
|
this.port=port;
|
this.downpush=downpush;
|
}
|
private Socket socket;
|
private String ip;
|
private Integer port;
|
private Downpush downpush;
|
private BufferedReader in;
|
|
@SneakyThrows
|
@Override
|
public void run()
|
{
|
connectCheckin();//初次 循环尝试连接，直到连接成功
|
while (this!=null)
|
{
|
try
|
{
|
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
|
String response = in.readLine();
|
if(response!=null)
|
{
|
downpush.barcodeCheckin(response);
|
}
|
}
|
catch (Exception exception)
|
{
|
//异常，重连
|
connectCheckin();
|
}
|
finally {
|
if(in!=null)
|
{
|
in.close();
|
}
|
}
|
|
Thread.sleep(100);
|
}
|
}
|
|
@SneakyThrows
|
private void connectCheckin()
|
{
|
while (this!=null)
|
{
|
try
|
{
|
socket=new Socket();
|
socket.setSoTimeout(10000);
|
socket.connect(new InetSocketAddress(ip,port));
|
if(socket.isConnected())
|
{
|
return;
|
}
|
}
|
catch (Exception exception)
|
{
|
|
}
|
|
Thread.sleep(1000);
|
}
|
}
|
}
|
