当前位置：首页 > 后端开发 > 正文

怎么样用java接收数据

admin
后端开发
2025-08-08
6

Java中，可以使用Socket编程通过 InputStream接收数据，或使用网络库如Netty

Java中接收数据有多种方式,具体取决于数据的来源和传输方式，以下是几种常见的场景及相应的接收数据方法：

从标准输入（控制台）接收数据

Java提供了Scanner类和BufferedReader类来从标准输入流（通常是键盘输入）读取数据。

使用Scanner类：

import java.util.Scanner; public class ConsoleInputExample { public static void main(String[] args) { Scanner scanner = new Scanner(System.in); System.out.print("请输入您的名字: "); String name = scanner.nextLine(); System.out.print("请输入您的年龄: "); int age = scanner.nextInt(); System.out.println("您好, " + name + "! 您今年 " + age + " 岁。"); scanner.close(); } }

使用BufferedReader类：

import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.IOException; public class BufferedReaderExample { public static void main(String[] args) { BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); try { System.out.print("请输入您的名字: "); String name = reader.readLine(); System.out.print("请输入您的年龄: "); int age = Integer.parseInt(reader.readLine()); System.out.println("您好, " + name + "! 您今年 " + age + " 岁。"); } catch (IOException e) { e.printStackTrace(); } } }

从文件接收数据

Java的FileReader、BufferedReader以及Scanner类都可以用于从文件中读取数据。

使用BufferedReader读取文件：

import java.io.BufferedReader; import java.io.FileReader; import java.io.IOException; public class FileReadExample { public static void main(String[] args) { String filePath = "data.txt"; // 替换为你的文件路径 try (BufferedReader br = new BufferedReader(new FileReader(filePath))) { String line; while ((line = br.readLine()) != null) { System.out.println(line); } } catch (IOException e) { e.printStackTrace(); } } }

使用Scanner读取文件：

从网络接收数据

Java的Socket类和ServerSocket类用于网络通信，可以接收来自客户端的数据。

简单的服务器端接收数据示例：

import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; import java.io.IOException; public class ServerExample { public static void main(String[] args) { int port = 12345; // 监听端口 try (ServerSocket serverSocket = new ServerSocket(port)) { System.out.println("服务器已启动，等待客户端连接..."); try (Socket clientSocket = serverSocket.accept(); BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()))) { String receivedData = in.readLine(); System.out.println("收到来自客户端的数据: " + receivedData); } } catch (IOException e) { e.printStackTrace(); } } }

客户端发送数据示例：

import java.io.PrintWriter; import java.net.Socket; import java.io.IOException; public class ClientExample { public static void main(String[] args) { String host = "localhost"; // 服务器地址 int port = 12345; // 服务器端口 try (Socket socket = new Socket(host, port); PrintWriter out = new PrintWriter(socket.getOutputStream(), true)) { out.println("Hello, Server!"); } catch (IOException e) { e.printStackTrace(); } } }

从URL或网页接收数据

Java的URL和URLConnection类可以用于从网页或API获取数据。

使用URL类读取网页内容：

从数据库接收数据

使用JDBC（Java Database Connectivity）可以从数据库中检索数据，以下是一个使用MySQL数据库的示例：

JDBC查询示例：

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.sql.SQLException; public class JDBCExample { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb"; // 数据库URL String user = "root"; // 数据库用户名 String password = "password"; // 数据库密码 try { Connection conn = DriverManager.getConnection(url, user, password); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery("SELECT id, name FROM users"); while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); System.out.println("ID: " + id + ", Name: " + name); } rs.close(); stmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }

从串口接收数据

对于与硬件设备通过串口通信的场景,可以使用第三方库如RXTX或jSerialCom，以下是使用jSerialCom的简单示例：

使用jSerialCom接收串口数据：

import com.fazecast.jSerialComm.SerialPort; public class SerialPortExample { public static void main(String[] args) { SerialPort[] ports = SerialPort.getCommPorts(); if (ports.length == 0) { System.out.println("没有找到串口设备。"); return; } SerialPort serialPort = ports[0]; // 选择第一个串口 serialPort.setComPortParameters(9600, 8, SerialPort.ONE_STOP_BIT, SerialPort.NO_PARITY); serialPort.setComPortTimeouts(SerialPort.TIMEOUT_READ_SEMI_BLOCKING, 1000, 0); if (serialPort.openPort()) { System.out.println("串口已打开: " + serialPort.getSystemPortName()); try { byte[] readBuffer = new byte[1024]; int numRead = serialPort.readBytes(readBuffer, readBuffer.length); String receivedData = new String(readBuffer, 0, numRead); System.out.println("收到的数据: " + receivedData); serialPort.closePort(); } catch (Exception e) { e.printStackTrace(); } } else { System.out.println("无法打开串口。"); } } }

注意：使用前需添加jSerialCom库到项目中。

从消息队列接收数据（如RabbitMQ）

使用消息队列进行数据传输时,可以利用相应的客户端库来接收消息，以下是使用RabbitMQ的简单示例：

使用RabbitMQ接收消息：

import com.rabbitmq.client.; public class RabbitMQReceiver { private final static String QUEUE_NAME = "hello"; public static void main(String[] args) throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); // 替换为你的RabbitMQ服务器地址 try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.out.println("等待消息..."); DeliverCallback deliverCallback = (consumerTag, delivery) -> { String message = new String(delivery.getBody(), "UTF-8"); System.out.println("收到消息: '" + message + "'"); }; channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {}); } } }

注意：使用前需添加RabbitMQ客户端库到项目中。

归纳表格

数据来源	使用的类或库	示例场景
标准输入	Scanner, BufferedReader	控制台输入
文件	FileReader, BufferedReader, Scanner	读取文本文件
网络	Socket, ServerSocket	客户端-服务器通信
URL/网页	URL, URLConnection	获取网页内容或API数据
数据库	JDBC (Connection, Statement, ResultSet)	从数据库查询数据
串口	jSerialCom (SerialPort)	与硬件设备通信
消息队列（RabbitMQ）	RabbitMQ客户端库	分布式系统中的消息传递