java Socket通信(一)[转]

http://blog.csdn.net/gxy3509394/article/details/7899923

 

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();

}

}

}

}