Java之ServerSocket使用及说明

 更新时间:2025年11月24日 15:04:54   作者:Java杨永杰  
本文介绍了Java中ServerSocket类的使用方法,包括创建ServerSocket对象、绑定端口、监听连接请求、接受连接、关闭连接等常用方法,还通过两个案例分别展示了如何使用ServerSocket实现TCP和UDP通信

前言

Java中的ServerSocket是一种用于建立服务器端socket的类。它允许程序在指定端口上监听客户端的连接请求,并在连接成功后与客户端进行数据交互。

ServerSocket类提供了一些方法,用于控制服务器端socket的行为,如绑定端口、监听连接请求、接受连接、关闭连接等。

常用方法

以下是ServerSocket类的一些常用方法:

  • ServerSocket(int port): 构造器,用于创建一个指定端口的ServerSocket对象。
  • void bind(SocketAddress endpoint):将ServerSocket绑定到指定的端口,可以是本地或远程端口。
  • Socket accept():监听并接受客户端的连接请求,返回一个与客户端建立连接后的Socket对象。
  • void close():关闭ServerSocket以及与之关联的所有Socket连接。

使用

ServerSocket的使用步骤如下:

  • 创建ServerSocket对象,并指定监听的端口。
  • 调用bind()方法将ServerSocket绑定到指定端口。
  • 调用accept()方法监听并接受客户端的连接请求。
  • 使用返回的Socket对象与客户端进行数据交互。
  • 使用完毕后,调用close()方法关闭ServerSocket以及与之关联的所有Socket连接。

ServerSocket的常见应用场景包括:建立Web服务器、FTP服务器、邮件服务器等需要监听客户端连接请求的网络服务。

案例

1.实现TCP

要使用ServerSocket实现TCP连接,可以按照以下步骤进行操作:

  • 创建ServerSocket对象,并指定要监听的端口号。
ServerSocket serverSocket = new ServerSocket(port);
  • 调用accept()方法监听并接受客户端的连接请求。accept()方法会阻塞程序直到有客户端连接成功,并返回与客户端建立连接后的Socket对象。
Socket socket = serverSocket.accept();
  • 使用返回的Socket对象与客户端进行数据交互。可以使用InputStream和OutputStream来接收和发送数据。
// 从客户端读取数据
InputStream inputStream = socket.getInputStream();
DataInputStream dataInputStream = new DataInputStream(inputStream);
String clientMessage = dataInputStream.readUTF();

// 向客户端发送数据
OutputStream outputStream = socket.getOutputStream();
DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
dataOutputStream.writeUTF("Hello Client!");
  • 使用完毕后,调用close()方法关闭ServerSocket以及与之关联的所有Socket连接。
serverSocket.close();

