Node搭建一個DNS服務器

DevTTL 發布于2019-08-22 14:49 / 2943人閱讀

摘要：文件用來路由不同的服務器的有三個功能所以包含有三個模塊兒，開頭就引入了三個模塊兒，通過請求的路徑名稱我們路由到不同的處理模塊兒。鏈接到一個真實的服務器進行域名解析，且始終使用網絡進行查詢。

Node搭建DNS服務器的過程

接下來請深呼吸一大片代碼正奔涌而來，該項目托管在https://github.com/MaxMin-she... 請各位同仁大神view指導。
1、route文件用來路由不同的action

const DNSserver = require("./src/controller/DNSserver.js");
const Staticfiels = require("./src/controller/Staticfiels.js");
const SaveImg = require("./src/controller/Saveimg.js")

exports.getRouter = function (req, res) {
    console.log(url.parse(req.url));
    const pathname = url.parse(req.url).pathname;

    switch (pathname) {
        case "/dns":
          DNSserver.parse(req, res);
        break;
        case "":
        case "/":
        case "/index":
          Staticfiels.index(req, res);
        break;
        case "/post/img":
          SaveImg.saveimg (req, res);
        break;
        default:
         Staticfiels.loadfiels(req, res, pathname);
    }
}
module.exports = exports;

DNS服務器的有三個功能所以包含有三個模塊兒，開頭就引入了三個模塊兒，通過請求的url路徑名稱我們路由到不同的處理模塊兒。這個簡易的DNS服務器總共有四個自定義的模塊:

utile: 自定義的錯誤處理模塊兒

DNSserver：進行DNS域名解析，獲取域名所對應的IP地址

Staticfiles：根據請求路徑加載靜態文件

Saveimg：存儲圖片，返回一個自定的存儲路徑

接下來，我們分別來介紹這幾個模塊兒的功能和作用：

utile模塊兒

/**
 * handdle error
 * @param err
 * @param msg
 */

exports.errorHandle = function(err, type){
    const time = new Date();
    console.log(`------------------------

                 time: ${time}

                 err: ${err}

                 type: ${type}

                 ------------------------

                `);
}

module.exports = exports;

該模塊兒的作用是通過傳入的err，和提示的msg將錯誤的結果打印出來

DNSserver模塊兒

/**
 * DNS解析
 */
const url = require("url");
const querystring = require("querystring");
const dns = require("dns");

const util = require("../utile/utile.js");

/**
 * @param req
 * @param res
 */

exports.parse = function(req, res){
    const query_url = url.parse(req.url);
    const query = querystring.parse(query_url.query);
    dns.resolve4(query["hostname"], function(err, addresses){
       if(err){
          util.errorHandle(err, "DNS failed");
          res.writeHead(400);
          res.end();
       } else {
          res.writeHead(200);
          res.end(addresses.toString());
       }
    });
}

module.exports = exports;

req.url:req.url是一個包含著請求基本信息的字符串，以‘http://user:pass@host.com:8080/path?query=string#hash’為例，主要包含的屬性字段有：
1、protocal：‘http’，協議類型
2、slashes:true,表示protocal冒號后面跟著兩個ASCII 斜杠字符
3、auth:"user:pass",由username：user和password：pass組成
4、host:"host.com:8080",由hostname（域名或者ip地址）和port（端口號）8080組成
5、path：‘/path?query=string’，路徑，是由pathname（路徑名稱：‘/path’）和search（查詢名稱：‘?query=string’）組成
6、query:‘query=string’,由搜索對象形成

url.parse():url模塊的parse方法是將上面所說的這些屬性值序列化成鍵值對對像。

假設我們的請求是：‘http://localhost:3000/dns?hostname=www.google.com’

querystring.parse(str[, sep[, eq[, options]]])：query的屬性的值類似于"hostname=www.google.com"這樣的值,querystring(查詢字符串)模塊兒的作用是用來解析和格式化url查詢字符串，其中的parse方法是將這種形式的字符串序列化成{hostname：google.com}這樣的鍵值對集合。
str:需要分割的查詢字符串
sep:用于界定查詢字符串中鍵值對的符號
eq:用于界定查詢字符串中鍵與值的符號
options:用來定義解碼查詢字符串的函數和解析鍵的最大數量

dns.resolve4(str,function(err, ad){}):dns（域名服務器模塊兒），這個模塊包含兩種函數：1、使用底層操作系統工具進行域名解析，無需進行網絡通訊。2、鏈接到一個真實的DNS服務器進行域名解析，且始終使用網絡進行查詢。resolve4()屬于第二種函數。它的作用是使用DNS協議解析IPV4地址主機名，回調函數中的第一個參數是出現的錯誤，第二個參數是解析得到的ip地址，注意：這里返回的addresses是一個IPV4地址數組，但是res.end()的數據類型只能是string或者buffer，所以在響應是需要回調toString方法，將數組轉化成字符串。

