Java-SocketServer极简示例

引言：作为ctrl cv工程师，实现用socket通信连续收发信息这个功能，却还是废了一些功夫，特此记录。

本文将分为三部分示例，示例将会层层推进。第一部分展示如何实现socket客户端向服务端发消息；第二部分展示如何实现socket服务端向客户端发送消息；第三部分展示如何实现socket客户端和服务端相互发消息。

客户端向服务端发消息

我们将实现通过socket客户端向服务端发消息，服务端接收消息并展示

• 编写服务端（SocketServer.java）代码

import java.io.DataInputStream;
import java.io.IOException;
import java.net.*;
import java.util.Enumeration;

public class SocketServer {
    public static void main(String[] args) throws IOException {

        int port = 1573;
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("ServerSocket创建成功，地址为 " + getLocalIP() + ":" + port);
        System.out.println("等待接收客户端消息...");
        Socket socket = serverSocket.accept();
        DataInputStream dataInputStream = new DataInputStream(socket.getInputStream());
        String read = dataInputStream.readUTF();
        System.out.println("收到来自客服端的消息：" + read);
    }

    /**
     * 获取本机IP
     * @return 本机IP，获取失败则返回 "0.0.0.0"
     * @throws SocketException
     */
    public static String getLocalIP() throws SocketException {
        Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces();

        while(networkInterfaces.hasMoreElements()) {
            NetworkInterface next = networkInterfaces.nextElement();
            Enumeration<InetAddress> inetAddresses = next.getInetAddresses();

            while(inetAddresses.hasMoreElements()) {
                InetAddress inetAddress = inetAddresses.nextElement();
                if (!inetAddress.isLoopbackAddress() && inetAddress instanceof Inet4Address) {
                    return inetAddress.getHostAddress();
                }
            }
        }
        return "0.0.0.0";
    }
}

• 编写客户端（SocketClient.java）代码

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

public class SocketClient {
    public static void main(String[] args) throws IOException {
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入ip");
        String ip = scanner.next();
        System.out.println("请输入端口");
        int port = scanner.nextInt();
        String url = ip + ":" + port;
        System.out.println("我们即将连接 →\n               " + url);
        Socket socket = new Socket(ip, port);
        System.out.println("socket连接成功，请输入要发送的内容：");
        String sendToServer = scanner.next();
        DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());
        dataOutputStream.writeUTF(sendToServer);
        dataOutputStream.flush();
        System.out.println("发送成功");
        dataOutputStream.close();
    }
}

• 编译并运行服务端代码

javac -Dfile.encoding=UTF-8 SocketServer.java
java SocketServer

• 编译并运行客户端代码

javac -Dfile.encoding=UTF-8 SocketClient.java
java SocketClient

客户端和服务端运行后如下图

客户端和服务端运行后

我们在客户端输入ip和端口（ip和端口和服务端对应），以连接服务端

客户端连接上服务端

我们在客户端继续输入要发送的内容

客户端发送内容

可以看到，服务端正常接收到客户端发送过来的消息

服务端向客户端发消息

我们将实现通过socket服务端向客户端发消息，客户端接收消息并展示

修改服务端（SocketServer.java）代码

DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());
String sendBackToClient = "哈喽，我是服务端，要不起";
System.out.println("将要发送到客户端的内容：" + sendBackToClient);
dataOutputStream.write(sendBackToClient.getBytes());
dataOutputStream.flush();

代码对比如下：

修改服务端（`SocketServer.java`）代码

修改客户端（SocketClient.java）代码

System.out.println(" →→  等待接收服务端发来的消息！");
int bufferSize = 16 * 1024;
byte[] buffer = new byte[bufferSize];
try {
    int readCount = socket.getInputStream().read(buffer);
    String read = new String(buffer, 0, readCount);
    System.out.println(" →→  收到来自服务端的消息：" + read);
} catch (IOException e) {
    throw new RuntimeException(e);
}

代码对比如下：

修改客户端（`SocketClient.java`）代码

运行结果如下：

服务端发送内容

互发消息

有了前面的两个章节，实现服务器与客户端互发消息只是代码结构的问题

修改服务端（SocketServer.java）代码

Scanner scanner = new Scanner(System.in);
int bufferSize = 16 * 1024;
byte[] buffer = new byte[bufferSize];
boolean runningFlag = true;
try {
    while (runningFlag) {
        int readCount = socket.getInputStream().read(buffer);
        String read2 = new String(buffer, 0, readCount);
        System.out.print("客户端出：" + read2 + "， 那我出：");
        String will = scanner.next();
        dataOutputStream.write(will.getBytes());
        dataOutputStream.flush();
    }
} catch (IOException e) {
    throw new RuntimeException(e);
}

代码对比如下：

修改服务端（`SocketServer.java`）代码

修改客户端（SocketClient.java）代码

boolean runningFlag = true;
try {
    while (runningFlag) {
        int readCount = socket.getInputStream().read(buffer);
        String read = new String(buffer, 0, readCount);
        System.out.print("服务器出：" + read + "， 那我出：");
        String will = scanner.next();
        dataOutputStream.write(will.getBytes());
        dataOutputStream.flush();
    }
} catch (IOException e) {
    throw new RuntimeException(e);
}

代码对比如下：

修改客户端（`SocketClient.java`）代码

运行结果如下：

互发内容

以上，仅供参考，收工！