Intellij?IDEA?的maven項(xiàng)目通過Java代碼實(shí)現(xiàn)Jetty的Http服務(wù)器(推薦)
Jetty是一個(gè)輕量級(jí)的高度可擴(kuò)展的基于 java的web服務(wù)器和servlet引擎。
下面是 使用 Intellij IDEA 的maven項(xiàng)目 通過Java代碼,實(shí)現(xiàn) Jetty 的 Http服務(wù)器 從而獲取到 Http 的 Get 和 Post 請(qǐng)求
一、添加 pom.xml


<!-- Jetty。要注意版本,版本匹配不對(duì)時(shí),運(yùn)行Jetty的應(yīng)用將會(huì)報(bào)錯(cuò)-->
<dependency>
<groupId>org.eclipse.jetty.aggregate</groupId>
<artifactId>jetty-all</artifactId>
<version>8.0.4.v20111024</version>
</dependency>二、在maven 加載 jetty

點(diǎn)擊 刷新 圖標(biāo) 系統(tǒng)會(huì)自動(dòng) 加載 jetty
加載完成后 就會(huì) 出現(xiàn)org.eclipse.jetty.aggregate:jetty-all:8.0.4.v20111024
三、新建AttendentConsoleHttpServlet.java
package com.SinaServer;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;import java.util.HashMap;
import java.util.Map;
/**
* @title: AttendentConsoleHttpServlet
* @Author wxj
* @Date: 2021/6/24 10:30
* @Version 1.0
*/
public class AttendentConsoleHttpServlet extends HttpServlet {
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException {
System.out.println(req.toString());
BufferedReader streamReader = new BufferedReader( new InputStreamReader(req.getInputStream(), "UTF-8"));
StringBuilder responseStrBuilder = new StringBuilder();
String inputStr;
while ((inputStr = streamReader.readLine()) != null)
responseStrBuilder.append(inputStr);
System.out.println(responseStrBuilder.toString());
//允許跨域
res.setHeader("Access-Control-Allow-Origin", "*");
res.setHeader("Access-Control-Allow-Methods", "*");
res.setHeader("Access-Control-Max-Age", "3600");
res.addHeader("Access-Control-Allow-Headers", "*");
res.setHeader("Access-Control-Allow-Credentials", "*");
//
//Map<String ,String> map = JSON.parseObject(Base64.decode(responseStrBuilder.toString()),Map.class);
//this.doGet(req, res);
}
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) {
response.setContentType("text/html;charset=utf-8");
response.setStatus(HttpServletResponse.SC_OK);
//允許跨域
response.setHeader("Access-Control-Allow-Origin", "*");
response.setHeader("Access-Control-Allow-Methods", "*");
response.setHeader("Access-Control-Max-Age", "3600");
response.addHeader("Access-Control-Allow-Headers", "*");
response.setHeader("Access-Control-Allow-Credentials", "*");
//
System.out.println("get request:");
Map<String, String[]> maps = request.getParameterMap();
HashMap<String,String> mapAction = new HashMap<>();
for (Map.Entry<String, String[]> entry : maps.entrySet()) {
//String cs = entry.getKey() + ":"+ Arrays.toString(entry.getValue())+";";
String cs = entry.getKey() + ":"+ entry.getValue()[0]+";";
System.out.println(cs);
mapAction.put(entry.getKey(),entry.getValue()[0]);
}
//如果包含action請(qǐng)求
String strResponse="";
if (mapAction.containsKey("action")){
switch (mapAction.get("action")){
case "query":
strResponse=this.query();
break;
default:
}
}
//
try {
response.getWriter().println(strResponse);
} catch (IOException e) {
e.printStackTrace();
}
}
public String query(){
String json="Hello Word! 已收到請(qǐng)求";
return json;
}
}四、在App.java 中 加入
package com.SinaServer;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.ContextHandlerCollection;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.servlet.ServletHolder;
/**
* Hello world!
*
*/
public class App
{
public static void main( String[] args )
{
System.out.println( "Hello World!111222" );
//jetty的處理集合
ContextHandlerCollection contexts = new ContextHandlerCollection();
//jetty http請(qǐng)求事件
ServletContextHandler context1 = new ServletContextHandler(ServletContextHandler.SESSIONS);
//httpapi
AttendentConsoleHttpServlet httpServletCli= new AttendentConsoleHttpServlet();
context1.addServlet(new ServletHolder(httpServletCli), "/httpCli");//httpapi
contexts.addHandler(context1);
//jetty服務(wù)器啟動(dòng)
Server server = new Server(5011);//設(shè)置端口
server.setHandler(contexts);
try {
server.start();//jetty服務(wù)器啟動(dòng)
System.out.println("Jetty Server 啟動(dòng)成功。port : 5011" );
server.join();
} catch (Exception e) {
e.printStackTrace();
System.out.println(e.getMessage());
}
}
}五、運(yùn)行 java

啟動(dòng)成功后 用瀏覽器 訪問
http://192.168.1.143:5011/httpCli?action=query

到此這篇關(guān)于Intellij IDEA 的maven項(xiàng)目通過Java代碼實(shí)現(xiàn) Jetty 的 Http服務(wù)器的文章就介紹到這了,更多相關(guān)Intellij IDEA Http服務(wù)器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
使用jaxp進(jìn)行dom解析_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
SpringBoot 中實(shí)現(xiàn)跨域的5種方式小結(jié)
IDEA 中使用 Big Data Tools 連接大數(shù)據(jù)組件
Springcloud微服務(wù)架構(gòu)基礎(chǔ)知識(shí)解析
java 分轉(zhuǎn)元與元轉(zhuǎn)分實(shí)現(xiàn)操作
IDEA工程運(yùn)行時(shí)總是報(bào)xx程序包不存在實(shí)際上包已導(dǎo)入(問題分析及解決方案)
基于java實(shí)現(xiàn)顏色拾色器并打包成exe

