java HttpServer构建http服务器_起一个好听的名字的博客-程序员宅基地

技术标签： HTTPClient

介绍摘自网络:

JDK6提供了一个简单的Http Server API,据此我们可以构建自己的嵌入式Http Server,它支持Http和Https协议,提供了HTTP1.1的部分实现，没有被实现的那部分可以通过扩展已有的Http Server API来实现,程序员必须自己实现HttpHandler接口,HttpServer会调用HttpHandler实现类的回调方法来处理客户端请求,在这里,我们把一个Http请求和它的响应称为一个交换,包装成HttpExchange类,HttpServer负责将HttpExchange传给HttpHandler实现类的回调方法

我想开发一个j2se的小程序，它能接受网页传来的参数，并对传来参数做些处理。我希望这个小程序即可能接受网页传过来的参数，也能接受OutputStream流传来参数，JDK6新特性能够实现。

一、提供http服务的类

Java代码

package com.tdt.server.httpserver;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import com.sun.net.httpserver.spi.HttpServerProvider;
/**
* @project SimpleHttpServer
* @author sunnylocus
* @vresion 1.0 2009-9-2
* @description 自定义的http服务器
*/
public class MyHttpServer {
//启动服务，监听来自客户端的请求
public static void httpserverService() throws IOException {
HttpServerProvider provider = HttpServerProvider.provider();
HttpServer httpserver =provider.createHttpServer(new InetSocketAddress(6666), 100);//监听端口6666,能同时接受100个请求
httpserver.createContext("/myApp", new MyHttpHandler());
httpserver.setExecutor(null);
httpserver.start();
System.out.println("server started");
}
//Http请求处理类
static class MyHttpHandler implements HttpHandler {
public void handle(HttpExchange httpExchange) throws IOException {
String responseMsg = "ok"; //响应信息
InputStream in = httpExchange.getRequestBody(); //获得输入流
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
String temp = null;
while((temp = reader.readLine()) != null) {
System.out.println("client request:"+temp);
}
httpExchange.sendResponseHeaders(200, responseMsg.length()); //设置响应头属性及响应信息的长度
OutputStream out = httpExchange.getResponseBody(); //获得输出流
out.write(responseMsg.getBytes());
out.flush();
httpExchange.close();
}
}
public static void main(String[] args) throws IOException {
httpserverService();
}
}

二、测试类

Java代码

package com.tdt.server.test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* @project SimpleHttpServer
* @author sunnylocus
* @vresion 1.0 2009-9-2
* @description 测试类
*/
public class Test {
public static void main(String[] args) {
ExecutorService exec = Executors.newCachedThreadPool();
// 测试并发对MyHttpServer的影响
for (int i = 0; i < 20; i++) {
Runnable run = new Runnable() {
public void run() {
try {
startWork();
} catch (IOException e) {
e.printStackTrace();
}
}
};
exec.execute(run);
}
exec.shutdown();// 关闭线程池
}
public static void startWork() throws IOException {
URL url = new URL("http://127.0.0.1:6666/myApp");
HttpURLConnection urlConn = (HttpURLConnection) url.openConnection();
urlConn.setDoOutput(true);
urlConn.setDoInput(true);
urlConn.setRequestMethod("POST");
// 测试内容包
String teststr = "this is a test message";
OutputStream out = urlConn.getOutputStream();
out.write(teststr.getBytes());
out.flush();
while (urlConn.getContentLength() != -1) {
if (urlConn.getResponseCode() == 200) {
InputStream in = urlConn.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
String temp = "";
while ((temp = reader.readLine()) != null) {
System.err.println("server response:" + temp);// 打印收到的信息
}
reader.close();
in.close();
urlConn.disconnect();
}
}
}
}

注意：经过我测试发现httpExchange.sendResponseHeaders(200, responseMsg.length())有bug,如果responseMsg里面包含中文的话，客户端不会收到任何信息，因为一个汉字用二个字节表示。

应修改为：

httpExchange.sendResponseHeaders(HttpURLConnection.HTTP_OK, responseMsg.getBytes().length);

本文链接：https://blog.csdn.net/qq_29663071/article/details/52385411

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

Windows和PyCharm常用快捷键_Le0v1n的博客-程序员宅基地

Windows这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.这是一行测试语言, 没有其他的含义.Shiftshift, 又名换挡键, 一般是Shift + 其他按键多选Shift + ←/→可以实现选中文字按下shift + →多按几次shift + →Shift + 鼠标

MATLAB WRanksum test,python与Matlab的ranksum等价物是什么？_f飞姐的博客-程序员宅基地

这取决于您使用的选项。检查以下示例：1-MATLABrng('default') % for reproducibilityx = unifrnd(0,1,20,1);y = unifrnd(0.25,1.25,20,1);p = ranksum(x,y);p =0.25032-Python(为了保持一致，我没有再次生成数字，但是我已经将MATLAB中生成的数字移动到Python脚本中)^{pr2...

linux命令管道工作原理与使用方法_weixin_34198762的博客-程序员宅基地

一、管道定义管道是一种两个进程间进行单向通信的机制。因为管道传递数据的单向性，管道又称为半双工管道。管道的这一特点决定了器使用的局限性。管道是Linux支持的最初Unix IPC形式之一，具有以下特点：*** 数据只能由一个进程流向另一个进程（其中一个读管道，一个写管道）；如果要进行双工通信，需要建立两个管道。*** 管道只能用于父子进程或者兄弟进程间通信。，也就是说管道只能用...

python生成带有调用第三方库的exe可执行文件_起个名字都难啊的博客-程序员宅基地_python打包exe 带第三方库

python代码生成exe的工具有多种，以pyinstaller为例：python代码中含有第三方库，比如opencv时，需要指定库的路径，这会使pyinstaller将库打包进生成的exe中，否则运行exe时会出现缺少xxx库。指令：pyinstaller -F -w -i skull.ico -p "D:\install file\python3.7.9\Lib\site-packages" test22.py参数含义-F 指定打包后只生成一个exe格式的文件-D 创建一个目

java git打包iOS_Jenkins实现iOS项目自动化打包(含踩坑记录)_weixin_39955781的博客-程序员宅基地

一、前言这段时间一直在参与开发前端项目。与iOS工作流程不同的是，前端给QA提测前，只需将feature分支代码合到一个指定的分支。然后QA人员会通过Jenkins工具进行项目的构建部署。之前在探索iOS的自动化打包时，就听过Jenkins的大名，但是一直没去了解。这次借此机会由最擅长的iOS项目为切入点，开始对Jenkins的探索。二、安装Jenkins**Jenkins**依赖了Java环境，...

Web开发（初级）- HTML基础_weixin_33721344的博客-程序员宅基地

HTML简介 HTML是英文Hyper Text Mark-up Language(超文本标记语言)的缩写，他是一种制作万维网页面标准语言（标记）。相当于定义统一的一套规则，大家都来遵守他，这样就可以让浏览器根据标记语言的规则去解释它。浏览器负责将标签翻译成用户“看得懂”的格式，呈现给用户！(例：django模版引擎)HTML文档Doctype<!DOCTYPEh...