java实例练习——基于TCP/IP协议的多客户端通信

先说一下大概的思路：

应用多线程来实现服务器与多客户端之间的通信

1、服务器端创建ServerSocket，循环调用accept（）等待客户端连接；

2、客户端创建一个Socket并请求与服务器端连接；

3、服务器端接受客户端请求，创建Socket与该客户端简历专线连接；

4、建立连接的两个Socket在一个单独的线程上对话；

5、服务器端继续等待其他新的连接。

闲话不多说，直接上代码：

package net;

/**

 * 1、客户端

 */

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.net.Socket;

import java.net.UnknownHostException;

public class Client {

	public static void main(String[] args) {

		try {

			//1、创建Socket,与服务器建立连接

			Socket socket = new Socket("localhost", 8889);

			//2、向服务器端发送消息

			OutputStream os = socket.getOutputStream();

			PrintWriter pwriter = new PrintWriter(os); //将Socket的输出字节流包装成打印流

			pwriter.write("用户名：sysker ;  密码：sys154");

			//刷新流

			pwriter.flush();

			//3、关闭资源

			socket.shutdownOutput();

			//3、获取输入流

			InputStream inputStream = socket.getInputStream();

			InputStreamReader inputStreamReader = new InputStreamReader(inputStream);

			BufferedReader bufferedReader = new BufferedReader(inputStreamReader);

			String getMsage=null;

			while((getMsage=bufferedReader.readLine())!=null){

				System.out.println("客户端正在等待响应，服务器说："+getMsage);

			}	

			//socket.shutdownInput();

			bufferedReader.close();

			inputStream.close();

			inputStreamReader.close();

			pwriter.close();

			os.close();

			socket.close();

		} catch (UnknownHostException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		} catch (IOException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

}

package net;

/**

 * 2、服务器端

 */

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

public class ManyClientServer {

	public static void main(String[] args) {

		Socket socket = null;

		int clientCount = 0;

		try {

			ServerSocket serverSocket = new ServerSocket(8889);

			while(true){

				socket = serverSocket.accept();

				ManyClientThread manyClientThread = new ManyClientThread(socket);

				manyClientThread.start();

				clientCount++;

				System.out.println("客户端数量"+clientCount);

				System.out.println("客户端的IP地址："+socket.getInetAddress().getHostAddress());

			}	

		} catch (IOException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

}

package net;

/**

 * 3、服务器通信线程

 */

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.Socket;

public class ManyClientThread extends Thread{

	Socket socket = null;

	BufferedReader bufferedReader = null;

	public ManyClientThread(Socket socket){

		this.socket = socket;

	}

	public void run(){

		try {

			BufferedReader bufferedReader = new BufferedReader(

					new InputStreamReader(socket.getInputStream()));

			String mString = null;

			while((mString = bufferedReader.readLine())!=null){

				System.out.println("我是服务器，客户端说"+mString);

			}

			bufferedReader.close();

			socket.close();

		} catch (IOException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}finally{

			if(bufferedReader!=null){

				try {

					bufferedReader.close();

				} catch (IOException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

			}

			if(socket!=null){

				try {

					socket.close();

				} catch (IOException e) {

					// TODO Auto-generated catch block

					e.printStackTrace();

				}

			}

		}

	}

}