Staticfiles模塊兒

/**
 * get static files
 */
const fs = require("fs");
const path = require("path");
const util = require("../utile/utile.js");
/**
 * read Fiels
 * @param req
 * @param res
 * @param pathname
 */

const readStaticFiles = function(req, res, filename){
  fs.readFile(filename, function(err, data){
     if(err){
       util.errorHandle(err, "filed readFile");
       res.writeHead(404);
       res.end("We Got A Problem: File Not Found");
     } else {
         res.writeHead(200);
         res.end(data);
     }
  })
} 

/**
 * exports function of reading files
 */
exports.loadfiels = function(req, res, pathname){
  const filename = path.join("E:static", pathname);
  console.log(filename);
  readStaticFiles(req, res, filename);
}

module.exports = exports;

/**
 * exports function of getting default page
 */
exports.index = function(req, res){
    const filename = path.join("static", "html/index.html");
    readStaticFiles(req, res, filename);
}

Staticfiles文件中有兩個輸出，index模塊是用來處理沒有輸入文件名時的默認值，loadfiels模塊則可以根據文件名返回靜態文件，兩個模塊兒都使用的同一函數readStaticFiles進行文件的讀取操作。

path模塊兒：用來處理文件和目錄的路徑

path.join([...paths]):將給定的所有path片段使用平臺特定的鏈接符鏈接成規范化路徑。在這個項目中，由于所有靜態文件都放在該項目的static目錄下面。所以，請求路徑之前要加一個相對路徑"static",不然就會報路徑錯誤的error。

fs.readFile(path[,options],callback):根據路徑異步讀取文件，回調函數中返回兩個參數：第一個：error是讀取文件過程中產生的錯誤，第二個：data是讀取文件的二進制數據流，如果在option中未指定編碼方式，返回的則是一個原始的buffer。

Saveimg模塊兒

在這個模塊中我們將實現圖片上傳下載的功能。
首先在html中完成一個form表單：

"multipart/form-data"是post的一種數據提交方式，用于附件的上傳，表單中還有file類型的控件，用于上傳一張圖片：

接下來，我們了解一下請求報文頭和報文體的格式和內容：

請求報文頭 req.headers,如下圖所示：

在請求報文頭中可以找到這些信息，其中Content-Type中的boundary屬性很重要，因為附件的數據量比較大，所以一個附件需要多部分提交才能完成，而boundary就是每一部分內容之間的分隔符；Content-Length是報文的長度。
報文體如下所示：

------WebKitFormBoundaryKXd7iAk5VsWqoaAY
Content-Disposition: form-data; name="userfile1"; filename="2.jpg"
Content-Type: image/jpeg


------WebKitFormBoundaryKXd7iAk5VsWqoaAY--

因為傳輸的數據量是未知的，所以通過boundary處理報文體是至關重要的一步。
在了解完附件上傳的報文形式以后，接下來我們將一步步的來實現圖片上傳的所有功能：

exports.saveimg = function (req, res) {
    if (req.method.toLowerCase() === "get") {
        getHandle(req, res);
    } else if (req.method.toLowerCase() === "post") {
        postHandle(req, res);
    }
}

首先，我們通過請求的方式來進行分支處理，上傳圖片的http請求方式必須是post，postHandle函數的具體實現過程如下：

