Socket

Socket 服务端SingleThreadServer

package com.zhcs.bs.bus.task.job;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;


public class SingleThreadServer {
    public static void main(String[] args) {
        int port = 4406;
        try {
            ServerSocket serverSocket = new ServerSocket(port);
            System.out.println(serverSocket.getLocalSocketAddress() + " : " + serverSocket.getLocalPort());

            // 此时阻塞，等待客户端连接  直到客户端连接服务端返回Socket
            Socket client = serverSocket.accept();
            

            // 接收
            InputStream inputStream = client.getInputStream();
            Scanner scanner = new Scanner(inputStream);
            System.out.println("客户端> " + scanner.nextLine());

            // 发送
            OutputStream out = client.getOutputStream();
            PrintStream printStream = new PrintStream(out);
            printStream.println("你好，我是客户端==");
            printStream.flush();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

客户端SingleThreadClient

package com.zhcs.bs.bus.task.job;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;

//这是一个客户端
public class SingleThreadClient {
    public static void main(String[] args) {
        String ip = "127.0.0.1";
        int port = 4406;
        try {
            Socket socket = new Socket(ip, port);
            //发送消息
            OutputStream out = socket.getOutputStream();
            PrintStream printStream = new PrintStream(out);
            printStream.println("嗨，你好");
            printStream.flush();
            //接收消息
            InputStream in = socket.getInputStream();
            Scanner scanner = new Scanner(in);
            System.out.println("服务端>" + scanner.nextLine());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

baseVo

package com.eds.message.vo;


public class ResultVo {

    public final static int SUCCESS_STATUS = 200;
    public final static int FAIL_STATUS = 500;
    public final static String SUCCESS_STRING = "处理成功";

    
    int code;

    
    String message;

    
    T data;

    public int getCode() {
        return code;
    }

    public void setCode(int code) {
        this.code = code;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }

    @Override
    public String toString() {
        return "ResultVo{" +
                "code=" + code +
                ", message='" + message + ''' +
                ", data=" + data +
                '}';
    }

    
    public static ResultVo fail(String message) {
        ResultVo