socket客户端和服务端通信

一、BufferedReader和BufferedWriter

客户端代码：

package main.java;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
/**
 * 客户端发送写死的信息给服务器(BufferedWriter),客户端读取服务器响应返回的信息(BufferedReader)
 * @author whh
 *
 */
public class SocketClient1 {
    public static void main(String[] args) throws UnknownHostException, IOException {
            
        //创建Socket通信，设置访问服务器的IP和Port
        Socket  socket = new Socket("127.0.0.1",90);
        //输出流向服务器发送数据消息
        OutputStream outputStream = socket.getOutputStream();
        OutputStreamWriter osw = new OutputStreamWriter(outputStream);
        BufferedWriter bw = new  BufferedWriter(osw);
        //输入流读取服务器发送来的数据消息
        InputStream inputStream = socket.getInputStream();
        InputStreamReader inputStreamReader  =new InputStreamReader(inputStream);
        BufferedReader br  = new BufferedReader(inputStreamReader);
        //向服务器端发送一条消息  
        bw.write("测试客户端和服务器通信，服务器接收到消息返回到客户端");
        bw.newLine();
        bw.flush();
        System.out.println("我是客户端，已经连接到服务器："+socket.getRemoteSocketAddress());
        
                
        String readLine = null;
        while ((readLine = br.readLine()) != null){
            System.out.println("来自服务端的消息："+readLine);
        }
        socket.close();
    }
    
}

服务端代码：

package main.java;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * 服务器读取客户端发送的信息(BufferedReader),
 * 服务器发送写死的响应信息到客户端(BufferedWriter)
 * @author whh
 *
 */
public class SocketServer1 {
    public static void main(String[] args) throws Exception{
        //服务器建立通信ServerSocket，并设置端口号
        ServerSocket serverSocket = new  ServerSocket(90);
        System.out.println("启动服务器....");
        while(true){
            Socket clientSocket = serverSocket.accept();//然后接受新的连接请求    //阻塞直到有客户端连接上  
            System.out.println("客户端:"+clientSocket.getInetAddress().getLocalHost()+"已连接到服务器");
            try {
                process(clientSocket);
            } catch (Exception e) {
                e.printStackTrace();
                clientSocket.close();    
            }    
        }
        
    }
    public  static void process(Socket clientSocket) throws Exception{
        System.out.println("client socket连接:"+clientSocket.getRemoteSocketAddress());
        //输入流:读取客户端发送信息
        InputStream in = clientSocket.getInputStream();
        InputStreamReader isr = new InputStreamReader(in);
        BufferedReader br = new  BufferedReader(isr);
        //输出流：返回给客户端响应信息
        OutputStream out = clientSocket.getOutputStream();
        OutputStreamWriter osw = new OutputStreamWriter(out);
        BufferedWriter bw  = new BufferedWriter(osw);
        String line = null;
        while ((line = br.readLine()) != null){
            System.out.println("来自客户端的消息：" + line);
            bw.write("welcome from server.");
            bw.newLine();
            bw.flush();
        }
    }
}

* 注意事项：转自http://blog.csdn.net/keketrtr/article/details/47128999
上面的java Socket通信用到了BufferedReader的readLine()方法和BufferedWriter的write()方法。
注意readLine()方法，通过查看JDK中关于此方法的注释可知，它是读取一行数据，这行数据的末尾必须有换行符标识符说明到此为止是一行。不然readLine()方法无法顺利读取。
所以在服务器端或客户端进行输出的时候必须输出换行标识（ ），让对方可以顺利读取一行。因此可以这样写writer.write("hello world ")。为了更好地使用java的跨平台特性，BufferedWriter提供了一个newLine()方法，该方法就是专门输出一个换行符。所以也可以这样写writer.write("hello world");writer.newLine();
另外既然是BufferedWriter，自然用到了缓冲，当你输出的字符长度不超过缓冲区时，可能不会被输出，这时候程序也无法正常运行。所以要用writer.flush();刷新缓冲区。也就是说writer.write("我接收到你的数据："+input);writer.newLine();writer.flush();必须一起使用，它们总是同时出现，因此你可以自定义一个方法，包含这三个方法。
  public void writeLine(String msg){
   writer.write(msg);

   writer.newLine();

   writer.flush();
  }

二、PrintWriter和BufferedReader :在控制台输入，读取

客户端代码：

package main.java;

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;
import java.util.Scanner;
/**
 * 客户端发送控制台输入的信息给服务器，服务器在控制台输入信息返回给用户：PrintWriter
 * @author whh
 *
 */
