学步园

java socket通信已经被封装好了主要使用两个类ServerSocket 和Socket

首先写一个1v1的通信

服务端

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

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

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

	public static int PORT = 8080;
	public static void main(String[] agrs) {
		ServerSocket s = null;
		Socket socket = null;
		BufferedReader br = null;
		PrintWriter pw = null;
		try {
			//设定服务端的端口号
			s = new ServerSocket(PORT);
			System.out.println("ServerSocket Start:"+s);
			//等待请求,此方法会一直阻塞,直到获得请求才往下走
			socket = s.accept();
			System.out.println("Connection accept socket:"+socket);
			//用于接收客户端发来的请求
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			//用于发送返回信息,可以不需要装饰这么多io流使用缓冲流时发送数据要注意调用.flush()方法
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			while(true){
				String str = br.readLine();
				if(str.equals("END")){
					break;
				}
				System.out.println("Client Socket Message:"+str);
				Thread.sleep(1000);
				pw.println("Message Received");
				pw.flush();
			}
			
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			System.out.println("Close.....");
			try {
				br.close();
				pw.close();
				socket.close();
				s.close();
			} catch (Exception e2) {
				
			}
		}
	}
}

客户端

/**
 * 
 */
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();
			}
		}
	}

}

这样一个简单地通信就完成了,这里我们要注意现在只能一对一通信。下面我们将使用多线程来实现多客户端通信的例子。