完整的示例代码如下:

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPServer {

    public static void main(String[] args) {
        int port = 1234;

        try {
            // 创建ServerSocket对象
            ServerSocket serverSocket = new ServerSocket(port);

            System.out.println("Server started and listening on port " + port);

            // 监听并接受客户端的连接请求
            Socket socket = serverSocket.accept();

            System.out.println("Client connected: " + socket.getInetAddress().getHostAddress());

            // 从客户端读取数据
            InputStream inputStream = socket.getInputStream();
            DataInputStream dataInputStream = new DataInputStream(inputStream);
            String clientMessage = dataInputStream.readUTF();
            System.out.println("Received message from client: " + clientMessage);

            // 向客户端发送数据
            OutputStream outputStream = socket.getOutputStream();
            DataOutputStream dataOutputStream = new DataOutputStream(outputStream);
            dataOutputStream.writeUTF("Hello Client!");

            // 关闭连接
            socket.close();
            serverSocket.close();

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

这个示例代码创建了一个简单的TCP服务器,监听在端口1234上。当有客户端连接成功后,服务器会从客户端接收一条消息,并向客户端发送一条回复消息。完成后,服务器关闭连接。

要测试该示例代码,可以编写一个TCP客户端,使用相同的端口号连接到服务器,发送消息并接收回复。

2.实现UDP

要使用ServerSocket实现UDP连接,可以按照以下步骤操作:

  • 创建DatagramSocket对象,并指定要监听的端口号。
DatagramSocket serverSocket = new DatagramSocket(port);
  • 创建一个字节数组用于接收数据。
byte[] receiveData = new byte[1024];
  • 创建一个DatagramPacket对象,用于接收从客户端发送过来的数据。
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
  • 使用receive()方法从客户端接收数据。该方法会阻塞程序直到接收到数据。
serverSocket.receive(receivePacket);
  • 使用DatagramPacket对象获取接收到的数据,并进行相应处理。
String clientMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());
  • 可以使用DatagramPacket对象获取客户端的IP地址和端口号。
InetAddress clientIPAddress = receivePacket.getAddress();
int clientPort = receivePacket.getPort();
  • 可以使用DatagramSocket对象向客户端发送数据。首先创建一个字节数组和一个DatagramPacket对象。
String serverMessage = "Hello Client!";
byte[] sendData = serverMessage.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, clientIPAddress, clientPort);
  • 使用send()方法将数据发送给客户端。
serverSocket.send(sendPacket);
  • 使用完毕后,调用close()方法关闭DatagramSocket。
serverSocket.close();

完整的示例代码如下:

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPServer {

    public static void main(String[] args) {
        int port = 1234;

        try {
            // 创建DatagramSocket对象
            DatagramSocket serverSocket = new DatagramSocket(port);

            System.out.println("Server started and listening on port " + port);

            // 创建一个字节数组用于接收数据
            byte[] receiveData = new byte[1024];

            // 创建一个DatagramPacket对象,用于接收数据
            DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);

            // 接收从客户端发送的数据
            serverSocket.receive(receivePacket);

            // 获取接收到的数据和客户端的信息
            String clientMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());
            InetAddress clientIPAddress = receivePacket.getAddress();
            int clientPort = receivePacket.getPort();

            System.out.println("Received message from client: " + clientMessage);

            // 向客户端发送数据
            String serverMessage = "Hello Client!";
            byte[] sendData = serverMessage.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, clientIPAddress, clientPort);
            serverSocket.send(sendPacket);

            // 关闭连接
            serverSocket.close();

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

这个示例代码创建了一个简单的UDP服务器,监听在端口1234上。当有客户端发送数据时,服务器会接收并打印出来,然后向客户端发送一条回复消息。完成后,服务器关闭连接。

要测试该示例代码,可以编写一个UDP客户端,使用相同的端口号连接到服务器,发送数据并接收回复。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • SpringData JPA审计功能(@CreatedDate与@LastModifiedDate)实现

    SpringData JPA审计功能(@CreatedDate与@LastModifiedDate)实现

    Spring Data JPA的审计功能提供了一种强大而灵活的机制,用于自动跟踪实体的创建和修改信息,通过使用@CreatedDate和@LastModifiedDate注解,开发者可以轻松地实现时间审计,感兴趣的可以了解一下
    2025-04-04
  • SpringAop @Aspect织入不生效,不执行前置增强织入@Before方式

    SpringAop @Aspect织入不生效,不执行前置增强织入@Before方式

    这篇文章主要介绍了SpringAop @Aspect织入不生效,不执行前置增强织入@Before方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • 替换jar包中的依赖jar实现方式

    替换jar包中的依赖jar实现方式

    在没有源码的情况下替换JAR包中的依赖包,可以通过以下步骤完成:备份原始JAR包,进入JAR包的BOOT-INF/lib目录,删除旧的依赖包并替换为新的依赖包,最后重新打包
    2025-12-12
  • SpringBoot整合Sa-Token实现登录认证的示例代码

    SpringBoot整合Sa-Token实现登录认证的示例代码

    本文主要介绍了SpringBoot整合Sa-Token实现登录认证的示例代码,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-01-01
  • SpringBoot统一数据返回的方法实现

    SpringBoot统一数据返回的方法实现

    在前后端交互过程中,为了便于数据处理,后端数据需要进行统一封装返回给前端,这种做法不仅方便前后端沟通,降低了沟通成本,还有助于项目的统一维护和后端技术部门的规范制定,本文就来介绍一下
    2024-10-10
  • Java中ArrayList类的源码解析

    Java中ArrayList类的源码解析

    本文主要介绍了Java中ArrayList类的源码解析,具有很好的参考价值。下面跟着小编一起来看下吧
    2017-03-03
  • Java面试题冲刺第二十六天--实战编程

    Java面试题冲刺第二十六天--实战编程

    这篇文章主要为大家分享了最有价值的三道java实战面试题,涵盖内容全面,包括数据结构和算法相关的题目、经典面试编程题等,感兴趣的小伙伴们可以参考一下
    2021-08-08
  • Tomcat处理请求的线程模型详解

    Tomcat处理请求的线程模型详解

    这篇文章主要为大家详细介绍了Tomcat处理请求的线程模型,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下,希望能够给你带来帮助
    2022-03-03
  • 详解Java线程池队列中的延迟队列DelayQueue

    详解Java线程池队列中的延迟队列DelayQueue

    这篇文章主要为大家详细介绍了Java线程池队列中的延迟队列DelayQueue的相关资料,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
    2022-12-12
  • SpringBoot项目集成MinIO全过程

    SpringBoot项目集成MinIO全过程

    这篇文章主要介绍了SpringBoot项目集成MinIO全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-08-08

最新评论