java Socket通信(一)

标签： socketjavaexceptionstring服务器class

版权声明：本文为博主原创文章，未经博主允许不得转载。

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

首先写一个1v1的通信

服务端

[java] view plain copy

    /**
     *
     */
    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) {  

                }
            }
        }
    } 

客户端

[java] view plain copy

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

    }  

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