public class SocketClient2 {
    public static void main(String[] args) throws UnknownHostException, IOException {
        
//        try {
            //创建Socket通信，设置通信服务器的IP和Port
            Socket  socket = new Socket("127.0.0.1",9090);
            //建立IO输入流读取服务器发送来的数据消息
            InputStream inputStream = socket.getInputStream();
            InputStreamReader inputStreamReader  =new InputStreamReader(inputStream);
            BufferedReader br  = new BufferedReader(inputStreamReader);
            //建立IO输出流向服务器发送数据消息
            OutputStream outputStream = socket.getOutputStream();
//            OutputStreamWriter osw = new OutputStreamWriter(outputStream);
            boolean autoflush = true;
            PrintWriter pw = new  PrintWriter(outputStream, autoflush);
            //在控制台输入信息
            System.out.println("请输入信息：");
            Scanner scan = new Scanner(System.in);
            String send = scan.nextLine();
            //发送到服务器
            pw.println(send);
            
            // read the response
            System.out.println(socket.getRemoteSocketAddress());
            String readLine = br.readLine();
            System.out.println("来自服务端的消息："+readLine+"end...");
            socket.close();
    }
    
    
    

服务端代码：

package main.java;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
/**
 * 客户端发送控制台输入的信息给服务器，服务器在控制台输入信息返回给用户：PrintWriter
 * @author whh
 *
 */
public class SocketServer2 {
    public static void main(String[] args) throws Exception{
        //服务器建立通信ServerSocket，并设置端口号
        ServerSocket serverSocket = new  ServerSocket(9090);
        System.out.println("启动服务器....");
        while(true){
            Socket clientSocket = serverSocket.accept();//然后接受新的连接请求    //阻塞直到有客户端连接上  
            System.out.println("客户端:"+clientSocket.getInetAddress().getLocalHost()+"已连接到服务器");
            try {
                process(clientSocket);
            } catch (Exception e) {
                e.printStackTrace();
                clientSocket.close();    
            }    
        }
        
    }
    public  static void process(Socket clientSocket) throws Exception{
        System.out.println("client socket连接:"+clientSocket.getRemoteSocketAddress());
        //输入流
        InputStream in = clientSocket.getInputStream();
        InputStreamReader isr = new InputStreamReader(in);
        BufferedReader br = new  BufferedReader(isr);
        //输出流
        OutputStream out = clientSocket.getOutputStream();
        OutputStreamWriter osw = new OutputStreamWriter(out);
//        BufferedWriter bw  = new BufferedWriter(osw);
        PrintWriter pw = new PrintWriter(out,true);
        String line = null;
        while ((line = br.readLine()) != null){
            System.out.println("客户输入信息为：" + line);
            //在控制台输入信息
            System.out.println("请输入返回客户信息：");
            Scanner scan = new Scanner(System.in);
            String messToClient = scan.nextLine();
            //发送到客户端
            pw.println("welcome from server..."+messToClient+"end...");
            System.err.println("server  end...");
            pw.flush();
        }
         
        
        
        
        
    }
    
    

}

 三、SocketTest客户端和SocketServer

1.SocketTest

SocketTest V3.0.0 客户端下载地址：http://sockettest.sourceforge.net/

SocketTest作为客户端测试工具，可以不用写客户端代码，直接连接服务端SocketServer

在IP Address中输入访问服务的IP地址，若访问本机，则输入：127.0.0.1（服务器套接字将会监听本地机器。）

然后点击connect,连接服务器。

连接成功后，在Message输入信息，点击send,发送到服务器。然后可以在conversation with host 查看返回的结果 。

所以 可以借助SocketTest来实现客户端和服务端交互，测试服务端代码是否正确。

2.SocketServer

SocketServer构造方法的重载形式有以下几种：

◆ServerSocket()throws IOException 
◆ServerSocket(int port) throws IOException 
◆ServerSocket(int port, int backlog) throws IOException
◆ServerSocket(int port, int backlog, InetAddress bindAddr) throws IOException     //对于这个构造方法，绑定地址必须是java.net.InetAddress的一个实例

如：new ServerSocket(8080, 1, InetAddress.getByName("127.0.0.1"));

其中，参数：port为：服务器要绑定的端口（服务器要监听的端口），

                     backlog为：这是服务器套接字开始拒绝传入的请求之前，传入的连接请求的最大队列长度

                     bindAddr为：服务器要绑定的IP地址。

你需要指定IP地址和服务器套接字将要进行监听的端口号。通常，IP地址将会是127.0.0.1，也就是说，服务器套接字将会监听本地机器。