本示例使用设备介绍：WIFI/TCP/UDP/HTTP协议RFID液显网络读卡器可二次开发语音播报POE-淘宝网 (taobao.com)
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;
public class TCPServer_Java {
//监听端口
private static final int PORT = 39169;
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = null;
Socket socket = null;
try {
//建立服务器的Socket，并设定一个监听的端口PORT
serverSocket = new ServerSocket(PORT);
//由于需要进行循环监听，因此获取消息的操作应放在一个while大循环中
while(true){
try {
//建立跟客户端的连接
socket = serverSocket.accept();
ServerThread thread = new ServerThread(socket);
thread.start();
} catch (Exception e) {
System.out.println("建立与客户端的连接出现异常");
e.printStackTrace();
}
//ServerThread thread = new ServerThread(socket);
//thread.start();
}
} catch (Exception e) {
System.out.println("端口被占用");
e.printStackTrace();
}
finally {
serverSocket.close();
}
}
}
//服务端线程类
//继承Thread类的话，必须重写run方法，在run方法中定义需要执行的任务。
class ServerThread extends Thread {
private Socket socket ;
InputStream inputStream;
OutputStream outputStream;
public ServerThread(Socket socket){
this.socket=socket;
}
public void run(){
try {
while (true){
//接收客户端的消息,解析信息并回应读卡器
//System.out.println(socket);
byte[] bytes =new byte[1024];
inputStream =socket.getInputStream();
int GetDataLen=0;
while ((GetDataLen=inputStream.read(bytes))!=-1){ //通过这个方法读取全部数据 及 长度，
break;
}
if(GetDataLen>0) {
String bytestr = "";
String DataStr = "";
String DispStr = "";
String CardNo16 = "";
String SerialNum = "";
long cardno10;
long cardnum;
for (int p = 0; p < GetDataLen; p++) {
bytestr = "00" + Integer.toHexString(bytes[p] & 0xff);
DataStr = DataStr + bytestr.substring(bytestr.length() - 2, bytestr.length()) + " ";
}
System.out.println("Received from " + socket.getRemoteSocketAddress() + " : " + DataStr);
switch (bytes[0]) {
case (byte)0xc1:
case (byte)0xcf:
if(bytes[0]==(byte)0xc1){
DispStr = "数据解析：接收到读取IC卡号信息，";
}else{DispStr = "数据解析：接收到IC卡离开读卡器，";}
DispStr = DispStr + "功能码：" + Integer.toHexString(bytes[0] & 0xff);
DispStr = DispStr + "，设备IP：" + Integer.toString(bytes[1] & 0xff) + "." + Integer.toString(bytes[2] & 0xff) + "." + Integer.toString(bytes[3] & 0xff) + "." + Integer.toString(bytes[4] & 0xff);
DispStr = DispStr + "，机号：" + Integer.toString((bytes[5] & 0xff) + ((bytes[6] & 0xff) * 256));
DispStr = DispStr + "，数据包序号：" + Integer.toString((bytes[7] & 0xff) + ((bytes[8] & 0xff) * 256));
int Cardlen = bytes[9];
DispStr = DispStr + "，卡号长度：" + Integer.toString(Cardlen);
CardNo16 = "";
for (int p = 10; p < 10 + Cardlen; p++) {
bytestr = "00" + Integer.toHexString(bytes[p] & 0xff);
CardNo16 = CardNo16 + bytestr.substring(bytestr.length() - 2, bytestr.length());
}
DispStr = DispStr + "，16进制卡号：" + CardNo16;
cardnum = bytes[10] & 0xff;
cardnum = cardnum + (bytes[11] & 0xff) * 256;
cardnum = cardnum + (bytes[12] & 0xff) * 65536;
cardnum = cardnum + (bytes[13] & 0xff) * 16777216;
cardno10 = 0;
for (int j = 28; j >= 0; j -= 4) {
cardno10 = cardno10 << 4 | (cardnum >>> j & 0xF);
}
DispStr = DispStr + "，转10进制卡号：" + String.format("%010d", cardno10);
SerialNum = "";
for (int p = 10 + Cardlen; p < GetDataLen; p++) {
bytestr = "00" + Integer.toHexString(bytes[p] & 0xff);
SerialNum = SerialNum + bytestr.substring(bytestr.length() - 2, bytestr.length());
}
DispStr = DispStr + "，唯一硬件序号：" + SerialNum;
System.out.println(DispStr + "\n");
//向客户端发送消息
byte[] RespByte=GetResponseData(2); //生成不同的回应数据包
outputStream = socket.getOutputStream();
outputStream.write(RespByte);
bytestr = "";
DataStr = "";
for (int p = 0; p < RespByte.length; p++) {
bytestr = "00" + Integer.toHexString(RespByte[p] & 0xff);
DataStr = DataStr + bytestr.substring(bytestr.length() - 2, bytestr.length()) + " ";
}
System.out.println("Send Data To "+socket.getRemoteSocketAddress()+" : "+DataStr+"\n");
break;
case (byte)0xd1:
case (byte)0xdf:
if(bytes[0]==(byte)0xd1){
DispStr="数据解析：接收到读取ID卡号信息，";
}else{DispStr="数据解析：接收到ID卡离开读卡器，";}
DispStr=DispStr+"功能码："+ Integer.toHexString(bytes[0] & 0xff);
DispStr=DispStr+"，设备IP："+ Integer.toString(bytes[1] & 0xff) + "." + Integer.toString(bytes[2] & 0xff) + "." + Integer.toString(bytes[3] & 0xff) + "." + Integer.toString(bytes[4] & 0xff);
DispStr=DispStr+"，机号："+ Integer.toString((bytes[5] & 0xff) + ((bytes[6] & 0xff) * 256));
DispStr=DispStr+"，数据包序号："+ Integer.toString((bytes[7] & 0xff) + ((bytes[8] & 0xff) * 256));
CardNo16="";
for (int p = 9; p < 14; p++) {
bytestr = "00" + Integer.toHexString(bytes[p] & 0xff);
CardNo16 = CardNo16 + bytestr.substring(bytestr.length() - 2, bytestr.length());
}
DispStr=DispStr+"，16进制卡号："+CardNo16;
cardnum = bytes[9] & 0xff;
cardnum = cardnum + (bytes[10] & 0xff) * 256;
cardnum = cardnum + (bytes[11] & 0xff) * 65536;
cardnum = cardnum + (bytes[12] & 0xff) * 16777216;
cardno10 = 0;
for (int j = 28; j >= 0; j -= 4) {
cardno10 = cardno10 << 4 | (cardnum >>> j & 0xF);
}
DispStr=DispStr+"，转10进制卡号："+ String.format("%010d", cardno10);
SerialNum="";
for (int p = 14; p < GetDataLen; p++) {
bytestr = "00" + Integer.toHexString(bytes[p] & 0xff);
SerialNum = SerialNum + bytestr.substring(bytestr.length() - 2, bytestr.length());
}
DispStr=DispStr+"，唯一硬件序号："+ SerialNum;
System.out.println(DispStr+"\n");
//向客户端发送消息
RespByte=GetResponseData(2); //生成不同的回应数据包
outputStream = socket.getOutputStream();
outputStream.write(RespByte);
bytestr = "";
DataStr = "";
for (int p = 0; p < RespByte.length; p++) {
bytestr = "00" + Integer.toHexString(RespByte[p] & 0xff);
DataStr = DataStr + bytestr.substring(bytestr.length() - 2, bytestr.length()) + " ";
}
System.out.println("Send Data To "+socket.getRemoteSocketAddress()+" : "+DataStr+"\n");
break;
case (byte)0xf3:
DispStr="数据解析：接收到设备心跳包，";
DispStr=DispStr+"功能码："+Integer.toHexString(bytes[0] & 0xff);
DispStr=DispStr+"，设备IP："+Integer.toString(bytes[1] & 0xff)+"."+Integer.toString(bytes[2] & 0xff)+"."+Integer.toString(bytes[3] & 0xff)+"."+Integer.toString(bytes[4] & 0xff);
DispStr=DispStr+"，机器号："+Integer.toString((bytes[5] & 0xff)+((bytes[6] & 0xff) *256));
DispStr=DispStr+"，包序号："+Integer.toString((bytes[7] & 0xff)+((bytes[8] & 0xff) *256));
DispStr=DispStr+"，心跳码："+Integer.toHexString(bytes[9] & 0xff);
DispStr=DispStr+"，长 度："+Integer.toHexString(bytes[10] & 0xff);
DispStr=DispStr+"，继电器："+Integer.toHexString(bytes[11] & 0xff);
DispStr=DispStr+"，按键值："+Integer.toHexString(bytes[12] & 0xff);
for(int p=13;p<17;p++){
bytestr="00"+Integer.toHexString(bytes[p] & 0xff);
SerialNum=SerialNum+ bytestr.substring(bytestr.length() -2,bytestr.length());
}
DispStr=DispStr+"，随机码："+SerialNum;
SerialNum="";
for(int p=17;p<GetDataLen;p++){
bytestr="00"+Integer.toHexString(bytes[p] & 0xff);
SerialNum=SerialNum+ bytestr.substring(bytestr.length() -2,bytestr.length());
}
DispStr=DispStr+"，设备序列号："+SerialNum;
System.out.println(DispStr+"\n");
break;
}
}
}
} catch (Exception e) {
System.out.println("客户端主动断开连接了");
e.printStackTrace();
}
//操作结束，关闭socket
try{
socket.close();
}catch(IOException e){
System.out.println("关闭连接出现异常");
e.printStackTrace();
}
}
//根据Respcode返回不同的回应数据包
static byte[] GetResponseData(int Respcode) throws Exception {
byte[] RespByte= new byte[300];
String DispStr="本次刷卡成功，感谢您的使用，再见! "; //满屏显示34个字符，不足后面加空格
byte[] DispBuf;
switch(Respcode){
case 0: //驱动读卡器蜂鸣响声
RespByte[0] = (byte) 0x96; //蜂鸣响声的指令码
RespByte[1] = (byte) 0x00; //机号低位
RespByte[2] = (byte) 0x00; //机号高，0000表示任意机号
RespByte[3] = (byte) 0x01; //蜂鸣响声代码，取值范围0-12
RespByte = Arrays.copyOf(RespByte, 4);
break;
case 1: //驱动读卡器显示文字+蜂鸣响声
DispBuf= DispStr.getBytes("gb2312"); //显示文字转字节数组
RespByte[0]=(byte)0x5a; //指令码
RespByte[1]=(byte)0x00; //机号低
RespByte[2]=(byte)0x00; //机号高，如果高低位都为0表示任意机号
RespByte[3]=(byte)0x02; //蜂鸣声代码
RespByte[4]=(byte)0x14; //显示时长
for(int i=0;i<34;i++){ //显示文字
RespByte[i+5]=DispBuf[i];
}
RespByte = Arrays.copyOf(RespByte, 39);
break;
case 2: //驱动读卡器显示文字+蜂鸣响声+继电器开关+TTS语音
DispBuf= DispStr.getBytes("gb2312"); //显示文字转字节数组
String SpeakStr=""; //将要播报的TTS语音生成字节数组，最大不能超过126个字节
SpeakStr="[v1]"; //定义语音大小，取值范围v0 到 v16，可加在任何地方
SpeakStr=SpeakStr+"欢迎您使用我们的网络读卡器，谢谢！"; //要播报的中文语音
byte[] SpeakBuf= SpeakStr.getBytes("gb2312");
int SpeakLen=SpeakBuf.length; //语音长度
int SendLen=11+34+SpeakLen+4; //总计发送数据长度
RespByte[0]=(byte)0x5C; //指令码
RespByte[1]=(byte)0x00; //机号低
RespByte[2]=(byte)0x00; //机号高，如果高低位都为0表示任意机号
RespByte[3]=(byte)0x01; //蜂鸣声代码
RespByte[4]=(byte)0xF0; //继电器代码 F0表示全部继电器 F1表示1号继电器 F2表示2号继电器
RespByte[5]=(byte)0x20; //继电器开启时长 低位
RespByte[6]=(byte)0x00; //继电器开启时长 高位
RespByte[7]=(byte)0x14; //显示保留时间，单位为秒，为0xFF时表示永久显示
RespByte[8]=(byte)0x00; //在显示屏中的哪个位置开始
RespByte[9]=(byte)0x22; //显示字符串长度 为全屏显示为 34 个字符
RespByte[10]=(byte)SpeakLen; //语音长度
for(int i=0;i<34;i++){ //显示的文字信息
RespByte[i+11]=DispBuf[i];
}
for(int i=0;i<SpeakLen;i++){ //TTS语音播报信息
RespByte[i+45]=SpeakBuf[i];
}
RespByte[10+34+SpeakLen+1]=(byte)0x55; //固定的抗干扰后缀
RespByte[10+34+SpeakLen+2]=(byte)0xaa;
RespByte[10+34+SpeakLen+3]=(byte)0x66;
RespByte[10+34+SpeakLen+4]=(byte)0x99;
RespByte = Arrays.copyOf(RespByte, 10+34+SpeakLen+5);
break;
case 3: //驱动读卡器开启继电器开关
RespByte[0]=(byte)0x78; //指令码
RespByte[1]=(byte)0x00; //机号低
RespByte[2]=(byte)0x00; //机号高，如果高低位都为0表示任意机号
RespByte[3]=(byte)0xF0; //继电器代码 F0表示全部继电器、F1表示1号继电器 、F2表示2号继电器......
RespByte[4]=(byte)0x2C; //继电器开启延时低位
RespByte[5]=(byte)0x01; //继电器开启延时高位，FFFF表示继电器一直开启
RespByte = Arrays.copyOf(RespByte, 6);
break;
default:
}
return RespByte;
}
}
