import java.io.*;import java.net.Socket;import java.util.Date;/** * Created by CLY on 2017/7/11. */public class ClientSocket {    public static void main(String[] arg){        int port = 233;//与之连接的服务端套接字的端口号        String host = "127.0.0.1";//与之连接的服务端套接字ip地址        Socket socket = null;        try {            //创建socket连接，即在该Socket构造函数返回之前，就会与远程主机建立连接，如果未能连接，则会抛出异常。            socket = new Socket(host, port);            //获取输出流，向服务器端发送当前时间            OutputStream outputStream = socket.getOutputStream();            Writer writer = new OutputStreamWriter(outputStream);            String now_date = new Date().toString();            writer.write("客户端当前时间为——"+now_date);            writer.flush();            ////关闭客户端的输出流。相当于给流中加入一个结束标记-1.这个样子服务器的输入流的reaLine方法就会读到一个-1，然后结束readLIne方法。            socket.shutdownOutput();            //获取输入流，并读取服务器端的响应信息            InputStream inputStream= socket.getInputStream();            BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));            String server_info = null;            while((server_info=br.readLine())!=null){                System.out.println("服务端传过来的值："+server_info);            }        } catch (IOException e) {            e.printStackTrace();        } finally {            //如果socket不为null，则释放掉它            if (socket!=null){                try {                    socket.close();                } catch (IOException e) {                    e.printStackTrace();                }            }        }    }}

import java.io.*;import java.net.InetAddress;import java.net.ServerSocket;import java.net.Socket;import java.util.Date;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * Created by CLY on 2017/7/11. */public class MyServerSocket {    public static void main(String[] arg){        /**         * 根据tcp协议可知，所谓套接字（socket）是指一个由“ip地址+端口”组成的组合。         * 而每一台主机的ip地址都是确定的，不需要我们来指定，         * 所以构建服务器socket的第一步就是确定端口         */        try {            int port = 233;//端口号            int queueLength = 50;//最大入站连接            InetAddress bindAddress = InetAddress.getByName("127.0.0.1");//只监听该ip的指定端口            ExecutorService pool = Executors.newFixedThreadPool(50);//创建一个最大容量为50的线程池，为每一个入站连接分配一条线程。            //创建一个端口为“233”的服务器socket            ServerSocket serverSocket = new ServerSocket(port);            //创建一个端口为233的服务器socket，且队列一次最多能保存50个入站连接            //ServerSocket serverSocket = new ServerSocket(port,queueLength);            //假设一台主机有多个ip地址，则服务器socket会默认在所有ip地址的指定端口上监听，但可以指定其只监听指定ip的端口。            //ServerSocket serverSocket = new ServerSocket(port,queueLength,bindAddress);            while (true){                //accept()调用会阻塞，会一直等到有客户端连接到指定socket端口为止。                final Socket connection = serverSocket.accept();                //线程池中拿取一条线程来处理socket连接。然后主程序运行下一个循环，继续等待下一个客户端的访问。                pool.execute(new Runnable() {                    public void run() {                        try {                            //从输入流中读取获取客户端传过来的值                            InputStream inputStream= connection.getInputStream();                            BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));                            String client_info = null;                            while((client_info=br.readLine())!=null){                                System.out.println("客户端传过来的值："+client_info);                            }                            //测试：将当前时间写入流中返回给客户端                            Writer writer = new OutputStreamWriter(connection.getOutputStream());                            String nowData = new Date().toString();                            writer.write("服务端当前时间为——"+nowData);                            writer.flush();                        } catch (IOException e) {                            e.printStackTrace();                        } finally {                            try {                                //关闭socket连接                                connection.close();                            } catch (IOException e) {                                e.printStackTrace();                            }                        }                    }                });            }        } catch (IOException e) {            e.printStackTrace();        }    }}