import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author 一一哥Sun
 * @company 千鋒教育
 */
public class MySocketServer {
    public static void main(String[] args) throws IOException {
        //設(shè)置服務(wù)器的端口號
        int portNumber = 1234;
        // 創(chuàng)建服務(wù)器套接字并綁定端口號
        ServerSocket serverSocket = new ServerSocket(portNumber);
        //獲取與ServerSocket關(guān)聯(lián)的Socket客戶端對象
        Socket acceptSocket = serverSocket.accept();

        // 服務(wù)器接收客戶端發(fā)來的消息
        InputStream serverInputStream = acceptSocket.getInputStream();
        BufferedReader in = new BufferedReader(new InputStreamReader(serverInputStream));
        String response = in.readLine();
        if (response != null) {
            System.out.println("服務(wù)器接收客戶端發(fā)來的消息===>: " + response);
        }

        // 關(guān)閉套接字和流
        serverSocket.close();
        acceptSocket.close();
        serverInputStream.close();
    }
}

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

/**
 * @author 一一哥Sun
 * @company 千鋒教育
 */
public class MySocketClient {
    public static void main(String[] args) throws IOException {
        try {
            // 創(chuàng)建Socket對象并連接到服務(wù)器，關(guān)聯(lián)服務(wù)器的ip地址與端口號
            Socket socket = new Socket("localhost", 1234);

            // 創(chuàng)建輸入輸出流，通過套接字發(fā)送和接收數(shù)據(jù)
            Scanner scanner = new Scanner(System.in);
            String nextLine = scanner.nextLine();
            // 輸出流，客戶端向服務(wù)器發(fā)送消息
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            out.println(nextLine);

            // 關(guān)閉套接字和流
            out.close();
            scanner.close();
            socket.close();
            } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

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;

/**
 * @author 一一哥Sun
 * @company 千鋒教育
 */
public class MyServer {
    public static void main(String[] args) throws IOException {
        int portNumber = 1234;
        // 創(chuàng)建服務(wù)器套接字并綁定端口號
        ServerSocket serverSocket = new ServerSocket(portNumber);
        // 注意：服務(wù)器只能接受一次客戶端！用該socket對象既可以接收客戶端發(fā)來的消息，也可以給客戶端回復消息
        Socket acceptSocket = serverSocket.accept();

        // 服務(wù)器接收客戶端發(fā)來的消息
        InputStream serverInputStream = acceptSocket.getInputStream();
        BufferedReader in = new BufferedReader(new InputStreamReader(serverInputStream));
        String response = in.readLine();
        if (response != null) {
            System.out.println("服務(wù)器接收客戶端發(fā)來的消息===>: " + response);

            // 服務(wù)器向客戶端發(fā)送響應(yīng)信息
            OutputStream serverOutputStream = acceptSocket.getOutputStream();
            String serverResponse = "我是服務(wù)器,你的消息已收到!";
            serverOutputStream.write(serverResponse.getBytes());
            serverOutputStream.flush();
            serverOutputStream.close();
        }

        // 關(guān)閉套接字和流
        serverSocket.close();
        acceptSocket.close();
        serverInputStream.close();
        //serverOutputStream.close();
    }
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

/**
 * @author 一一哥Sun
 * @company 千鋒教育
 */
public class MyClient {
    public static void main(String[] args) throws IOException {
        try {
            //創(chuàng)建Socket對象并連接到服務(wù)器
            Socket socket = new Socket("localhost", 1234);

            //創(chuàng)建輸入輸出流，通過套接字發(fā)送和接收數(shù)據(jù)
            Scanner scanner=new Scanner(System.in);
            String nextLine = scanner.nextLine();
            //輸出流，客戶端向服務(wù)器發(fā)送消息
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            out.println(nextLine);

            //輸入流，客戶端從服務(wù)器接收消息
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String response = in.readLine();
            System.out.println("Server服務(wù)器返回的響應(yīng)信息===>: " + response);

            //關(guān)閉套接字和流
            out.close();
            in.close();
            scanner.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}