Linux下的Java Socket通信是指在Linux操作系统环境下,使用Java编程语言实现的网络通信。Socket(套接字)是网络通信的基本构建块,它允许不同计算机之间通过网络进行数据交换。Java提供了java.net
包来处理Socket通信,包括TCP(传输控制协议)和UDP(用户数据报协议)两种类型。
java.net
包API,使得网络编程变得简单和高效。服务器端代码
import java.io.*;
import java.net.*;
public class TCPServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(8080);
System.out.println("Server started, listening on port 8080...");
Socket clientSocket = serverSocket.accept();
System.out.println("Client connected from " + clientSocket.getInetAddress());
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
String inputLine;
while ((inputLine = in.readLine()) != null) {
System.out.println("Received from client: " + inputLine);
out.println("Echo: " + inputLine);
}
clientSocket.close();
serverSocket.close();
}
}
客户端代码
import java.io.*;
import java.net.*;
public class TCPClient {
public static void main(String[] args) throws IOException {
Socket socket = new Socket("localhost", 8080);
System.out.println("Connected to server");
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;
while ((userInput = stdIn.readLine()) != null) {
out.println(userInput);
System.out.println("Server response: " + in.readLine());
}
socket.close();
}
}
服务器端代码
import java.io.*;
import java.net.*;
public class UDPServer {
public static void main(String[] args) throws IOException {
DatagramSocket socket = new DatagramSocket(8080);
System.out.println("Server started, listening on port 8080...");
byte[] buffer = new byte[1024];
DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
while (true) {
socket.receive(packet);
String received = new String(packet.getData(), 0, packet.getLength());
System.out.println("Received from client: " + received);
byte[] sendData = ("Echo: " + received).getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, packet.getAddress(), packet.getPort());
socket.send(sendPacket);
}
}
}
客户端代码
import java.io.*;
import java.net.*;
public class UDPClient {
public static void main(String[] args) throws IOException {
DatagramSocket socket = new DatagramSocket();
InetAddress address = InetAddress.getByName("localhost");
int port = 8080;
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
String userInput;
while ((userInput = stdIn.readLine()) != null) {
byte[] sendData = userInput.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, address, port);
socket.send(sendPacket);
byte[] buffer = new byte[1024];
DatagramPacket receivePacket = new DatagramPacket(buffer, buffer.length);
socket.receive(receivePacket);
String received = new String(receivePacket.getData(), 0, receivePacket.getLength());
System.out.println("Server response: " + received);
}
socket.close();
}
}
通过以上内容,您应该对Linux下Java Socket通信有了全面的了解,并能够解决常见的通信问题。
领取专属 10元无门槛券
手把手带您无忧上云