Java Socket 一对一通信

package com.test.socket;

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

/**
 * socket 简单一对一通信 服务器
 * @author Administrator
 *
 */
public class Server {
    public static void main(String[] args) throws Exception{
        /**绑定端口**/
        ServerSocket server = new ServerSocket(8080);
        /**接受客户端请求**/
        Socket client = server.accept();
        /**用语读取客户端发来的信息**/
        BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
        /**用语返回客户端的响应**/
        PrintWriter out = new PrintWriter(client.getOutputStream());
        while(true){
            String message = in.readLine();
            System.out.println("receive:"+message);
            out.println("has received");
            out.flush();
            if(message.equals("bye")){
                break;
            }
        }
        client.close();
        
    }
}




package com.test.socket;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/**
 * socket 简单一对一通信 客户端
 * @author Administrator
 *
 */
public class Client {
    public static void main(String[] args) throws Exception {
        /**链接服务器**/
        Socket server = new Socket("127.0.0.1",8080);
        /**用于读取服务器信息**/
        BufferedReader in = new BufferedReader(new InputStreamReader(server.getInputStream()));
        /**用于向客户端输出信息**/
        PrintWriter out = new PrintWriter(server.getOutputStream());
        /**用于读取键盘输入流**/
        InputStreamReader inputstremreader = new InputStreamReader(System.in);  
        BufferedReader br = new BufferedReader(inputstremreader);  
        while(true){
            String s = br.readLine();
            out.println(s);
            out.flush();
            if(s.equals("bye")){
                break;
            }
            System.out.println(in.readLine());
        }
        server.close();
    }
}
//启动dos窗口编译执行代码Server.java 和 Client.java进行测试，能够实现