package com.zy.core.thread;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.core.common.Cools;
|
import com.core.common.DateUtils;
|
import com.zy.core.News;
|
import com.zy.core.Slave;
|
import com.zy.core.ThreadHandler;
|
import com.zy.core.cache.OutputQueue;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.io.DataInputStream;
|
import java.io.DataOutputStream;
|
import java.io.IOException;
|
import java.net.InetSocketAddress;
|
import java.net.Socket;
|
import java.net.SocketAddress;
|
import java.net.SocketTimeoutException;
|
import java.util.Date;
|
|
/**
|
* 条码扫描仪线程
|
* Created by vincent on 2020/8/4
|
*/
|
@Data
|
@Slf4j
|
public class BarcodeThread implements Runnable, ThreadHandler {
|
|
private Slave slave;
|
private StringBuffer barcode = new StringBuffer();
|
private Socket socket;
|
private DataOutputStream dataOutputStream;
|
private DataInputStream dataInputStream;
|
public Integer connCount = 0;
|
|
public BarcodeThread(Slave slave) {
|
this.slave = slave;
|
}
|
|
public String getBarcode() {
|
return barcode.toString();
|
}
|
|
public void setBarcode(String barcode) {
|
this.barcode.delete(0, this.barcode.length());
|
this.barcode.append(barcode);
|
if(!Cools.isEmpty(barcode)) {
|
News.info("{}号条码器，检索数据：{}", slave.getId(), this.barcode);
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("time", DateUtils.convert(new Date(), DateUtils.yyyyMMddHHmmss_F));
|
jsonObject.put("barcode", barcode);
|
if (OutputQueue.BARCODE.size() >= 32) {
|
OutputQueue.BARCODE.poll();
|
}
|
OutputQueue.BARCODE.offer(jsonObject);
|
}
|
}
|
|
@Override
|
public boolean connect() {
|
try {
|
close(); //1.主动释放连接 //2.某些服务器对指定ip有链路数限制
|
socket = new Socket();
|
SocketAddress socketAddress = new InetSocketAddress(slave.getIp(), slave.getPort());
|
socket.connect(socketAddress, 1000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
|
dataOutputStream = new DataOutputStream(socket.getOutputStream());
|
dataInputStream = new DataInputStream(socket.getInputStream());
|
// log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
} catch (Exception e) {
|
socket = null;
|
log.error("条码扫描仪连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
|
return false;
|
}
|
return true;
|
}
|
|
@Override
|
public void close() {
|
try {
|
if (null != dataOutputStream) {
|
dataOutputStream.close();
|
}
|
if (null != dataInputStream) {
|
dataInputStream.close();
|
}
|
if (null != socket){
|
socket.close();
|
}
|
socket = null;
|
} catch (IOException e) {
|
log.error("SocketClient close Exception:" + e.getMessage());
|
}
|
}
|
|
@Override
|
@SuppressWarnings("InfiniteLoopStatement")
|
public void run() {
|
connect();
|
while (true) {
|
try {
|
byte[] read = read(14, 5000);
|
if (null != read) {
|
String s = new String(read);
|
if (!Cools.isEmpty(s)) {
|
setBarcode(new String(read));
|
}
|
}
|
Thread.sleep(50);
|
} catch (SocketTimeoutException ignore) {
|
connCount++;
|
} catch (Exception e) {
|
setBarcode("");
|
e.printStackTrace();
|
}
|
}
|
}
|
|
public byte[] read(int bufferSize, int timeOut) throws IOException {
|
if (socket == null || !socket.isConnected() || socket.isClosed() || connCount > 120) {
|
connect();
|
connCount = 0;
|
return null;
|
}
|
socket.setSoTimeout(timeOut);
|
byte[] bytes = new byte[bufferSize];
|
int len = dataInputStream.read(bytes);
|
byte[] tempBytes = null;
|
if (len > 0) {
|
tempBytes = new byte[len];
|
System.arraycopy(bytes, 0, tempBytes, 0, len);
|
} else {
|
connect();
|
}
|
return tempBytes;
|
}
|
|
|
}
|
