了解java原生网络api有助于理解底层通信机制,为排查问题和学习高级框架打下基础;2. 处理post请求需设置setrequestmethod("post")、setdooutput(true)、设置content-type头并写入请求体;3. 异步请求可通过线程池或completablefuture实现,与同步请求的主要区别在于异步不会阻塞主线程,能提升程序响应性和吞吐量,而同步请求则按顺序执行并等待结果。

Java里要实现简单的网络请求,其实入门门槛并不高,最直接的方法就是用它内置的
java.net
解决方案:
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class SimpleHttpRequest {
public static void main(String[] args) {
String targetUrl = "https://www.example.com"; // 替换成你想请求的网址
try {
// 1. 创建URL对象
URL url = new URL(targetUrl);
// 2. 打开连接
// URLConnection是抽象类,HttpURLConnection是其子类,专门处理HTTP/HTTPS
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
// 3. 设置请求方法 (默认为GET,但明确写出来更清晰)
connection.setRequestMethod("GET");
// 4. 设置连接和读取超时时间(可选,但推荐)
connection.setConnectTimeout(5000); // 5秒连接超时
connection.setReadTimeout(5000); // 5秒读取超时
// 5. 获取响应码
int responseCode = connection.getResponseCode();
System.out.println("响应码: " + responseCode);
// 6. 读取服务器响应
// 如果响应码是200 OK,就从正常输入流读取;否则从错误流读取
BufferedReader in;
if (responseCode == HttpURLConnection.HTTP_OK) {
in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
} else {
in = new BufferedReader(new InputStreamReader(connection.getErrorStream()));
}
String inputLine;
StringBuilder content = new StringBuilder();
while ((inputLine = in.readLine()) != null) {
content.append(inputLine);
}
in.close(); // 关闭输入流
// 7. 打印响应内容
System.out.println("响应内容:\n" + content.toString());
} catch (IOException e) {
// 处理可能发生的网络错误、URL格式错误等
System.err.println("网络请求发生错误: " + e.getMessage());
e.printStackTrace();
} finally {
// 8. 关闭连接 (在try-with-resources或finally块中确保关闭)
// 对于HttpURLConnection,通常不需要显式调用disconnect(),
// 因为当输入/输出流关闭后,连接会自动关闭或被连接池管理。
// 但如果需要立即释放资源,可以调用。
// connection.disconnect();
}
}
}说实话,现在市面上那么多好用的HTTP客户端库,比如Apache HttpClient、OkHttp,甚至Spring WebClient,它们用起来确实方便,功能也强大。但我觉得,作为开发者,尤其是刚接触网络编程的,花点时间理解Java原生的
java.net
立即学习“Java免费学习笔记(深入)”;
首先,它能让你对网络通信的底层逻辑有个清晰的认知。那些高级框架,说到底,都是在这些原生API之上封装出来的。当你遇到一些奇奇怪怪的网络问题时,如果对底层机制一无所知,就很难定位。比如,连接超时和读取超时有什么区别?HTTP状态码的含义?这些都是基础,原生API的用法能帮你把这些概念具象化。
再者,对于一些非常轻量级、对依赖包大小有严格要求的项目,或者你需要实现一些非标准协议的通信时,原生API的优势就体现出来了。你不需要引入一个庞大的第三方库,就能完成任务。有时候,你只是想简单地发个GET请求,拿个JSON回来,用原生API,代码量可能也就多几行,但省去了配置和依赖管理的麻烦。
最后,这是一种“知其然,更知其所以然”的成就感。当你亲手写出一段代码,看着它从一个URL地址,一步步地打开连接,发送请求,然后把服务器的响应数据一行行读回来,那种感觉是直接调用一个
client.get().execute()
从GET到POST,或者再到PUT、DELETE这些HTTP方法,本质上最主要的区别在于你是否需要向服务器“发送数据”。GET请求通常只从服务器获取数据,数据在URL参数里;而POST请求则需要把数据放在请求体(request body)里发送出去。
对于Java原生的
HttpURLConnection
connection.setRequestMethod("POST");connection.setDoOutput(true);
Content-Type
application/json
application/x-www-form-urlencoded
connection.getOutputStream()
举个例子,如果你要发送JSON数据,代码可能会是这样:
// ... 前面创建URL和连接的部分类似
connection.setRequestMethod("POST");
connection.setDoOutput(true); // 允许输出
connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); // 设置内容类型
String jsonInputString = "{\"name\": \"John Doe\", \"age\": 30}"; // 你的JSON数据
try (OutputStream os = connection.getOutputStream()) {
byte[] input = jsonInputString.getBytes("utf-8");
os.write(input, 0, input.length);
}
// ... 后面读取响应的部分和GET请求类似除了POST,其他像PUT、DELETE等方法也是类似的处理方式,关键在于你是否需要发送请求体,以及如何设置正确的HTTP方法和请求头。此外,处理更复杂的场景,比如文件上传(multipart/form-data)、自定义请求头、Cookie管理、HTTPS证书验证等,原生API虽然能实现,但代码会变得相当复杂和冗长。这也是为什么在实际项目中,大家更倾向于使用那些封装好的高级框架,它们把这些复杂性都隐藏起来了,让你能更专注于业务逻辑。
我们上面讲的
HttpURLConnection
connection.getInputStream()
connection.getResponseCode()
异步网络请求的核心思想是:发起请求后,当前线程不需要等待响应,可以立即去做其他事情。当网络请求有结果(无论是成功还是失败)时,会通过某种回调机制或者通知机制来告诉你。
在Java中实现异步网络请求,有几种常见的方式:
使用线程池:这是最直接也最常用的方法。你可以把每个网络请求封装成一个
Runnable
Callable
ExecutorService
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.Callable;
// ... 其他必要的import
public class AsyncHttpRequest {
private static final ExecutorService executor = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池
public static void makeAsyncRequest(String urlString) {
Callable<String> task = () -> {
// 这里放入之前同步请求的代码逻辑,比如创建URL, 打开连接,读取响应等
// 确保处理IOException并返回结果或抛出异常
try {
URL url = new URL(urlString);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
// ... 读取响应内容
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
StringBuilder content = new StringBuilder();
String inputLine;
while ((inputLine = in.readLine()) != null) {
content.append(inputLine);
}
in.close();
return content.toString();
} catch (IOException e) {
throw new RuntimeException("Async request failed: " + e.getMessage(), e);
}
};
Future<String> future = executor.submit(task); // 提交任务
// 你可以在这里做其他事情,不需要等待
System.out.println("异步请求已提交,主线程继续执行...");
// 稍后需要结果时,可以调用future.get(),但会阻塞直到结果可用
// 更好的方式是在另一个线程或回调中处理结果
try {
String result = future.get(); // 实际项目中,通常不在这里立即get()
System.out.println("异步请求完成,结果是:\n" + result.substring(0, Math.min(result.length(), 200)) + "...");
} catch (Exception e) {
System.err.println("异步请求获取结果失败: " + e.getMessage());
}
}
public static void main(String[] args) {
makeAsyncRequest("https://www.baidu.com");
makeAsyncRequest("https://www.qq.com");
// ... 你的主程序可以继续做其他事情
executor.shutdown(); // 在程序结束时关闭线程池
}
}使用CompletableFuture
// 假设你有一个方法来执行同步请求
public static String doSyncRequest(String urlString) throws IOException {
// ... 之前的同步请求代码 ...
URL url = new URL(urlString);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
// ... 读取响应内容
BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
StringBuilder content = new StringBuilder();
String inputLine;
while ((inputLine = in.readLine()) != null) {
content.append(inputLine);
}
in.close();
return content.toString();
}
public static void main(String[] args) {
// 使用CompletableFuture进行异步请求
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
try {
return doSyncRequest("https://www.baidu.com");
} catch (IOException e) {
throw new RuntimeException(e); // 包装为非受检异常
}
});
CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
try {
return doSyncRequest("https://www.qq.com");
} catch (IOException e) {
throw new RuntimeException(e);
}
});
// 当future1完成时
future1.thenAccept(result -> {
System.out.println("百度请求完成,结果片段: " + result.substring(0, Math.min(result.length(), 100)));
}).exceptionally(ex -> {
System.err.println("百度请求失败: " + ex.getMessage());
return null; // 返回null表示异常已处理
});
// 当future2完成时
future2.thenAccept(result -> {
System.out.println("腾讯请求完成,结果片段: " + result.substring(0, Math.min(result.length(), 100)));
}).exceptionally(ex -> {
System.err.println("腾讯请求失败: " + ex.getMessage());
return null;
});
// 主线程可以继续做其他事情
System.out.println("主线程继续执行,等待异步请求完成...");
// 为了让主线程不立即退出,等待所有异步任务完成
CompletableFuture.allOf(future1, future2).join();
System.out.println("所有异步请求处理完毕。");
}同步与异步的主要区别在于程序的执行流程和资源利用。同步是串行的,一个任务没完成,下一个就得等着,这可能导致界面卡顿或服务器吞吐量低。异步则是并行的,你发起请求后可以立即处理其他任务,当请求完成后再回来处理结果,这大大提高了程序的响应性和资源利用率。在现代网络应用中,尤其是有大量I/O操作的场景,异步编程几乎是标配。
以上就是java代码如何实现简单的网络请求 java代码网络编程的入门方法的详细内容,更多请关注php中文网其它相关文章!
java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号