java服务端与客户端交互（二）服务多个客户--多开线程

上次做了一个java socket一对一通信的例子这次来写一个一对多的通信,这里我们使用java的多线程来实现

首先来看一下服务类

[java]
view plaincopyprint?

/**
*
*/
package com.dnion.socket;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

/**
***************************************************************

* 项目名称：JavaThread
* 程序名称：MultiJabberServer

* 日期：2012-8-23 下午02:38:20
* 作者：
* 模块：
* 描述：
* 备注：
* ------------------------------------------------------------

* 修改历史
* 序号 日期 修改人 修改原因
*
* 修改备注：
* @version
***************************************************************

*/
public class MultiJabberServer {

/**
* 方法名：main
* 描述：
* 作者：
* 日期：2012-8-23 下午02:38:20
* @param @param args
* @return void
*/
public static
void main(String[] args) {
ServerSocket s = null;

Socket socket = null;

try {
s = new ServerSocket(8080);

//等待新请求、否则一直阻塞
while(true){

socket = s.accept();
System.out.println("socket:"+socket);

new ServeOneJabbr(socket);

}
} catch (Exception e) {

try {
socket.close();
} catch (IOException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();
}
}finally{

try {
s.close();
} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();
}
}

}

}

/**
 * 
 */
package com.dnion.socket;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

/**
 *************************************************************** 
 * 项目名称：JavaThread
 * 程序名称：MultiJabberServer
 * 日期：2012-8-23 下午02:38:20
 * 作者：
 * 模块：
 * 描述：
 * 备注：
 * ------------------------------------------------------------
 * 修改历史
 * 序号  				日期        		修改人       修改原因
 * 
 * 修改备注：
 * @version 
 ***************************************************************
 */