function postHandle(req, res) {
    req.setEncoding("binary");
    let body = "";
    let filename = "";

    req.on("data", function (chunk) {
        body += chunk;
    });

    req.on("end", function () {
        const boundary = req.headers["content-type"].split(";")[1].replace("boundary=", "");  （1）
        const file = querystring.parse(body, "
", ":");  （2）
        if (file["Content-Type"].indexOf("image") !== -1) {
            const fileAr = file["Content-Disposition"].split("; ")[2].replace("filename=", "").split(".");（3）
            let filename = fileAr[0];（4）
            const imageState = fileAr[1].substring(0, fileAr[1].length-1);（5）
            const entireData = body.toString();

            const contentType = file["Content-Type"].substring(1);
            const upperBound = entireData.indexOf(contentType) + contentType.length;（6）
            const tarStr = entireData.substring(upperBound).trim();
            const boundaryIndex = tarStr.length - boundary.length - 4;
            const binaryData = tarStr.substring(0, boundaryIndex);

            //重新設置文件名稱
            filename = randomImgString(filename);

                fs.writeFile(path.join(__dirname, `../../img/${filename}.${imageState}`), binaryData, { encoding: "binary" }, (err) => {
                    if (err) {
                        utile.errorHandle(err, "failed write file");
                    } else {
                        res.writeHead(200, {
                            "Content-Type": "application/json"
                        });
                        const data = JSON.stringify({
                            "url":`http://127.0.0.1:3000/${filename}.${imageState}`
                        })
                        console.log(data);
                        res.write(data);
                        res.end();
                    }
                });
        }
    })
}

req.on("data",callback)綁定了用來監聽數據流的事件，req.on("end",callback)監聽數據傳輸完畢的事件，由此可見對傳輸來的數據進行的一系列操作都應該放在這個監聽事件的回調函數當中

body變量中存儲的是本次附件上傳中存儲的所有數據，如下圖所示（我只截取了body變量中的一部分）：

以下截圖是body的開頭部分：

以下截圖則是body的結束部分：

（1）段代碼的作用是從請求報文頭的content-type屬性值中截取boundary分割符的內容

（2）段代碼的作用是提取出報文體中的鍵值對，querystring模塊兒中的parse方法上文有提及，解析后的具體內容如下圖所示：

這段代碼的目的是為了獲取到報文體中的Content-Disposition字段和Content-Type字段，從Content-Disposition字段中可以獲取到文件名稱和文件格式，代碼3，4，5則完成了這個功能。
從打印的返回的報文體來看，Content-Type以后的所有數據就是圖片的編碼，所以接下來的任務就是將這個編碼提取出來

（6）段代碼的作用是找到圖片編碼字符串開始的index

（7）段代碼的作用是找到圖片編碼字符串的結束index，由body的結尾截圖可以看出，結束部分是由‘--boundary--’的形式組成，所以最后減去的除了boundary的長度還有兩個‘--’的長度4。

（8）段代碼中的binaryData則是圖片的完整編碼

隨機生成文件名稱的函數randomImgString的實現過程如下所示：

/**
 * option to generate randomString
 */
function randomImgString(filename){
    let outString = new Date().toTimeString();
    outString += filename.substring(0, filename.indexOf("."));
    outString = hash.update(outString)
                    .digest("hex").substring(0, 15);
    return outString;
}

*fs.writeFile(file, data[, options], callback)：1、file:文件的存儲路徑 2、data：文件編碼 3、options編碼方式 4、callback：寫入文件成功后的回調函數

GPU云服務器云服務器搭建node云服務器 webrtc node 搭建 webrtc node.js服務搭建 node搭建webrtc服務器

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/92898.html

搭建Kubernetes集群時DNS無法解析問題的處理過程

摘要：問題描述在搭建集群過程中，安裝了插件后，運行一個容器，發現容器內無法解析集群外域名，一開始可以解析集群內域名，一段時間后也無法解析集群內域名。總結通過對問題的探究，也理解了集群中解析的完整過程，如圖。 showImg(https://segmentfault.com/img/remote/1460000015639330); 問題描述在搭建Kubernetes集群過程中，安裝了kub...

snowLu 2019-07-01 16:45 評論0 收藏0
搭建Kubernetes集群時DNS無法解析問題的處理過程

摘要：問題描述在搭建集群過程中，安裝了插件后，運行一個容器，發現容器內無法解析集群外域名，一開始可以解析集群內域名，一段時間后也無法解析集群內域名。總結通過對問題的探究，也理解了集群中解析的完整過程，如圖。 showImg(https://segmentfault.com/img/remote/1460000015639330); 問題描述在搭建Kubernetes集群過程中，安裝了kub...

Berwin 2019-05-28 17:09 評論0 收藏0
手動搭建kubernetes集群

摘要：手動搭建集群探索系列的第三篇，主要記錄手動搭建集群的過程，部署部署用作服務發現。配置的子網范圍不能和的一致。手動搭建kubernetes集群探索kubernetes系列的第三篇，主要記錄手動搭建k8s集群的過程，部署dashboard, 部署DNS用作服務發現。順便記錄一下k8s中的一些資源的概念。配置環境這個步驟可以參考《Flannel with Docker》文中的步驟，不...

warnerwu 2019-07-01 16:27 評論0 收藏0
Kubernetes v1.0特性解析

摘要：問題是不是定義的一個的容器集群是只部署在同一個主機上楊樂到目前是，同一個里的是部署在同一臺主機的。問題這個圖里的是安裝在哪里的所有的客戶端以及會連接這個嘛楊樂可以任意地方，只要能訪問到集群，會作為的出口。 kubernetes1.0剛剛發布，開源社區400多位貢獻者一年的努力，多達14000多次的代碼提交，最終達到了之前預計的milestone, 并意味著這個開源容器編排系統可以正式在...

HackerShell 2019-07-01 16:19 評論0 收藏0