Java的Socket网络编程

Java 网络编程是实现网络通信的重要技术,它可以帮助我们实现像聊天室、远程调用、下载、上传等网络应用。Java 网络编程是基于 TCP/IP 协议实现的,在 Java 中,可以使用 Socket 类来进行创建客户端和服务端之间的通信。Socket 类是在 java.net 包中实现的。

TCP/IP 网络协议

TCP/IP 是 Transmission Control Protocol / Internet Protocol,是一组网络通信协议,是因特网的基础。TCP/IP 协议族主要包括入门级协议(如 IP、ICMP)、传输层协议(如 TCP 与 UDP)和应用层协议(如 FTP、HTTP、SMTP 等)

  • IP(Internet Protocol)协议:用于对数据进行分组和转发,IP 把数据分成数据包进行传输,每个数据包包含发送地址、接收地址和其他相关信息。
  • ICMP(Internet Control Message Protocol)协议:用于对网络通信状态进行监控和调整,常用于 ping 命令。
  • TCP(Transmission Control Protocol)协议:是一种可靠的、面向连接的通信协议,负责提供高可靠性的数据传输。TCP 协议以字节流方式传输数据,会先建立连接再进行数据传输,所以可靠性更高,用于文件传输、电子邮件等传输较大数量的数据。
  • UDP(User Datagram Protocol)协议:是一种无连接、不可靠的通信协议,不需要先建立连接,不保证数据是否到达,用于实现视频、音频等实时传输的服务,速度更快。

ServerSocket

ServerSocket 是服务端的套接字对象,提供了用于监听客户端请求并接受连接请求的方法,在 TCP/IP 连接中服务端一般通过 ServerSocket 去监听客户端的 Socket 连接。主要方法如下:

  • void bind(SocketAddress endpoint, int backlog):将 ServerSocket 绑定到指定的端口和 IP 地址,并设置等待队列的长度(一般为 50)。
  • Socket accept():监听并等待客户端连接,返回一个 Socket 对象,该对象用于与客户端进行通信。
  • void close():关闭 ServerSocket 的连接。

其中,SocketAddress 类用于表示 IP 地址和端口号。

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

public class Server {
    public static void main(String[] args) {
        System.out.println("Server start.");

        try {
            // 创建 ServerSocket 对象,并监听指定的端口
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("Server started, listening on port " + serverSocket.getLocalPort());
            // 循环等待客户端的连接请求
            while (true) {
                // 阻塞等待客户端的连接请求
                Socket socket = serverSocket.accept();
                // 启动一个新的线程来处理请求
                new ServerThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Socket

Socket 是客户端的套接字对象,用于与服务端进行连接。主要方法如下:

  • void connect(SocketAddress endpoint):连接到指定 IP 地址和端口号的远程主机。
  • InputStream getInputStream():获取该 Socket 连接的输入流,可以从输入流读取远程主机发送的数据。
  • OutputStream getOutputStream():获取该 Socket 连接的输出流,可以向输出流写入数据。
  • void close():关闭 Socket 的连接。
import java.io.*;
import java.net.Socket;

public class Client {
    public static void main(String[] args) {
        System.out.println("Client start.");

        try {
            // 建立 Socket 连接,连接到服务端
            Socket socket = new Socket("localhost", 8888);
            // 获取 Socket 对应的输入流和输出流
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));

            // 向服务端发送消息
            out.println("Hello, World!");
            out.flush();
            // 接收服务端的消息并进行处理
            String response = in.readLine();
            System.out.println("Received from server: " + response);

            // 关闭流和 Socket 连接
            in.close();
            out.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

基于多线程的 Socket 通信

在多个客户端同时连接时,我们需要采用多线程的方式来处理。当服务端接收到客户端的请求之后,就开启一个新的线程来处理这个请求。这样就可以保证每个客户端的请求都能够得到相应的处理,并且不会阻塞其他客户端的连接和处理。主要代码如下:

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

public class ServerThread extends Thread {
    private Socket socket;

    public ServerThread(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        System.out.println("Client connected: " + socket.getRemoteSocketAddress());
        try {
            // 获取 Socket 对应的输入流和输出流
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));

            // 处理客户端请求
            String request = in.readLine();
            System.out.println("Received from client: " + request);
            out.println("Your message has been received. response success.");
            out.flush();

            // 关闭流和 Socket 连接
            in.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Java 网络编程应用

Java 网络编程应用非常广泛,例如可以实现网络聊天室、文件传输、远程调用等。示例代码:

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

public class NetworkApplication {
    public static void main(String[] args) throws IOException {
        // 创建服务端,监听客户端连接请求
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("Server started, listening on: " + serverSocket.getLocalSocketAddress());
        while (true) {
            // 阻塞等待客户端连接
            Socket socket = serverSocket.accept();
            // 客户端连接成功,启动线程处理请求
            new HandlerThread(socket).start();
        }
    }

    private static class HandlerThread extends Thread {
        private Socket socket;

        public HandlerThread(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            try {
                // 读取客户端传来的消息
                BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                StringBuilder message = new StringBuilder();
                String line;
                while ((line = reader.readLine()) != null) {
                    message.append(line);
                }
                System.out.println("Received message from client: " + message);

                // 发送响应
                PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
                writer.println("Hello, Client.");
                writer.flush();

                // 关闭流和 Socket 连接
                reader.close();
                writer.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

一个简单的 Java 网络应用就实现了,程序可以不停地监听客户端连接请求,收到请求之后就启动一个新的线程来处理客户端的请求。客户端连接时,就会向服务端发送消息,服务端接收消息之后向客户端回复一个消息。

总结

Java 网络编程是建立在 TCP/IP 协议上的网络通信技术,主要用于实现两个端点(客户端和服务端)之间的数据传输。在 Java 中,可以使用 Socket 类来实现网络编程,服务端通过 ServerSocket 监听客户端连接,客户端通过 Socket 连接服务端。在多个客户端连接时,需要使用多线程来处理。Java 网络编程的应用场景广泛。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,686评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,668评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,160评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,736评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,847评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,043评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,129评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,872评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,318评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,645评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,777评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,470评论 4 333
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,126评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,861评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,095评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,589评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,687评论 2 351

推荐阅读更多精彩内容