Java使用Netty框架自建DNS代理服务器教程

　　前言
　　DNS协议作为着互联网客户端服务器通信模式得第一关，在当下每天都有成千上亿上网记录产生得当今社会，其重要性自然不可言喻。在国内比较有名得DNS服务器有电信得114。114。114。114、阿里云得223。5。5。5，DNSPod得119。29。29。29，配置一个好的DNS服务器可以缩短请求响应时间、降低DNS劫持概率，提升上网体验。
　　上面这些都是互联网公用DNS服务器，本文博主教大家使用JavaNetty自建DNS代理服务器，目前网上对于使用Netty自建DNS服务器得教程良莠不齐，大多没有代理步骤，达不到博主想要得代理效果，因而创建此文。觉得本文有帮助得可以关注博主githubhttps：github。comwayn111一、自建DNS代理服务器有哪些优势1。域名控制：对于特定域名可以自由控制访问权限（屏蔽对特定网站访问）2。域名记录：记录局域网内各个主机得域名访问（记录员工上网记录）3。配置内网域名：通过自建DNS服务器可以配置内网域名，节约成本4。DNS负载均衡：通过自建DNS服务器可以轻松实现对于访问域名得负载均衡配置5。。。。二、自建DNS代理服务器代码
　　1。添加域名黑名单文件，resources文件夹下添加blacklist。txt文件google。com。facebook。com。
　　初始化BLACKLISTDOMAINprivatestaticfinalListStringBLACKLISTDOMAINnewArrayList（）；static｛Strings；try（InputStreamisDnsServer。class。getClassLoader（）。getResourceAsStream（blacklist。txt）；BufferedReaderbrnewBufferedReader（newInputStreamReader（is）））｛while（StrUtil。isNotBlank（sbr。readLine（）））｛BLACKLISTDOMAIN。add（s）；｝｝catch（Exceptione）｛log。error（e。getMessage（），e）；｝｝
　　2。使用UDP协议绑定本机53端口，并初始化ProxyUdpDNS请求代理对象Slf4jpublicfinalclassDnsServer｛privatestaticfinalListStringBLACKLISTDOMAINnewArrayList（）；static｛。。。｝publicstaticvoidmain（String〔〕args）throwsException｛ProxyUdpproxyUdpnewProxyUdp（）；proxyUdp。init（）；finalint〔〕num｛0｝；finalNioEventLoopGroupgroupnewNioEventLoopGroup（）；BootstrapbootstrapnewBootstrap（）；bootstrap。group（group）。channel（NioDatagramChannel。class）。handler（newChannelInitializerNioDatagramChannel（）｛OverrideprotectedvoidinitChannel（NioDatagramChannelnioDatagramChannel）｛nioDatagramChannel。pipeline（）。addLast（。。。）；｝｝）。option（ChannelOption。SOBROADCAST，true）；intport53；ChannelFuturefuturebootstrap。bind（port）。addListener（future1｛log。info（serverlisteningport：｛｝，port）；｝）；future。channel（）。closeFuture（）。addListener（future1｛if（future。isSuccess（））｛log。info（future。channel（）。toString（））；｝｝）；｝｝
　　3。给nioDatagramChannel。pipeline（）添加ChannelHandlernioDatagramChannel。pipeline（）。addLast（newDatagramDnsQueryDecoder（））；nioDatagramChannel。pipeline（）。addLast（newSimpleChannelInboundHandlerDatagramDnsQuery（）｛OverrideprotectedvoidchannelRead0（ChannelHandlerContextctx，DatagramDnsQuerymsg）｛try｛DefaultDnsQuestiondnsQuestionmsg。recordAt（DnsSection。QUESTION）；StringnamednsQuestion。name（）；log。info（namenum〔0〕）；Channelchannelctx。channel（）；intidmsg。id（）；channel。attr（AttributeKey。DatagramDnsQueryvalueOf（String。valueOf（id）））。set（msg）；if（BLACKLISTDOMAIN。contains（name））｛DnsQuestionquestionmsg。recordAt（DnsSection。QUESTION）；DatagramDnsResponsednsResponsegetDatagramDnsResponse（msg，id，question）；channel。writeAndFlush（dnsResponse）；return；｝proxyUdp。send（name，msg。id（），channel）；｝catch（Exceptione）｛log。error（e。getMessage（），e）；｝｝privateDatagramDnsResponsegetDatagramDnsResponse（DatagramDnsQuerymsg，intid，DnsQuestionquestion）｛DatagramDnsResponsednsResponsenewDatagramDnsResponse（msg。recipient（），msg。sender（），id）；dnsResponse。addRecord（DnsSection。QUESTION，question）；DefaultDnsRawRecordqueryAnswernewDefaultDnsRawRecord（question。name（），DnsRecordType。A，600，Unpooled。wrappedBuffer（newbyte〔〕｛（byte）192，（byte）168，1，1｝））；dnsResponse。addRecord（DnsSection。ANSWER，queryAnswer）；returndnsResponse；｝OverridepublicvoidexceptionCaught（ChannelHandlerContextctx，Throwablee）｛log。error（e。getMessage（），e）；｝｝）；nioDatagramChannel。pipeline（）。addLast（newDatagramDnsResponseEncoder（））；
　　在newSimpleChannelInboundHandler（）中解析客户端DNS查询报文，获取访问域名信息，如果访问域名在黑名单中，则通过getDatagramDnsResponse（）直接返回192。168。1。1的DNS响应报文，反之则通过proxyUdp对象转发DNS查询。
　　4。ProxyUdp作为DNS查询代理类会通过send（Stringdomain，intid，ChannelserverChannel）方法传入DnsServer类收到的访问域名、DNS事务ID、serverChannel。随后包装访问域名请求DNS服务器114。114。114。114，最后通过newSimpleChannelInboundHandler（）将收到的DNS响应报文通过上一步传入得serverChannel输出到客户端。Slf4jclassProxyUdp｛privateChannelserverChannel；privateChannelproxyChannel；publicvoidinit（）throwsInterruptedException｛EventLoopGroupproxyGroupnewNioEventLoopGroup（）；BootstrapbnewBootstrap（）；b。group（proxyGroup）。channel（NioDatagramChannel。class）。handler（newChannelInitializerDatagramChannel（）｛OverrideprotectedvoidinitChannel（DatagramChannelch）｛ChannelPipelinepch。pipeline（）；p。addLast（newDatagramDnsQueryEncoder（））。addLast（newDatagramDnsResponseDecoder（））。addLast（newSimpleChannelInboundHandlerDatagramDnsResponse（）｛OverridepublicvoidchannelActive（ChannelHandlerContextctx）｛log。info（ctx。channel（）。toString（））；｝OverrideprotectedvoidchannelRead0（ChannelHandlerContextctx，DatagramDnsResponsemsg）｛DatagramDnsQuerydnsQuerylocalChannel。attr（AttributeKey。DatagramDnsQueryvalueOf（String。valueOf（msg。id（））））。get（）；DnsQuestionquestionmsg。recordAt（DnsSection。QUESTION）；DatagramDnsResponsednsResponsenewDatagramDnsResponse（dnsQuery。recipient（），dnsQuery。sender（），msg。id（））；dnsResponse。addRecord（DnsSection。QUESTION，question）；for（inti0，countmsg。count（DnsSection。ANSWER）；icount；i）｛DnsRecordrecordmsg。recordAt（DnsSection。ANSWER，i）；if（record。type（）DnsRecordType。A）｛justprinttheIPafterqueryDnsRawRecordraw（DnsRawRecord）record；DefaultDnsRawRecordqueryAnswernewDefaultDnsRawRecord（question。name（），DnsRecordType。A，600，Unpooled。wrappedBuffer（ByteBufUtil。getBytes（raw。content（））））；dnsResponse。addRecord（DnsSection。ANSWER，queryAnswer）；｝｝serverChannel。writeAndFlush（dnsResponse）；｝OverridepublicvoidexceptionCaught（ChannelHandlerContextctx，Throwablee）｛log。error（e。getMessage（），e）；｝｝）；｝｝）；proxyChannelb。bind（0）。sync（）。addListener（future1｛log。info（绑定成功）；｝）。channel（）；｝publicvoidsend（Stringdomain，intid，ChannelserverChannel）｛this。serverChannelserverChannel；DnsQueryquerynewDatagramDnsQuery（null，newInetSocketAddress（114。114。114。114，53），id）。setRecord（DnsSection。QUESTION，newDefaultDnsQuestion（domain，DnsRecordType。A））；this。proxyChannel。writeAndFlush（query）；｝｝
　　5。自建DNS服务器全部代码Slf4jpublicfinalclassDnsServer｛privatestaticfinalListStringBLACKLISTDOMAINnewArrayList（）；static｛Strings；try（InputStreamisDnsServer。class。getClassLoader（）。getResourceAsStream（blacklist。txt）；BufferedReaderbrnewBufferedReader（newInputStreamReader（is）））｛while（StrUtil。isNotBlank（sbr。readLine（）））｛BLACKLISTDOMAIN。add（s）；｝｝catch（Exceptione）｛log。error（e。getMessage（），e）；｝｝publicstaticvoidmain（String〔〕args）throwsException｛ProxyUdpproxyUdpnewProxyUdp（）；proxyUdp。init（）；finalint〔〕num｛0｝；finalNioEventLoopGroupgroupnewNioEventLoopGroup（）；BootstrapbootstrapnewBootstrap（）；bootstrap。group（group）。channel（NioDatagramChannel。class）。handler（newChannelInitializerNioDatagramChannel（）｛OverrideprotectedvoidinitChannel（NioDatagramChannelnioDatagramChannel）｛nioDatagramChannel。pipeline（）。addLast（newDatagramDnsQueryDecoder（））；nioDatagramChannel。pipeline（）。addLast（newSimpleChannelInboundHandlerDatagramDnsQuery（）｛OverrideprotectedvoidchannelRead0（ChannelHandlerContextctx，DatagramDnsQuerymsg）｛try｛DefaultDnsQuestiondnsQuestionmsg。recordAt（DnsSection。QUESTION）；StringnamednsQuestion。name（）；log。info（namenum〔0〕）；Channelchannelctx。channel（）；intidmsg。id（）；channel。attr（AttributeKey。DatagramDnsQueryvalueOf（String。valueOf（id）））。set（msg）；if（BLACKLISTDOMAIN。contains（name））｛DnsQuestionquestionmsg。recordAt（DnsSection。QUESTION）；DatagramDnsResponsednsResponsegetDatagramDnsResponse（msg，id，question）；channel。writeAndFlush（dnsResponse）；return；｝proxyUdp。send（name，msg。id（），channel）；｝catch（Exceptione）｛log。error（e。getMessage（），e）；｝｝privateDatagramDnsResponsegetDatagramDnsResponse（DatagramDnsQuerymsg，intid，DnsQuestionquestion）｛DatagramDnsResponsednsResponsenewDatagramDnsResponse（msg。recipient（），msg。sender（），id）；dnsResponse。addRecord（DnsSection。QUESTION，question）；justprinttheIPafterqueryDefaultDnsRawRecordqueryAnswernewDefaultDnsRawRecord（question。name（），DnsRecordType。A，600，Unpooled。wrappedBuffer（newbyte〔〕｛（byte）192，（byte）168，1，1｝））；dnsResponse。addRecord（DnsSection。ANSWER，queryAnswer）；returndnsResponse；｝OverridepublicvoidexceptionCaught（ChannelHandlerContextctx，Throwablee）｛log。error（e。getMessage（），e）；｝｝）；nioDatagramChannel。pipeline（）。addLast（newDatagramDnsResponseEncoder（））；｝｝）。option（ChannelOption。SOBROADCAST，true）；intport553；ChannelFuturefuturebootstrap。bind（port）。addListener（future1｛log。info（serverlisteningport：｛｝，port）；｝）；future。channel（）。closeFuture（）。addListener（future1｛if（future。isSuccess（））｛log。info（future。channel（）。toString（））；｝｝）；｝｝Slf4jclassProxyUdp｛privateChannellocalChannel；privateChannelproxyChannel；publicvoidinit（）throwsInterruptedException｛EventLoopGroupproxyGroupnewNioEventLoopGroup（）；BootstrapbnewBootstrap（）；b。group（proxyGroup）。channel（NioDatagramChannel。class）。handler（newChannelInitializerDatagramChannel（）｛OverrideprotectedvoidinitChannel（DatagramChannelch）｛ChannelPipelinepch。pipeline（）；p。addLast（newDatagramDnsQueryEncoder（））。addLast（newDatagramDnsResponseDecoder（））。addLast（newSimpleChannelInboundHandlerDatagramDnsResponse（）｛OverridepublicvoidchannelActive（ChannelHandlerContextctx）｛log。info（ctx。channel（）。toString（））；｝OverrideprotectedvoidchannelRead0（ChannelHandlerContextctx，DatagramDnsResponsemsg）｛DatagramDnsQuerydnsQuerylocalChannel。attr（AttributeKey。DatagramDnsQueryvalueOf（String。valueOf（msg。id（））））。get（）；DnsQuestionquestionmsg。recordAt（DnsSection。QUESTION）；DatagramDnsResponsednsResponsenewDatagramDnsResponse（dnsQuery。recipient（），dnsQuery。sender（），msg。id（））；dnsResponse。addRecord（DnsSection。QUESTION，question）；for（inti0，countmsg。count（DnsSection。ANSWER）；icount；i）｛DnsRecordrecordmsg。recordAt（DnsSection。ANSWER，i）；if（record。type（）DnsRecordType。A）｛justprinttheIPafterqueryDnsRawRecordraw（DnsRawRecord）record；DefaultDnsRawRecordqueryAnswernewDefaultDnsRawRecord（question。name（），DnsRecordType。A，600，Unpooled。wrappedBuffer（ByteBufUtil。getBytes（raw。content（））））；dnsResponse。addRecord（DnsSection。ANSWER，queryAnswer）；｝｝localChannel。writeAndFlush（dnsResponse）；｝OverridepublicvoidexceptionCaught（ChannelHandlerContextctx，Throwablee）｛log。error（e。getMessage（），e）；｝｝）；｝｝）；proxyChannelb。bind（0）。sync（）。addListener（future1｛log。info（绑定成功）；｝）。channel（）；｝publicvoidsend（Stringdomain，intid，ChannellocalChannel）｛this。localChannellocalChannel；DnsQueryquerynewDatagramDnsQuery（null，newInetSocketAddress（114。114。114。114，53），id）。setRecord（DnsSection。QUESTION，newDefaultDnsQuestion（domain，DnsRecordType。A））；this。proxyChannel。writeAndFlush（query）；｝｝三、本地测试
　　1。修改本机DNS设置（win11），修改首选、备选DNS地址为127。0。0。1image。png
　　2。打开命令行工具，执行DNS缓存清除命令ipconfigflushdnsimage。png
　　自此就可以打开浏览器访问常用网站，看是否能正常访问，来验证自建的DNS服务器效果了