tcpjava通讯_java网络通信（基于TCP协议可靠通信的socket编程）

package cn.wang;

import java.io.*;

import java.net.*;

public class Server {

static int num &＃61; 1;//客户端计数

public static void main(String[] args) {

// TODO Auto-generated method stub

ServerSocket server &＃61; null;

Socket client &＃61; null;

while(true) {

try {

server &＃61; new ServerSocket(4444);

//绑定端口&＃xff0c;监听客户端

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println("Error:"&＃43;e);

}

try {

client &＃61; server.accept();

//与客户端建立连接

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println("接受请求失败&＃xff01;");

System.exit(-1);

}

System.out.println("Client["&＃43;Server.num&＃43;"]登录...");

ServerThread st &＃61; new ServerThread(client);

Thread t&＃61; new Thread(st);

//监听到客户端&＃xff0c;为他创建线程&＃xff0c;主程序返回继续监听

t.start();

try {

server.close();

} catch (IOException e) {

// TODO Auto-generated catch block

System.out.println("关闭失败&＃xff01;");

}

num&＃43;&＃43;;

}

}

public static class ServerThread implements Runnable{

private Socket client;

public ServerThread(Socket client) {

this.client &＃61; client;

}

public void run() {

try {

BufferedReader is &＃61; new BufferedReader(new InputStreamReader(client.getInputStream()));

//将从客户端接受的信息存放到缓存is中

PrintWriter os &＃61; new PrintWriter(client.getOutputStream());

//从socket获取客户端的输出流&＃xff0c;通过os向客户端发送消息

BufferedReader sin &＃61; new BufferedReader(new InputStreamReader(System.in));

//建立缓存&＃xff0c;为后面输入数据做准备

System.out.println("Client:"&＃43;is.readLine());

//打印客户端发来的信息

String inputString &＃61; sin.readLine();

//从键盘输入信息&＃xff0c;存放在inputString中

while(inputString!&＃61;null&&inputString.trim().equals("quit")){

os.println(inputString);

//os.println向客户端发送消息&＃xff0c;内容是inputString

os.flush();

//刷新输出流&＃xff0c;使client马上得到该信息

System.out.println("Server发送的信息为:"&＃43;inputString);

//打印服务器向客户端发送的信息

System.out.println("Client发来的信息为:"&＃43;is.readLine());

//打印客户端发来的信息

inputString &＃61; sin.readLine();

//继续读入数据

}

os.close();//关闭Socket输出流

is.close();//关闭Socket输入流

client.close();//关闭Socket

System.out.println("通信结束&＃xff01;");

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}