package testlxd;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.Scanner;

public class Server_Test extends Thread {

    ServerSocket server = null;

    Socket socket = null;

    public Server_Test(int port) {

        try {

            server = new ServerSocket(port);

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void run() {

        super.run();

        try {

            System.out.println(getdate() + "  等待客户端连接...");

            socket = server.accept();

            new sendMessThread().start();// 连接并返回socket后，再启用发送消息线程

            System.out.println(getdate() + "  客户端 （" + socket.getInetAddress().getHostAddress() + "） 连接成功...");

            InputStream in = socket.getInputStream();

            int len = 0;

            byte[] buf = new byte[1024];

            while ((len = in.read(buf)) != -1) {

                System.out.println(getdate() + "  客户端: （"

                        + socket.getInetAddress().getHostAddress() + "）说："

                        + new String(buf, 0, len, "UTF-8"));

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    public static String getdate() {

        Date date = new Date();

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

        String result = format.format(date);

        return result;

    }

    class sendMessThread extends Thread {

        @Override

        public void run() {

            super.run();

            Scanner scanner = null;

            OutputStream out = null;

            try {

                if (socket != null) {

                    scanner = new Scanner(System.in);

                    out = socket.getOutputStream();

                    String in = "";

                    do {

                        in = scanner.next();

                        out.write(("" + in).getBytes("UTF-8"));

                        out.flush();// 清空缓存区的内容

                    } while (!in.equals("q"));

                    scanner.close();

                    try {

                        out.close();

                    } catch (IOException e) {

                        e.printStackTrace();

                    }

                }

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

    // 函数入口

    public static void main(String[] args) {

        Server_Test server = new Server_Test(1234);

        server.start();

    }

}

package testlxd;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

import java.net.UnknownHostException;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.Scanner;

public class Client extends Thread {

    //定义一个Socket对象

    Socket socket = null;

    public Client(String host, int port) {

        try {

            //需要服务器的IP地址和端口号，才能获得正确的Socket对象

            socket = new Socket(host, port);

        } catch (UnknownHostException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    @Override

    public void run() {

        //客户端一连接就可以写数据给服务器了

        new sendMessThread().start();

        super.run();

        try {

            // 读Sock里面的数据

            InputStream s = socket.getInputStream();

            byte[] buf = new byte[1024];

            int len = 0;

            while ((len = s.read(buf)) != -1) {

                System.out.println(getdate() + "  服务器说：  "+new String(buf, 0, len,"UTF-8"));

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

    //往Socket里面写数据，需要新开一个线程

    class sendMessThread extends Thread{

        @Override

        public void run() {

            super.run();

            //写操作

            Scanner scanner=null;

            OutputStream os= null;

            try {

                scanner=new Scanner(System.in);

                os= socket.getOutputStream();

                String in="";

                do {

                    in=scanner.next();

                    os.write((""+in).getBytes());

                    os.flush();

                } while (!in.equals("bye"));

            } catch (IOException e) {

                e.printStackTrace();

            }

            scanner.close();

            try {

                os.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

    public static String getdate() {

        Date date = new Date();

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

        String result = format.format(date);

        return result;

    }

    //函数入口

    public static void main(String[] args) {

        //需要服务器的正确的IP地址和端口号

        Client clientTest=new Client("127.0.0.1", 1234);

        clientTest.start();

    }

}