服务端

package com.guoyasoft.net;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Server {
    // 服务器
    public static void testServer() {
        System.out.println("等待客户端连接。。。");
        // 创建一个socket服务端，用于接收socket请求
        ServerSocket ss = null;
        // 键盘输入流
        Scanner keybordInput = null;
        // 网络输入流
        Scanner socketInput = null;
        // 网络输出流
        PrintWriter socketOutput = null;
        try {
            //发布一个端口
            ss = new ServerSocket(8082);
            // 创建一个接收连接客户端的对象
            Socket socket = ss.accept();
            System.out.println(socket.getInetAddress() + "已成功连接到此台服务器上。");
            // 字符输出流
            socketOutput = new PrintWriter(socket.getOutputStream());
            socketOutput.println("已成功连接到远程服务器！" + "\t" + "请您先发言。");
            socketOutput.flush();
            keybordInput = new Scanner(System.in);
            socketInput = new Scanner(socket.getInputStream());
            // 阻塞等待客户端发送消息过来
            while (socketInput.hasNextLine()) {
                String indata = socketInput.nextLine();
                System.out.println("客户端：" + indata);
                System.out.print("我(服务端)：");
                String keyborddata = keybordInput.nextLine();
                socketOutput.println(keyborddata);
                socketOutput.flush();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            socketOutput.close();
            keybordInput.close();
            socketInput.close();
            try {
                ss.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) {
        testServer();
    }
}

客户端

package com.guoyasoft.net;


import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class Client {
    public static void testClient(){
        System.out.println("正在向服务器请求连接。。。");
        //socket：网络链接对象，即TCP封装成的对象
        Socket socket = null;
        //键盘输入流
        Scanner keybordInput = null;
        //网络输入流
        Scanner socketInput = null;
        //网络输出流
        PrintWriter socketOutput = null;
        try {
            socket = new Socket("127.0.0.1", 8082);
            socketInput = new Scanner(socket.getInputStream()); 
            System.out.println(socketInput.nextLine());
            socketOutput = new PrintWriter(socket.getOutputStream());
            //先读取键盘录入方可向服务端发送消息
            System.out.print("我(客户端)：");
            keybordInput = new Scanner(System.in);
            while(keybordInput.hasNextLine()){
                //键盘输入内容，写到服务端的的控制台
                String keyborddata = keybordInput.nextLine();
                socketOutput.println(keyborddata);
                socketOutput.flush();
                //阻塞等待接收服务端的消息
                String indata = socketInput.nextLine();
                System.out.println("服务端："+indata);
                System.out.print("我(客户端)：");
            }
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            keybordInput.close();
            socketOutput.close();
            socketInput.close();
            try {
                socket.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
    }
    public static void main(String[] args) {
        testClient();
    }
}