package com.northglass.listener;
|
|
import java.io.DataInputStream;
|
import java.io.DataOutputStream;
|
import java.io.IOException;
|
import java.net.ConnectException;
|
import java.net.Socket;
|
|
import org.slf4j.Logger;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.context.support.GenericXmlApplicationContext;
|
|
import com.northglass.entity.CountMachine;
|
import com.northglass.entity.WashMachine;
|
import com.northglass.log.GLoggerFactory;
|
import com.northglass.service.countmachine.CountMachineService;
|
import com.northglass.service.washmachine.WashMachineService;
|
import com.northglass.util.HexUtil;
|
|
public class WashMachineClientListener implements Runnable {
|
|
private static final Logger LOGGER = GLoggerFactory.getLogger(WashMachineClientListener.class);
|
|
private static final int INTERVAL = 3000;
|
|
private static final int MESSAGE_LENGTH_START = 10;
|
private static final int MESSAGE_LENGTH_END = 13;
|
|
private static final int DATA_START = 74;
|
|
/**
|
* 信息头，字符串“<STA>”的16进制表示
|
*/
|
private static final String HEAD = "3c5354413e";
|
|
/**
|
* 信息尾，字符串“<EOF>”的16进制表示
|
*/
|
private static final String END = "3c454f463e";
|
|
private StringBuffer MESSAGE_BUFFER = new StringBuffer();
|
|
private WashMachine machineClient;
|
private WashMachineService machineService;
|
protected static final int BUFFER_SIZE = 2048;
|
protected byte[] msg = new byte[BUFFER_SIZE];
|
protected int bufSize = 0;
|
|
// 该方法Jetty中用不到，但是Tomcat中可能会有问题
|
private ApplicationContext initializeSpringContext() {
|
GenericXmlApplicationContext context = new GenericXmlApplicationContext();
|
context.getEnvironment().setActiveProfiles("production");
|
context.load("applicationContext.xml");
|
context.refresh();
|
|
return context;
|
}
|
|
public WashMachineClientListener(WashMachine machineClient, WashMachineService machineService) {
|
initializeSpringContext();
|
this.machineClient = machineClient;
|
this.machineService = machineService;
|
}
|
|
private void connect() throws IOException {
|
Socket socket = new Socket(machineClient.getIpAddress(), machineClient.getPort());
|
LOGGER.debug("清洗机【" + machineClient.getNumber() + "】启动连接服务器，端口：" + machineClient.getPort());
|
machineService.setConnectState(machineClient,"已连接");//ConnectState.CONNECTED
|
machineClient.getServerConnection().setSocket(socket);
|
DataOutputStream outToServer = new DataOutputStream(socket.getOutputStream());
|
try {
|
Thread.sleep(100);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
outToServer.write(HexUtil.stringToInt(sendMessage()));
|
outToServer.flush();
|
}
|
|
private void listen() throws IOException {
|
Socket socket = machineClient.getServerConnection().getSocket();
|
socket.setSoTimeout(3000);
|
|
while(true) {
|
DataInputStream in = new DataInputStream(socket.getInputStream());
|
bufSize = in.read(msg);
|
String message = HexUtil.byteToHexString(bufSize, msg);
|
String returnMessage = machineService.processMessage(message,machineClient);
|
if (returnMessage != null && !"".equals(returnMessage)) {
|
DataOutputStream out = new DataOutputStream(socket.getOutputStream());
|
out.write(HexUtil.stringToInt(returnMessage));
|
out.flush();
|
} else {
|
DataOutputStream outToServer = new DataOutputStream(socket.getOutputStream());
|
try {
|
Thread.sleep(100);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
outToServer.write(HexUtil.stringToInt(sendMessage()));
|
outToServer.flush();
|
}
|
}
|
}
|
|
public boolean existMessage() {
|
// 若缓冲区长度小于消息最小长度，则缓冲区中的消息无效。
|
if (MESSAGE_BUFFER.length() < 84) {
|
return false;
|
}
|
|
String head = MESSAGE_BUFFER.substring(0, 10);
|
LOGGER.trace("head: " + head);
|
|
// 若缓冲区不以HEAD为起始，则删掉字符；
|
// 一个字符一个字符删是避免一次删多导致消息损坏。
|
if (!head.equalsIgnoreCase(HEAD)) {
|
MESSAGE_BUFFER.delete(0, 2);
|
return false;
|
}
|
|
// 获取消息长度
|
String messageLengthHex = MESSAGE_BUFFER.substring(MESSAGE_LENGTH_START, MESSAGE_LENGTH_END + 1);
|
int messageLength = HexUtil.hexToInt(messageLengthHex);
|
LOGGER.trace("messageLength: " + messageLength);
|
|
if (MESSAGE_BUFFER.length() < DATA_START + messageLength*2) {
|
return false;
|
}
|
|
String dataAndEnd = MESSAGE_BUFFER.substring(DATA_START, DATA_START + messageLength*2);
|
String end = dataAndEnd.substring(dataAndEnd.length() - 10, dataAndEnd.length());
|
LOGGER.trace("end: " + end);
|
|
if (head.equals(HEAD) && end.equals(END)) {
|
return true;
|
}
|
|
return false;
|
}
|
|
public String getNextMessage() {
|
// 获取消息长度
|
String messageLengthHex = MESSAGE_BUFFER.substring(MESSAGE_LENGTH_START, MESSAGE_LENGTH_END + 1);
|
int messageLength = HexUtil.hexToInt(messageLengthHex);
|
LOGGER.trace("messageLength: " + messageLength);
|
|
String message = MESSAGE_BUFFER.substring(0, DATA_START + messageLength*2);
|
MESSAGE_BUFFER.delete(0, DATA_START + messageLength*2);
|
|
return message;
|
}
|
|
@Override
|
public void run() {
|
while (true) {
|
try {
|
connect();
|
listen();
|
}
|
catch (ConnectException ce) {
|
LOGGER.error("清洗机【" + machineClient.getNumber() + "】无法连接服务器：【"
|
+ machineClient.getIpAddress() + ":" + machineClient.getPort() + "】！");
|
LOGGER.error(ce.getMessage());
|
|
try {
|
Thread.sleep(INTERVAL);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
private String sendMessage() {
|
String date = "00010000000601030000002D";
|
return date;
|
}
|
|
}
|
