当前位置：首页 > Java

java如何接收数据

2026-03-22 00:58:44Java

Java接收数据的方法

通过控制台输入 使用Scanner类从控制台接收用户输入。需要导入java.util.Scanner包。

Scanner scanner = new Scanner(System.in);
String input = scanner.nextLine();
int number = scanner.nextInt();
scanner.close();

通过文件读取 使用FileReader或BufferedReader读取文件数据。

java如何接收数据

BufferedReader reader = new BufferedReader(new FileReader("file.txt"));
String line = reader.readLine();
reader.close();

通过网络接收 使用Socket或ServerSocket接收网络数据。

ServerSocket serverSocket = new ServerSocket(8080);
Socket socket = serverSocket.accept();
InputStream input = socket.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(input));
String data = reader.readLine();
socket.close();

通过HTTP请求 使用HttpURLConnection或第三方库如Apache HttpClient接收HTTP响应数据。

java如何接收数据

URL url = new URL("http://example.com");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String line;
while ((line = reader.readLine()) != null) {
    System.out.println(line);
}
reader.close();

通过数据库查询 使用JDBC连接数据库并执行查询。

Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db", "user", "password");
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM table");
while (resultSet.next()) {
    String data = resultSet.getString("column");
}
resultSet.close();
statement.close();
connection.close();

通过消息队列 使用JMS或类似技术从消息队列接收数据。

ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("queue");
MessageConsumer consumer = session.createConsumer(destination);
Message message = consumer.receive();
if (message instanceof TextMessage) {
    String text = ((TextMessage) message).getText();
}
connection.close();