public class MultiJabberServer {

	
	/**
	 * 方法名：main
	 * 描述：
	 * 作者：
	 * 日期：2012-8-23 下午02:38:20
	 * @param @param args
	 * @return void
	 */
	public static void main(String[] args) {
		ServerSocket s = null;
		Socket socket  = null;
		try {
			s = new ServerSocket(8080);
			//等待新请求、否则一直阻塞
			while(true){
				socket = s.accept();
				System.out.println("socket:"+socket);
				new ServeOneJabbr(socket);
				
			}
		} catch (Exception e) {
			try {
				socket.close();
			} catch (IOException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
		}finally{
			try {
				s.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		

	}

}

接着我们要写一个服务端响应请求的类也就是一个socket

[java]
view plaincopyprint?

/**
*
*/
package com.dnion.socket;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

/**
***************************************************************

* 项目名称：JavaThread
* 程序名称：ServeOneJabbr
* 日期：2012-8-23 下午02:34:13
* 作者：
* 模块：
* 描述：
* 备注：
* ------------------------------------------------------------

* 修改历史
* 序号 日期 修改人 修改原因
*
* 修改备注：
* @version
***************************************************************

*/
public class ServeOneJabbr
extends Thread{

private Socket socket =
null;
private BufferedReader br =
null;
private PrintWriter pw =
null;

public ServeOneJabbr(Socket s){

socket = s;
try {
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);

start();
} catch (Exception e) {

e.printStackTrace();
}
}

@Override

public void run() {

while(true){

String str;
try {
str = br.readLine();
if(str.equals("END")){

br.close();
pw.close();
socket.close();
break;
}
System.out.println("Client Socket Message:"+str);

pw.println("Message Received");

pw.flush();
} catch (Exception e) {

try {
br.close();
pw.close();
socket.close();
} catch (IOException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();
}
}
}
}

}

/**
 * 
 */
package com.dnion.socket;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

/**
 *************************************************************** 
 * 项目名称：JavaThread
 * 程序名称：ServeOneJabbr
 * 日期：2012-8-23 下午02:34:13
 * 作者：
 * 模块：
 * 描述：
 * 备注：
 * ------------------------------------------------------------
 * 修改历史
 * 序号  				日期        		修改人       修改原因
 * 
 * 修改备注：
 * @version 
 ***************************************************************
 */
public class ServeOneJabbr extends Thread{

	private Socket socket = null;
	private BufferedReader br = null;
	private PrintWriter pw = null;
	
	public ServeOneJabbr(Socket s){
		socket = s;
		try {
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			start();
		} catch (Exception e) {
			
			e.printStackTrace();
		}
	}
	
	@Override
	public void run() {
		while(true){
			String str;
			try {
				str = br.readLine();
				if(str.equals("END")){
					br.close();
					pw.close();
					socket.close();
					break;
				}
				System.out.println("Client Socket Message:"+str);
				pw.println("Message Received");
				pw.flush();
			} catch (Exception e) {
				try {
					br.close();
					pw.close();
					socket.close();
				} catch (IOException e1) {
					// TODO Auto-generated catch block
					e1.printStackTrace();
				}
			}
		}
	}
	
	
	
}

接下来利用我们上一次的客户端socket

[java]
view plaincopyprint?

/**
*
*/
package com.dnion.socket;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

/**
***************************************************************

* 项目名称：JavaThread 程序名称：JabberClient 日期：2012-8-23 下午01:47:12

* 作者：
* 模块：
* 描述：
* 备注：
* ------------------------------------------------------------

* 修改历史
* 序号
* 日期
* 修改人
* 修改原因
* 修改备注：
*
* @version
***************************************************************

*/
public class JabberClient {

/**
* 方法名：main 描述： 作者：白鹏飞 日期：2012-8-23 下午01:47:12

*
* @param @param args
* @return void
*/
public static
void main(String[] args) {
Socket socket = null;

BufferedReader br = null;

PrintWriter pw = null;

try {
//客户端socket指定服务器的地址和端口号

socket = new Socket("127.0.0.1", JabberServer.PORT);

System.out.println("Socket=" + socket);

//同服务器原理一样
br = new BufferedReader(new InputStreamReader(

socket.getInputStream()));
pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(

socket.getOutputStream())));
for (int i =
0; i < 10; i++) {

pw.println("howdy " + i);

pw.flush();
String str = br.readLine();
System.out.println(str);
}
pw.println("END");

pw.flush();
} catch (Exception e) {

e.printStackTrace();
} finally {

try {
System.out.println("close......");

br.close();
pw.close();
socket.close();
} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();
}
}
}

}

/**
 * 
 */
package com.dnion.socket;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

/**
 *************************************************************** 
 * 项目名称：JavaThread 程序名称：JabberClient 日期：2012-8-23 下午01:47:12 
 * 作者：
 * 模块： 
 * 描述： 
 * 备注：
 * ------------------------------------------------------------ 
 * 修改历史
 * 序号
 * 日期
 * 修改人
 * 修改原因
 * 修改备注：
 * 
 * @version
 *************************************************************** 
 */
public class JabberClient {

	/**
	 * 方法名：main 描述： 作者：白鹏飞 日期：2012-8-23 下午01:47:12
	 * 
	 * @param @param args
	 * @return void
	 */
	public static void main(String[] args) {
		Socket socket = null;
		BufferedReader br = null;
		PrintWriter pw = null;
		try {
			//客户端socket指定服务器的地址和端口号
			socket = new Socket("127.0.0.1", JabberServer.PORT);
			System.out.println("Socket=" + socket);
			//同服务器原理一样
			br = new BufferedReader(new InputStreamReader(
					socket.getInputStream()));
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
					socket.getOutputStream())));
			for (int i = 0; i < 10; i++) {
				pw.println("howdy " + i);
				pw.flush();
				String str = br.readLine();
				System.out.println(str);
			}
			pw.println("END");
			pw.flush();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				System.out.println("close......");
				br.close();
				pw.close();
				socket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}

这样一个简单地多客户端响应socket就成了

每次有一个请求发送过来服务端都会新建一个线程来单独服务。