package com.northglass.listener;
|
|
import java.io.DataInputStream;
|
import java.io.DataOutputStream;
|
import java.io.IOException;
|
import java.net.ServerSocket;
|
import java.net.Socket;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.slf4j.MDC;
|
import org.springframework.context.ApplicationContext;
|
|
import com.northglass.constants.StateConstants.ConnectState;
|
import com.northglass.entity.CutMachine;
|
import com.northglass.service.cutmachine.CutMachineService;
|
import com.northglass.util.HexUtil;
|
|
public class CutMachineServerListener extends AbstractServerListener implements Runnable {
|
|
private static final Logger LOGGER = LoggerFactory.getLogger(CutMachineServerListener.class);
|
|
private CutMachine cutMachine;
|
private CutMachineService service;
|
|
private StringBuffer MESSAGE_BUFFER = new StringBuffer();
|
|
public CutMachineServerListener(Long cutMachineId) {
|
ApplicationContext context = initializeSpringContext();
|
service = context.getBean(CutMachineService.class);
|
this.cutMachine = service.getById(cutMachineId);
|
|
MDC.put("logFileName", "CutMachine_" + new SimpleDateFormat("yyyyMMdd_HHmmss").format(new Date()));
|
}
|
|
/**
|
* 启动服务器监听连接，等待客户端连接
|
*
|
* @throws IOException
|
*/
|
private void connect(ServerSocket serverSocket) throws IOException {
|
if (serverSocket.isClosed()) {
|
return;
|
}
|
|
Socket socket = serverSocket.accept();
|
LOGGER.debug("客户端已连接，客户端IP：" + socket.getInetAddress());
|
|
service.setConnectState(cutMachine, ConnectState.CONNECTED);
|
cutMachine.getServerConnection().setSocket(socket);
|
}
|
|
/**
|
* 服务器监听消息循环，先从客户端接收消息，再向客户端发送消息
|
*
|
* @throws IOException
|
*/
|
private void listen() throws IOException {
|
Socket socket = cutMachine.getServerConnection().getSocket();
|
socket.setSoTimeout(10000); // 10000ms = 10s
|
while (true) {
|
DataInputStream in = new DataInputStream(socket.getInputStream());
|
byte b = in.readByte();
|
MESSAGE_BUFFER.append(HexUtil.byteToHexString(b));
|
|
if (!existMessage()) {
|
continue;
|
}
|
|
String message = getNextMessage();
|
// machineService.saveMessage(MessageType.CLIENT, message, socket.getInetAddress().getHostAddress(), socket.getLocalPort());
|
String returnMessage = ""; //service.generateReturnMessage(message);
|
|
if (returnMessage != null && !"".equals(returnMessage)) {
|
// machineService.saveMessage(MessageType.SERVER, message, socket.getInetAddress().getHostAddress(), socket.getLocalPort());
|
|
DataOutputStream out = new DataOutputStream(socket.getOutputStream());
|
out.write(HexUtil.stringToInt(returnMessage));
|
out.flush();
|
}
|
|
// DataInputStream in = new DataInputStream(socket.getInputStream());
|
// bufSize = in.read(msg);
|
// String message = HexUtil.byteToHexString(bufSize, msg);
|
//
|
// String returnMessage = ""; //service.generateReturnMessage(message);
|
//
|
// // 客户端会一直向服务器发数据
|
// if(returnMessage!=null){
|
// DataOutputStream out = new DataOutputStream(socket.getOutputStream());
|
// out.write(HexUtil.stringToInt(returnMessage));
|
// out.flush();
|
// }
|
}
|
}
|
|
private boolean existMessage() {
|
return MESSAGE_BUFFER.indexOf("3c454f463e") >= 0;
|
}
|
|
private String getNextMessage() {
|
int messageEnd = MESSAGE_BUFFER.indexOf("3c454f463e");
|
String message = "";
|
|
if (messageEnd >= 0) {
|
message = MESSAGE_BUFFER.substring(0, messageEnd + 10);
|
MESSAGE_BUFFER = MESSAGE_BUFFER.delete(0, messageEnd + 10);
|
}
|
|
return message;
|
}
|
|
@Override
|
public void run() {
|
ServerSocket serverSocket = null;
|
|
try {
|
serverSocket = new ServerSocket(cutMachine.getPort());
|
LOGGER.debug("切割机【" + cutMachine.getNumber() + "】启动监听，等待客户端连接，端口：" + cutMachine.getPort());
|
cutMachine.getServerConnection().setServerSocket(serverSocket);
|
|
connect(serverSocket);
|
|
// 一直循环，若连接断开，则在Exception处理环节重新连接，并继续监听消息
|
while (!Thread.currentThread().isInterrupted()) {
|
try {
|
listen();
|
}
|
catch (IOException se) {
|
LOGGER.debug("切割机连接已断开！");
|
se.printStackTrace();
|
|
LOGGER.debug("切割机等待重新连接……");
|
service.setConnectState(cutMachine, ConnectState.CONNECTING);
|
connect(serverSocket);
|
}
|
}
|
}
|
catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
