版权声明:本文为博主原创文章,未经博主允许不得转载。
@Test
public void run() throws IOException {
AcceptThread acceptThread = new AcceptThread();
acceptThread.run();
}
class AcceptThread extends Thread {
public void run() {
ServerSocket serverSocket = null;
Socket socket = null;
DataInputStream input = null;
try {
serverSocket = new ServerSocket(3600);
socket = serverSocket.accept();
socket.setKeepAlive(true);
while (true) {
input = new DataInputStream(socket.getInputStream());
byte[] buffer = {};
int bufflenth = input.available();
int size = 0;
while (bufflenth != 0) {
// 初始化byte数组为buffer中数据的长度
buffer = new byte[bufflenth];
size += input.read(buffer);
bufflenth = input.available();
}
if (buffer.length != 0) {
String str = new String(buffer, "GB2312");
System.out.println("接收到:" + str);
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (input != null) {
input.close();
input = null;
}
if (socket != null) {
socket.close();
socket = null;
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}