简单的TCPIP服务器端demo程序
public void run()
{
String reccharBuf = new String(); byte[] receiveBuf = new byte[BUFSIZE];
SimpleDateFormat df=new SimpleDateFormat("yyyy/MM/dd/HH:mm:ss"); while (true) { //System.out.println("等待客户端连接。。。。" df.format(new Date())); Console.showInformation("等待客户连接...." df.format(new Date()));
Socket clntSock=null;
BufferedInputStream in=null;//声明BufferedInputStream局部变量 try {
clntSock = server.accept();
clntSock.setSoTimeout(15000);
SocketAddress clientAddress = clntSock.getRemoteSocketAddress(); //System.out.println("Handling client at" clientAddress "/" df.format(new Date())); Console.showInformation("正在处理来自" clientAddress "/" df.format(new Date()));
in = new BufferedInputStream(clntSock.getInputStream(), 1024);//得到从客户端发送来的数据,放到in中 while ((in.read(receiveBuf)) != -1) {
reccharBuf=bytesToHex(receiveBuf);
getMsg(receiveBuf);
Iterator it = receiveBuf.iterator();//迭代器 while (it.hasNext()) {//检查迭代器中是否还有数据 //System.out.println(it.next()); Console.showInformation(it.next().toString());//将得到的数据打印出来 } datalist.clear();//清空集合中的数据 } //Iterator it = datalist.iterator();//迭代器 //while (it.hasNext()) {//检查迭代器中是否还有数据 //System.out.println(it.next()); // Console.showInformation(it.next().toString()); //} if (datalist.isEmpty())
{ //setInsertindicator(true); Console.showInformation("未收到数据"); //System.out.println("未收到数据"); } else{ //setInsertindicator(true); }
} catch (IOException e) { //System.out.println("客户端数据读取异常"); Console.showInformation("客户端数据读取异常");
setInsertindicator(false); datalist.clear(); safeClose(in); safeClose(clntSock);
e.printStackTrace();
}finally{ datalist.clear();
}
}
}
资源文件列表
TcpServer/.classpath , 310
TcpServer/.fatjar , 381
TcpServer/.project , 385
TcpServer/.settings/org.eclipse.jdt.core.prefs , 598
TcpServer/.settings/settings.fatjar , 381
TcpServer/bin/cn/daneng/console/Console.class , 1469
TcpServer/bin/cn/daneng/mysql/DatabaseConnection.class , 947
TcpServer/bin/cn/daneng/mysql/MysqlInsert.class , 3101
TcpServer/bin/cn/daneng/run/Run.class , 902
TcpServer/bin/cn/daneng/tcp/TCPEchoServer.class , 4119
TcpServer/img/chart.png , 5390
TcpServer/img/comm_fail_128px.png , 8155
TcpServer/img/comm_link_128px.png , 26546
TcpServer/img/connect.png , 3238
TcpServer/img/database_fail_128px.png , 16842
TcpServer/img/database_link_128px.png , 16849
TcpServer/img/MCUsignal_fail.png , 1376
TcpServer/img/MCUsignal__sucess.png , 1260
TcpServer/img/realtimecurve.png , 6835
TcpServer/img/save.png , 4203
TcpServer/img/sensor.png , 7004
TcpServer/img/status_off.png , 5868
TcpServer/img/status_on.png , 5634
TcpServer/img/thermometer.png , 1743
TcpServer/img/upload.png , 2844
TcpServer/lib/mysql-connector-java-5.1.41-bin.jar , 992808
TcpServer/lib/sql.txt , 616
TcpServer/src/cn/daneng/console/Console.java , 871
TcpServer/src/cn/daneng/mysql/DatabaseConnection.java , 509
TcpServer/src/cn/daneng/mysql/MysqlInsert.java , 2369
TcpServer/src/cn/daneng/run/Run.java , 501
TcpServer/src/cn/daneng/tcp/TCPEchoServer.java , 3198
