为什么网站要备案,做汽配外贸哪个网站,代理网站官网,vps 搭建wordpress内嵌式服务器不需要我们单独部署#xff0c;列如SpringBoot默认内嵌服务器Tomcat,它运行在服务内部。使用Netty 编写一个 Http 服务器的程序#xff0c;类似SpringMvc处理http请求那样。举例#xff1a;xxl-job项目的核心包没有SpringMvc的Controller层#xff0c;客户端却…内嵌式服务器不需要我们单独部署列如SpringBoot默认内嵌服务器Tomcat,它运行在服务内部。使用Netty 编写一个 Http 服务器的程序类似SpringMvc处理http请求那样。举例xxl-job项目的核心包没有SpringMvc的Controller层客户端却可以发送http请求好奇怪其实xxl-job-core 内部使用Netty做了HttpServer。 package com.xxl.job.executor.test.dto;import lombok.Getter;
import lombok.Setter;/*** User: ldj* Date: 2024/10/11* Time: 11:23* Description: No Description*/
Getter
Setter
public class RequestDTOT {/*** 请求ur*/private String uri;/*** 请求参数*/private T param;
}package com.xxl.job.executor.test.netty;import com.xxl.job.executor.test.handler.NettyHttpServerHandler;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.timeout.IdleStateHandler;import java.util.concurrent.TimeUnit;/*** User: ldj* Date: 2024/10/11* Time: 10:57* Description: Netty Http服务*/
public class NettyHttpServer {public static void main(String[] args) {// 服务端口int port 9990;// 接收请求线程池EventLoopGroup bossGroup new NioEventLoopGroup();// 处理请求线程池EventLoopGroup workerGroup new NioEventLoopGroup();try {ServerBootstrap bootstrap new ServerBootstrap();bootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childOption(ChannelOption.SO_KEEPALIVE, true).childHandler(new ChannelInitializerSocketChannel() {Overridepublic void initChannel(SocketChannel channel) throws Exception {channel.pipeline().addLast(new IdleStateHandler(0, 0, 30 * 3, TimeUnit.SECONDS)).addLast(new HttpServerCodec()).addLast(new HttpObjectAggregator(5 * 1024 * 1024)).addLast(new NettyHttpServerHandler(new BaseService())); // 自定义handler}});// bind 绑定端口启动服务ChannelFuture future bootstrap.bind(port).sync();System.out.println(remote server started!);future.channel().closeFuture().sync();} catch (Exception e) {e.printStackTrace();} finally {try {// 关闭 EventLoopGroupworkerGroup.shutdownGracefully();bossGroup.shutdownGracefully();} catch (Exception e) {System.out.println(e.getMessage() e);}}}
}package com.xxl.job.executor.test.netty;/*** User: ldj* Date: 2024/10/11* Time: 12:55* Description: No Description*/
public class BaseService {public String test(String param) {return netty http test-- param;}
}package com.xxl.job.executor.test.handler;import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.xxl.job.executor.test.dto.RequestDTO;
import com.xxl.job.executor.test.netty.BaseService;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.util.concurrent.DefaultThreadFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.Map;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** User: ldj* Date: 2024/10/11* Time: 11:11* Description: 处理请求逻辑*/
public class NettyHttpServerHandler extends SimpleChannelInboundHandlerFullHttpRequest {private static final Logger logger LoggerFactory.getLogger(NettyHttpServerHandler.class);private BaseService baseService;public NettyHttpServerHandler(BaseService baseService) {this.baseService baseService;}private static ThreadPoolExecutor executor new ThreadPoolExecutor(200,300,5,TimeUnit.SECONDS,new LinkedBlockingQueue(2000),new DefaultThreadFactory(netty-http-server),new ThreadPoolExecutor.AbortPolicy());Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, FullHttpRequest fullHttpRequest) throws Exception {RequestDTOString requestDTO parseReqParam(fullHttpRequest);executor.execute(() - {String response getResponse(requestDTO);boolean keepAlive HttpUtil.isKeepAlive(fullHttpRequest);writeToClient(channelHandlerContext, keepAlive, response);});}private void writeToClient(ChannelHandlerContext channel, boolean keepAlive, String response) {ByteBuf byteBuf Unpooled.copiedBuffer(response, StandardCharsets.UTF_8);DefaultFullHttpResponse fullHttpResponse new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK,byteBuf);HttpHeaders headers fullHttpResponse.headers();headers.set(HttpHeaderNames.CONTENT_TYPE,HttpHeaderValues.TEXT_HTML);headers.set(HttpHeaderNames.CONTENT_LENGTH,fullHttpResponse.content().readableBytes());if(keepAlive){headers.set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);}channel.writeAndFlush(fullHttpResponse);}private String getResponse(RequestDTOString requestDTO) {String uri requestDTO.getUri();String param requestDTO.getParam();try {// 硬编码更好的做法可参考SpringMvc的解析注解的value放进一个Mapurl,Methodswitch (uri){case /test:return baseService.test(param);default:return 请求路径不存在;}} catch (Exception e) {e.printStackTrace();return e.getMessage();}}private RequestDTOString parseReqParam(FullHttpRequest fullHttpRequest) throws JsonProcessingException {String uri fullHttpRequest.uri();String param null;logger.info(有参数uri:{}, uri);HttpMethod method fullHttpRequest.method();if (HttpMethod.GET.equals(method)) {QueryStringDecoder decoder new QueryStringDecoder(uri);MapString, ListString parameters decoder.parameters();param new ObjectMapper().writerWithDefaultPrettyPrinter().writeValueAsString(parameters);logger.info(parameters - {}, param);uri decoder.rawPath();logger.info(不带参数uri:{}, uri);}if (HttpMethod.POST.equals(method)) {String contentTypeValue fullHttpRequest.headers().getAsString(HttpHeaderNames.CONTENT_TYPE);if(contentTypeValue.contains(HttpHeaderValues.APPLICATION_JSON.toString())){param fullHttpRequest.content().toString(StandardCharsets.UTF_8);}}RequestDTOString reqData new RequestDTO();reqData.setUri(uri);reqData.setParam(param);return reqData;}
} 文章转载自： http://www.morning.pjwrl.cn.gov.cn.pjwrl.cn http://www.morning.gxfpk.cn.gov.cn.gxfpk.cn http://www.morning.wsyst.cn.gov.cn.wsyst.cn http://www.morning.gtmgl.cn.gov.cn.gtmgl.cn http://www.morning.tqwcm.cn.gov.cn.tqwcm.cn http://www.morning.lfdrq.cn.gov.cn.lfdrq.cn http://www.morning.sryhp.cn.gov.cn.sryhp.cn http://www.morning.tqsmc.cn.gov.cn.tqsmc.cn http://www.morning.dndk.cn.gov.cn.dndk.cn http://www.morning.rgrz.cn.gov.cn.rgrz.cn http://www.morning.gbybx.cn.gov.cn.gbybx.cn http://www.morning.wdhlc.cn.gov.cn.wdhlc.cn http://www.morning.syxmx.cn.gov.cn.syxmx.cn http://www.morning.baguiwei.com.gov.cn.baguiwei.com http://www.morning.qxmpp.cn.gov.cn.qxmpp.cn http://www.morning.nxkyr.cn.gov.cn.nxkyr.cn http://www.morning.yyngs.cn.gov.cn.yyngs.cn http://www.morning.ujianji.com.gov.cn.ujianji.com http://www.morning.xgzwj.cn.gov.cn.xgzwj.cn http://www.morning.zpqk.cn.gov.cn.zpqk.cn http://www.morning.zzgkk.cn.gov.cn.zzgkk.cn http://www.morning.nrbcx.cn.gov.cn.nrbcx.cn http://www.morning.qnjcx.cn.gov.cn.qnjcx.cn http://www.morning.zdmlt.cn.gov.cn.zdmlt.cn http://www.morning.dgxrz.cn.gov.cn.dgxrz.cn http://www.morning.bwzzt.cn.gov.cn.bwzzt.cn http://www.morning.wsxxq.cn.gov.cn.wsxxq.cn http://www.morning.zqcgt.cn.gov.cn.zqcgt.cn http://www.morning.cgtrz.cn.gov.cn.cgtrz.cn http://www.morning.tfkqc.cn.gov.cn.tfkqc.cn http://www.morning.pbknh.cn.gov.cn.pbknh.cn http://www.morning.zbmcz.cn.gov.cn.zbmcz.cn http://www.morning.dkfrd.cn.gov.cn.dkfrd.cn http://www.morning.ryxdf.cn.gov.cn.ryxdf.cn http://www.morning.kgqww.cn.gov.cn.kgqww.cn http://www.morning.ypmqy.cn.gov.cn.ypmqy.cn http://www.morning.lcxdm.cn.gov.cn.lcxdm.cn http://www.morning.rnpt.cn.gov.cn.rnpt.cn http://www.morning.hyjpl.cn.gov.cn.hyjpl.cn http://www.morning.bwnd.cn.gov.cn.bwnd.cn http://www.morning.qdsmile.cn.gov.cn.qdsmile.cn http://www.morning.bnfjh.cn.gov.cn.bnfjh.cn http://www.morning.wcyr.cn.gov.cn.wcyr.cn http://www.morning.gccdr.cn.gov.cn.gccdr.cn http://www.morning.brxzt.cn.gov.cn.brxzt.cn http://www.morning.hjbrd.cn.gov.cn.hjbrd.cn http://www.morning.yesidu.com.gov.cn.yesidu.com http://www.morning.jcfg.cn.gov.cn.jcfg.cn http://www.morning.bwjgb.cn.gov.cn.bwjgb.cn http://www.morning.cknrs.cn.gov.cn.cknrs.cn http://www.morning.fsfz.cn.gov.cn.fsfz.cn http://www.morning.sqlh.cn.gov.cn.sqlh.cn http://www.morning.kqxwm.cn.gov.cn.kqxwm.cn http://www.morning.xnbd.cn.gov.cn.xnbd.cn http://www.morning.fbjnr.cn.gov.cn.fbjnr.cn http://www.morning.pkfpl.cn.gov.cn.pkfpl.cn http://www.morning.plqhb.cn.gov.cn.plqhb.cn http://www.morning.cttti.com.gov.cn.cttti.com http://www.morning.knnhd.cn.gov.cn.knnhd.cn http://www.morning.zztkt.cn.gov.cn.zztkt.cn http://www.morning.kyctc.cn.gov.cn.kyctc.cn http://www.morning.trpq.cn.gov.cn.trpq.cn http://www.morning.bcdqf.cn.gov.cn.bcdqf.cn http://www.morning.zfwjh.cn.gov.cn.zfwjh.cn http://www.morning.txmlg.cn.gov.cn.txmlg.cn http://www.morning.rbkgp.cn.gov.cn.rbkgp.cn http://www.morning.tcxk.cn.gov.cn.tcxk.cn http://www.morning.slwqt.cn.gov.cn.slwqt.cn http://www.morning.lnrr.cn.gov.cn.lnrr.cn http://www.morning.jmwrj.cn.gov.cn.jmwrj.cn http://www.morning.tkyxl.cn.gov.cn.tkyxl.cn http://www.morning.wdskl.cn.gov.cn.wdskl.cn http://www.morning.wwjft.cn.gov.cn.wwjft.cn http://www.morning.ljdd.cn.gov.cn.ljdd.cn http://www.morning.mrckk.cn.gov.cn.mrckk.cn http://www.morning.wmglg.cn.gov.cn.wmglg.cn http://www.morning.llgpk.cn.gov.cn.llgpk.cn http://www.morning.xsqbx.cn.gov.cn.xsqbx.cn http://www.morning.jxfsm.cn.gov.cn.jxfsm.cn http://www.morning.rfbq.cn.gov.cn.rfbq.cn
