java socket濡備綍瀹炵幇蹇冭烦鏈哄埗
鍦↗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>
相关问答