扫描二维码下载沐宇APP

沐宇

微信扫码使用沐宇小程序

沐宇

java socket濡備綍瀹炵幇蹇冭烦鏈哄埗

扬州沐宇科技
2024-06-27 18:22:29
Java

鍦↗ava涓紝鍙互浣跨敤Socket鏉ュ疄鐜板績璺虫満鍒讹紝閫氳繃鍦ㄥ鎴风鍜屾湇鍔″櫒绔彂閫佸拰鎺ユ敹蹇冭烦鍖呮潵淇濇寔杩炴帴鐨勬椿璺冩€с€備互涓嬫槸涓€涓畝鍗曠殑绀轰緥浠g爜鏉ュ疄鐜板績璺虫満鍒讹細

瀹㈡埛绔唬鐮侊細

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

public class Client {

    public static void main(String[] args) {
        String serverAddress = "127.0.0.1";
        int serverPort = 8888;

        try {
            Socket socket = new Socket(serverAddress, serverPort);
            OutputStream outputStream = socket.getOutputStream();

            while (true) {
                // 鍙戦€佸績璺冲寘
                String heartbeatMsg = "heartbeat";
                outputStream.write(heartbeatMsg.getBytes());
                outputStream.flush();

                Thread.sleep(5000); // 姣忛殧5绉掑彂閫佷竴娆″績璺冲寘
            }

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

鏈嶅姟鍣ㄧ浠g爜锛?/p>

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

public class Server {

    public static void main(String[] args) {
        int serverPort = 8888;

        try {
            ServerSocket serverSocket = new ServerSocket(serverPort);
            System.out.println("Server started...");

            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("Client connected: " + socket.getInetAddress());

                InputStream inputStream = socket.getInputStream();
                byte[] buffer = new byte[1024];

                int len;
                while ((len = inputStream.read(buffer)) != -1) {
                    String msg = new String(buffer, 0, len);
                    System.out.println("Received message: " + msg);

                    // 鍒ゆ柇鏄惁涓哄績璺冲寘
                    if (msg.equals("heartbeat")) {
                        System.out.println("Received heartbeat from client");
                    }
                }
            }

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

鍦ㄤ笂闈㈢殑绀轰緥浠g爜涓紝瀹㈡埛绔湪寰幆涓瘡闅?绉掑彂閫佷竴娆″績璺冲寘缁欐湇鍔″櫒锛屾湇鍔″櫒鎺ユ敹鍒板績璺冲寘鍚庤繘琛屽垽鏂苟杈撳嚭鐩稿叧淇℃伅銆傞€氳繃杩欑鏂瑰紡鍙互瀹炵幇绠€鍗曠殑蹇冭烦鏈哄埗鏉ヤ繚鎸佽繛鎺ョ殑娲昏穬鎬с€?/p>

扫码添加客服微信