部落格

  • 用python實現對元素的長截圖

    用python實現對元素的長截圖

    一.目標

    瀏覽網頁的時候,看見哪個元素,就能截取哪個元素當圖片,不管那個元素有多長

     

    二.所用工具和第三方庫

    python ,PIL,selenium

    pycharm

    三.代碼部分

    長截圖整體思路:

    1.獲取元素

    2.移動,截圖,移動,截圖,直到抵達元素的底部

    3.把截圖按照元素所在位置切割,在所有圖片中只保留該元素

    4.拼接

     

    如果driver在環境變量中,那麼不用指定路徑

    b=webdriver.Chrome(executable_path=r"C:\Users\Desktop\chromedriver.exe")#指定一下driver
    b.get("")
    b.maximize_window()#最大化窗口

    打開網站

     

     

     我們可以看見一個ID為maincontent的元素,寬度為850PX,長度為3828PX,這個長度必須使用才能長截圖才能完整截下來

     

    el=b.find_element_by_id("maincontent")#找到元素

    我們還需要一個重要的參數,就是你電腦一次能截取多高的像素

    先用下圖代碼獲取一個圖片

    #fp為存放圖片的地址
    b.get_screenshot_as_file(fp)

     

    也就是說用我電腦上截圖的默認高度為614像素

     

     所以我設置一個變量:

    sc_hight=614

    然後設置一下其他變量

        count = int(el.size["height"] / sc_hight)  # 元素的高度除以你每次截多少就是次數
        start_higth = el.location["y"]  # 元素的初始高度
        max_px = start_higth + (count - 1) * sc_hight  # for循環中最大的px
        last_px = el.size["height"] + start_higth - sc_hight  # 元素最底部的位置
        surplus_px = last_px - max_px  # 剩餘的邊的高度
        img_path = []  # 用來存放圖片地址

    註釋:

    1.count為元素的高度/每次截取的高度,比如這次實例中元素高度為3828PX,我每次截614px,需要6.2次,int之後變成6,也就是截6次,還剩一點,那一點後面再說

    2.start_higth為初始高度,這個沒有什麼可說的

    3.max_px為循環結束后,到達的高度

    4.last_px為元素最底部的高度

    5.surplus_px就是移動6次后,還沒有截取的高度

    屏幕每次移動,移動sc_hight個像素,初始位置為(0,元素的Y值)

        for i in range(0, count):
            js = "scrollTo(0,%s)" % (start_higth + i * sc_hight)  # 用於移動滑輪,每次移動614px,初始值是元素的初始高度
            b.execute_script(js)  # 執行js
            time.sleep(0.5)
            fp = r"C:\Users\wdj\Desktop\%s.png" % i  # 圖片地址,運行的話,改一下
            b.get_screenshot_as_file(fp)  # 屏幕截圖,這裡是截取是完整的網頁圖片,你可以打斷點看一下圖片
            img = Image.open(fp=fp)
            img2 = img.crop((el.location["x"], 0, el.size["width"] + el.location["x"], sc_hight))  # 剪切圖片
            img2.save(fp)  # 保存圖片,覆蓋完整的網頁圖片
            img_path.append(fp)  # 添加圖片路徑
            time.sleep(0.5)
            print(js)
        else:
            js = "scrollTo(0,%s)" % last_px  # 滾動到最後一個位置
            b.execute_script(js)
            fp = r"C:\Users\wdj\Desktop\last.png"
            b.get_screenshot_as_file(fp)
            img = Image.open(fp=fp)
            print((el.location["x"], sc_hight - surplus_px, el.size["width"] + el.location["x"], sc_hight))
            img2 = img.crop((el.location["x"], sc_hight - surplus_px, el.size["width"] + el.location["x"], sc_hight))
            img2.save(fp)
            img_path.append(fp)
            print(js)

    上面是把該元素的在頁面都截完,並且剪切,把圖片保存的路徑放入img_path

    最後一步:把所有截圖都貼到新創建的圖片中

        new_img = Image.new("RGB", (el.size["width"], el.size["height"]))  # 創建一個新圖片,大小為元素的大小
        k = 0
        for i in img_path:
            tem_img = Image.open(i)
            new_img.paste(tem_img, (0, sc_hight * k))  # 把圖片貼上去,間隔一個截圖的距離
            k += 1
        else:
            new_img.save(r"C:\Users\wdj\Desktop\test.png")  # 保存

     

    運行效果圖:


    說明完整的截取下來了

     

     

     

    補充優化:

    如果是個小元素怎麼辦,不用長截圖就能截取的那種

    因為很簡單我就直接貼代碼了

        start_higth = el.location["y"]
        js = "scrollTo(0,%s)" % (start_higth)
        b.execute_script(js)  # 執行js
        time.sleep(0.5)
        fp = r"C:\Users\wdj\Desktop\test.png" # 圖片地址,運行的話,改一下
        b.get_screenshot_as_file(fp)
        img = Image.open(fp=fp)
        img2 = img.crop((el.location["x"], 0, el.size["width"] + el.location["x"], el.size["height"]))  # 剪切圖片
        img2.save(fp)

    效果如下:

     

     

    完整代碼:

    from selenium import webdriver
    from PIL import Image
    import time
    def short_sc(el,b):
        start_higth = el.location["y"]
        js = "scrollTo(0,%s)" % (start_higth)
        b.execute_script(js)  # 執行js
        time.sleep(0.5)
        fp = r"C:\Users\wdj\Desktop\test.png" # 圖片地址,運行的話,改一下
        b.get_screenshot_as_file(fp)
        img = Image.open(fp=fp)
        img2 = img.crop((el.location["x"], 0, el.size["width"] + el.location["x"], el.size["height"]))  # 剪切圖片
        img2.save(fp)
    
    def long_sc(el,b):
        count = int(el.size["height"] / sc_hight)  # 元素的高度除以你每次截多少就是次數
        start_higth = el.location["y"]  # 元素的初始高度
        max_px = start_higth + (count - 1) * sc_hight  # for循環中最大的px
        last_px = el.size["height"] + start_higth - sc_hight  # 元素最底部的位置
        surplus_px = last_px - max_px  # 剩餘的邊的高度
        img_path = []  # 用來存放圖片地址
        for i in range(0, count):
            js = "scrollTo(0,%s)" % (start_higth + i * sc_hight)  # 用於移動滑輪,每次移動614px,初始值是元素的初始高度
            b.execute_script(js)  # 執行js
            time.sleep(0.5)
            fp = r"C:\Users\wdj\Desktop\%s.png" % i  # 圖片地址,運行的話,改一下
            b.get_screenshot_as_file(fp)  # 屏幕截圖,這裡是截取是完整的網頁圖片,你可以打斷點看一下圖片
            img = Image.open(fp=fp)
            img2 = img.crop((el.location["x"], 0, el.size["width"] + el.location["x"], sc_hight))  # 剪切圖片
            img2.save(fp)  # 保存圖片,覆蓋完整的網頁圖片
            img_path.append(fp)  # 添加圖片路徑
            time.sleep(0.5)
            print(js)
        else:
            js = "scrollTo(0,%s)" % last_px  # 滾動到最後一個位置
            b.execute_script(js)
            fp = r"C:\Users\wdj\Desktop\last.png"
            b.get_screenshot_as_file(fp)
            img = Image.open(fp=fp)
            print((el.location["x"], sc_hight - surplus_px, el.size["width"] + el.location["x"], sc_hight))
            img2 = img.crop((el.location["x"], sc_hight - surplus_px, el.size["width"] + el.location["x"], sc_hight))
            img2.save(fp)
            img_path.append(fp)
            print(js)
    
        new_img = Image.new("RGB", (el.size["width"], el.size["height"]))  # 創建一個新圖片,大小為元素的大小
        k = 0
        for i in img_path:
            tem_img = Image.open(i)
            new_img.paste(tem_img, (0, sc_hight * k))  # 把圖片貼上去,間隔一個截圖的距離
            k += 1
        else:
            new_img.save(r"C:\Users\wdj\Desktop\test.png")  # 保存
    
    b=webdriver.Chrome(executable_path=r"C:\Users\wdj\Desktop\chromedriver.exe")#指定一下driver
    b.get("https://www.w3school.com.cn/html/html_links.asp")
    b.maximize_window()#最大化窗口
    # b.get_screenshot_as_file(fp)
    sc_hight=614#你屏幕截圖默認的大小,可以去截一張,去畫圖裡面看看是多少像素,我這裡是614像素
    
    # b.switch_to.frame(b.find_element_by_xpath('//*[@id="intro"]/iframe'))
    el=b.find_element_by_id("maincontent")#找到元素
    if el.size["height"]>sc_hight:
        long_sc(el,b)
    else:
        short_sc(el,b)

    完整代碼

     

    PS:

    有些特殊情況,比如截取的元素在iframe中,直接用driver.switch_to.frame(iframe元素)即可

    或者不是iframe,但是元素有overflow屬性,直接用JS把他的overflow去掉就行

     

     

     

     

     

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※想知道網站建置網站改版該如何進行嗎?將由專業工程師為您規劃客製化網頁設計後台網頁設計

    ※不管是台北網頁設計公司台中網頁設計公司,全省皆有專員為您服務

    ※Google地圖已可更新顯示潭子電動車充電站設置地點!!

    ※帶您來看台北網站建置台北網頁設計,各種案例分享

    ※別再煩惱如何寫文案,掌握八大原則!

  • C表達式中的彙編指令

    C 表達式中的彙編指令

    asm 為 gcc 中的關鍵字,asm 表達式為在 C代碼中嵌套彙編指令,該表達式只是單純的替換出彙編代碼,並不對彙編代碼的含義進行解析。

    asm 表達式有兩種形式,第二種 asm-qualifiers 包含了 goto 語句。
    第一種形式為常見的用法,AssemblerTemplate 和 OutputOperands 必須存在, 其中 Clobbers 存在需要 InputOperands 也出現。

    asm asm-qualifiers ( AssemblerTemplate 
                     : OutputOperands 
                     [ : InputOperands
                     [ : Clobbers ] ])
    
    asm asm-qualifiers ( AssemblerTemplate 
                          : 
                          : InputOperands
                          : Clobbers
                          : GotoLabels)

    Qualifiers 的類型

    • volatile, 避免編譯器的優化
    • inline, 內斂限定符,最小的體積
    • goto, 包含跳轉指令

    參數

    • AssemblerTemplate
      – 彙編指令模板是包含彙編器指令的文字字符串,編輯器替換引用輸入,編譯器不會解析該指令的含義。
    • OutputOperands
      – 由 AssemblerTemplate 中的指令修改的C變量的逗號分隔列表,允許使用空列表。
    • InputOperands
      – 由 AssemblerTemplate 中的指令讀取的C變量的逗號分隔列表,允許使用空列表。
    • Clobbers
      – 用逗號分隔的寄存器列表或由 AssemblerTemplate 修改的值,不能出現在 OutputOperands 和 InputOperands 中被提及,允許使用空列表。
    • GotoLabels
      – 當使用asm的goto形式時,此部分包含 AssemblerTemplate 中的代碼可能跳轉到的所有C標籤的列表。

    AssemblerTemplate

    彙編指令由一個字符串給出,多條彙編指令結合在一起使用的時候,中間以 \r\t 隔開,如

    asm("inc %0\n\tinc %0" : "=r"(res) : "0"(res));
    
    /APP
    # 11 "asm.c" 1
            inc %rax
            inc %rax
    # 0 "" 2
    /NO_APPs

    需要轉義的字符:%, =, {, }, |

    故在ATT彙編中,對寄存器進行操作的需要雙 %%, 如 inc %%rax.

    OutputOperands

    操作數之間用逗號分隔。 每個操作數具有以下格式:

    [ [asmSymbolicName] ] constraint (cvariablename)
    • asmSymbolicName
      – 為操作數指定名稱,格式為 %[name]
      c // res = num asm("movq %[num], %[res]" : [res] "=r"(res) : [num] "m"(num));
      – 如果未指定名稱使用数字, 從 output 域開始,第一個參數為 %0, 一次類推, 這裏的 res 為 %0, num 為 %1
      c // res = num asm("movq %1, %0" : "=r"(res) : "m"(num));
    • constraint
      – 一個字符串常量,用於指定對操作數的存儲的 , 需要以 “=” 或 “+” 開頭
    • cvariablename
      – 指定一個C左值表達式來保存輸出,通常是一個變量名。 括號是語法的必需部分

    第一個參數為增加可讀性使用的,現在我們有代碼如下

    int64_t res;
    int64_t num = 1;
    
    asm("movq %[num], %[res]" : [res] "=r"(res) : [num] "m"(num));
    asm("movq %1, %0" : "=r"(res) : "m"(num));
    asm("movq %1, %0" : "=m"(res) : "m"(num));
    asm("movq %1, %0" : "=r"(res) : "r"(num));
    
    // 對應的彙編代碼, 只保留asm表達式中的代碼
    # 13 "asm.c" 1
            movq -16(%rbp), %rax  // asm-1
     # 0 "" 2
    /NO_APP
    
    /APP
     # 15 "asm.c" 1
            movq -16(%rbp), %rax  // asm-2
     # 0 "" 2
    /NO_APP
    
    /APP
     # 17 "asm.c" 1
            movq -16(%rbp), -8(%rbp)  // asm-3
     # 0 "" 2
    /NO_APP
    
    /APP
     # 19 "asm.c" 1
            movq %rax, %rax  // asm-4
     # 0 "" 2
    /NO_APP
    1. 使用名稱替換和数字替換效果一樣,見 asm-1 和 asm-2
    2. 約束的用法,這裏使用比較簡單通用的的兩種情況,r 為通過寄存器尋址操作,m 通過內存尋址操作,所以看到當約束了 r 就對應寄存器的操作。
    3. 結果保存在 res 也就是 cvariablename 中

    InputOperands

    輸入操作數使C變量和表達式中的值可用於彙編代碼。

    [ [asmSymbolicName] ] constraint (cexpression)
    • asmSymbolicName 和輸出列表的用法完全一致
    • constraint 約束不能使用 =+. 可以使用 “0”, 這表明在輸出約束列表中(從零開始)的條目,指定的輸入必須與輸出約束位於同一位置。
    int64_t res = 3;
    int64_t num = 1;
    asm("addq %1, %0" : "=g"(res) : "0"(num));
    
    // 輸入輸出位置相同
            movq    $3, -8(%rbp)
            movq    $1, -16(%rbp)
            movq    -16(%rbp), %rax
    /APP
    # 32 "asm.c" 1
            addq %rax, %rax
    # 0 "" 2
    /NO_APP
    • cexpression 可以不為左值,作為彙編表達式的輸入值即可

    Clobbers

    破壞列表,主要用於指示編譯器生成的彙編指令。

    從asm表達式中看到輸出操作數中列出條目的更改編譯器是可以確定的,但內聯彙編代碼可能不僅對輸出進行了修改。 例如,計算可能需要其他寄存器,或者處理器可能會由於特定彙編程序指令而破壞寄存器的值。 為了將這些更改通知編譯器,在Clobber列表中列出這些會產生副作用的條目。 破壞列表條目可以是寄存器名稱,也可以是特殊的破壞列表項(在下面列出)。 每個內容列表條目都是一個字符串常量,用雙引號引起來並用逗號分隔。

    • 寄存器

        ```c
        asm volatile("movc3 %0, %1, %2"
                : /* No outputs. */
                : "r"(from), "r"(to), "g"(count)
                : "%rbx", "%rcx", "%rdx", "memory");
      
        /APP
        # 25 "asm.c" 1
                movc3 %rax, %r8, -72(%rbp)
        # 0 "" 2
        /NO_APP
        ```
      
        可以看到使用到了 rax 寄存器,然後修改程序在 Clobbers 增加 %rax, 結果如下
      
        ```c
        asm volatile("movc3 %0, %1, %2"
                : /* No outputs. */
                : "r"(from), "r"(to), "g"(count)
                : "%rax", "%rbx", "%rcx", "%rdx", "memory");
      
        /APP
        # 25 "asm.c" 1
                movc3 %r8, %r9, -72(%rbp)
        # 0 "" 2
        /NO_APP
        ```
        編譯器在產生的彙編代碼中就未使用 %rax 寄存器了。
    • 特殊破壞列表項
      – “cc”, 表示彙編代碼修改了標誌寄存器
      – “memory”, 為了確保內存中包含正確的值,編譯器可能需要在執行asm之前將特定的寄存器值刷新到內存中

    編譯器為了破壞列表項的值受到破壞,當這些條目是寄存器時,不對其進行使用;為特殊參數時,重新刷新得到最新的值。

    約束

    • 一些基礎的約束
    約束名 說明
    whitespace 空白字符被忽略
    m 允許使用內存操作數,以及機器通常支持的任何類型的地址
    o 允許使用內存操作數,但前提是地址是可偏移的
    V 允許使用內存操作數,不可偏移的內存地址,與 “o’互斥
    r 允許在通用寄存器中使用的寄存器操作數,其中可以指定寄存器,如 a(%rax), b(%rbx)
    i 允許使用立即整數操作數
    n 允許使用具有已知數值的立即整數操作數, ‘I’, ‘J’, ‘K’, … ‘P’ 更應該使用 n
    F 允許使用浮點立即數
    g 允許使用任何寄存器,內存或立即數整數操作數,但非通用寄存器除外
    X 允許任何操作數, ‘0’, ‘1’, ‘2’, … ‘9’
    p 允許使用有效內存地址的操作數
    • 標識符約束
    標識符 說明
    = 表示此操作數是由該指令寫入的:先前的值將被丟棄並由新數據替換
    + 表示該操作數由指令讀取和寫入
    & 表示(在特定替代方法中)此操作數是早期指令操作數,它是在使用輸入操作數完成指令之前寫入的,故輸入操作數部分不能分配與輸出操作數相同的寄存器
    % 表示該操作數與後續操作數的可交換指令

    內核示例

    1. x86 的內存屏障指令。
    // 避免編譯器的優化,聲明此處內存可能發生破壞
    #define barrier() asm volatile("" ::: "memory")
    // 在32位的CPU下,lock 指令為鎖總線,加上一條內存操作指令就達到了內存屏障的作用,64位的cpu已經有新增的 *fence 指令可以使用
    // mb() 執行一個內存屏障作用的指令,為指定CPU操作;破壞列表聲明 cc memory 指示避免編譯器進行優化
    #ifdef CONFIG_X86_32
    #define mb() asm volatile(ALTERNATIVE("lock; addl $0,-4(%%esp)", "mfence", \
                                    X86_FEATURE_XMM2) ::: "memory", "cc")
    #define rmb() asm volatile(ALTERNATIVE("lock; addl $0,-4(%%esp)", "lfence", \
                                    X86_FEATURE_XMM2) ::: "memory", "cc")
    #define wmb() asm volatile(ALTERNATIVE("lock; addl $0,-4(%%esp)", "sfence", \
                                    X86_FEATURE_XMM2) ::: "memory", "cc")
    #else
    #define mb()    asm volatile("mfence":::"memory")
    #define rmb()   asm volatile("lfence":::"memory")
    #define wmb()   asm volatile("sfence" ::: "memory")
    #endif
    1. x86 下獲取 current 的值
    DECLARE_PER_CPU(struct task_struct *, current_task);
    
    #define this_cpu_read_stable(var)   percpu_stable_op("mov", var)
    
    static __always_inline struct task_struct *get_current(void)
    {
            return this_cpu_read_stable(current_task);
    }
    
    #define percpu_stable_op(op, var)           \
    ({                          \
            typeof(var) pfo_ret__;              \
            switch (sizeof(var)) {              \
            case 8:                     \
                    asm(op "q "__percpu_arg(P1)",%0"    \
                    : "=r" (pfo_ret__)          \
                    : "p" (&(var)));            \
                    break;                  \
            }                       \
            pfo_ret__;                  \
    })
    

    current_task 為一個 struct task_struct 類型的指針,追蹤宏調用,在x86-64 下命中了 case 8: 的彙編代碼, 展開的代碼為

    asm("mov" "q ""%%""gs" ":" "%" "P1"",%0" : "=r" (pfo_ret__) : "p" (&(current_task)));
    // 變換一下為
    asm("movq %%gs:%P1, %0" : "=r"(pfo_ret__) : "p"(&(current_task)));

    這行代碼的含義為將 約束輸入部分必須為有效的地址(p約束), 將CPU id(通過段寄存器gs和偏移通過GDT得到,這裏後文分析了)通過寄存器(r約束)賦值給 pfo_ret__.

    參考

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    網頁設計公司推薦更多不同的設計風格,搶佔消費者視覺第一線

    ※廣告預算用在刀口上,網站設計公司幫您達到更多曝光效益

    ※自行創業 缺乏曝光? 下一步"網站設計"幫您第一時間規劃公司的門面形象

    南投搬家前需注意的眉眉角角,別等搬了再說!

    新北清潔公司,居家、辦公、裝潢細清專業服務

  • 手寫jwt驗證,實現java和node無縫切換

    手寫jwt驗證,實現java和node無縫切換

    前言

    前端時間和我寫了一個簡易用戶管理後台,功能其實很簡單,涉及到的技術棧有:vue+elementUI,java+spring MVC以及node+egg,數據庫用的mysql,簡單方便。

    一開始是我是只負責前端,但是前端開發的的速度太快,老是沒事,加上他小子並沒有接觸過實戰的項目,又怕他出亂子,所以考慮我也寫一個後端,

    開始考慮的是用python+django,但是還是在半途放棄了,因為總感覺Django不過靈活,使用起來非常彆扭,也可能是用scrapy寫爬蟲寫多了,難以理解django的框架設計,總是會把他想象成一個scrapy架構,也導致代碼寫的很亂,下面上一張scrapy架構圖。

    所以最後考慮的用node,Express和Koa框架學習過node應該都知道,我以前也用過express(寫過一個小demo),但是給我的感覺這到像是一個只能有5年以上node開發經驗才能玩的轉的,因為express是非常的精簡的,安裝它后,會發現它幾乎不會為你提供任何編碼規範,也沒有約束你的框架應該怎麼設計,以至於新手下載完成后完全不知道自己應該幹嘛,甚至不知道直接的文件應該寫在哪,沒有框架本身的約定,標準的MVC模型有着千奇百怪的寫法,所以我覺得沒有一定的架構思想和經驗是很難駕馭的。

    koa我並沒有直接的使用過,只是聽說是express的原班人馬打造的,中間件是基於洋蔥圈模型實現的。下面上一張圖洋蔥圈模型圖。

    而是後來直接就接觸的egg,egg標語是“為企業級框架和應用而生”,

    廢話說的有點多了,重點是通一套前端代碼,開發了兩套後端代碼,功能是完全一致的,後端都實現了相應的jwt驗證功能,–>,密鑰都是我們約定好的固定值,但是最後發現一樣的密鑰,相同的數據,使用的jwt包不同產生的結果也不同,這也就導致兩端之間無法相互切換,每次切換必須從登陸重新開始,這不太符合邏輯,而且重要的是後面的安排有需要這樣的功能,無法做到無縫切換就直接導致實現不了下面的功能。

    提綱內容

    • jwt實現原理
    • jwt未能解決的疑惑
    • base64和base64url

    jwt實現原理

    其實作為一個前端開發人員,jwt實現原理我是沒必要懂得的,但是如果你不限於此,這算是個必不可少的內容了吧。

    先上一張圖。

    圖中数字1是後端使用jwt工具包生成的token,通常是由三部分組成,也就是token中間的兩個“.”將其分為三部分,第一部分對應的是右邊的数字2部分,然後依次對應。

    這三部分分別是頭部、有效載荷、簽名。

    頭部:alg是指說用到的算法,type當然是令牌類型

    有效荷載:sub所簽發的用戶,name是簽發者的姓名,lat是這簽發時間,exp是指到期時間,當然還有一些其他的,這些數據都是非必要數據,實則只有exp可能有用,因為有效數據實際都是在data裏面,當然你也可以不這麼做。

    簽名:前兩者都是通過base64url編碼過的,而非是算法加密的,所以幾乎是透明的。但是簽名是默認是通過hsa256算法加密的 ,加密的規則是:

    HMACSHA256(
      base64UrlEncode(header) + "." +
      base64UrlEncode(payload),
      your-256-bit-secret
    )

    如何驗證token呢?那更加簡單了,就是用前端傳回來的token前兩部分和服務器存的秘鑰再次加密一次,然後做base64url處理和第三部分比較,一樣代表這個token是自己簽發的,不一樣代表是偽造的,完了過後再將有效載荷部分進行base64url反編碼,就得到exp,然後和當前時間比較是否過期。

    jwt未能解決的疑惑

    經過測試,發現三個問題。

    1、 node和java使用對應的jwt工具包生成的token不相同,這裡是指在一系列參數完全相同的情況下。

    2、 還發現用java生成的token在jwt官網解析時候輸入秘鑰結果的到的簽名和自己的簽名不一樣,但是node是一樣的,於是就產生了java工具包在輸入簽名的時候對密鑰進行了其他處理的想法,但是他並沒有找出做出來怎麼樣的處理,也就是說我們在生成簽名的時候根本就連密鑰都是不一樣的。

    3、 不管是node還是java生成的token,我們用原來一模一樣的數據和一樣的算法公式都產生不了和工具包生成一樣的簽名,也就是可以懷疑在進行hsa256算法加密前確實對秘鑰進行處理了。

    base64和base64url

    base64就是一種二進制編碼方式,原理很簡單,先準備一個包含64個字符的數組:

    ['A','B','C',...'a','b','c',...'0','1','2',...'+','/']

    然後對二進制數據進行處理,每三個字節一組,一共24bit,一個字節8bit嘛,然後再將24分為4組,每組正好6bit。6bit的話就剛好能表示64個字符。如果編碼字符不是3的倍數,就會剩下一個字節或者兩個字節,這個時候就在後面填充\x00,再在編碼末尾加上一個或者兩個=號。解碼的時候制動力去掉就好了。

    base64url編碼就是將字符編碼成url能傳遞的參數,因為base64編碼會出現+號和/號,然後就會在url中出現問題,所以base64url其實就是將+和/分別變成-和_

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!!

    網頁設計一頭霧水??該從何著手呢? 找到專業技術的網頁設計公司,幫您輕鬆架站!

    ※想知道最厲害的台北網頁設計公司推薦台中網頁設計公司推薦專業設計師”嚨底家”!!

    ※幫你省時又省力,新北清潔一流服務好口碑

    ※別再煩惱如何寫文案,掌握八大原則!

  • Spring Boot 2.X(十六):應用監控之 Spring Boot Actuator 使用及配置

    Spring Boot 2.X(十六):應用監控之 Spring Boot Actuator 使用及配置

    Actuator 簡介

    Actuator 是 Spring Boot 提供的對應用系統的自省和監控功能。通過 Actuator,可以使用數據化的指標去度量應用的運行情況,比如查看服務器的磁盤、內存、CPU等信息,系統的線程、gc、運行狀態等等。

    Actuator 通常通過使用 HTTP 和 JMX 來管理和監控應用,大多數情況使用 HTTP 的方式。

    Actuator 端點說明

    端點 描述
    auditevents 獲取當前應用暴露的審計事件信息
    beans 獲取應用中所有的 Spring Beans 的完整關係列表
    caches 獲取公開可以用的緩存
    conditions 獲取自動配置條件信息,記錄哪些自動配置條件通過和沒通過的原因
    configprops 獲取所有配置屬性,包括默認配置,显示一個所有 @ConfigurationProperties 的整理列版本
    env 獲取所有環境變量
    flyway 獲取已應用的所有Flyway數據庫遷移信息,需要一個或多個 Flyway Bean
    liquibase 獲取已應用的所有Liquibase數據庫遷移。需要一個或多個 Liquibase Bean
    health 獲取應用程序健康指標(運行狀況信息)
    httptrace 獲取HTTP跟蹤信息(默認情況下,最近100個HTTP請求-響應交換)。需要 HttpTraceRepository Bean
    info 獲取應用程序信息
    integrationgraph 显示 Spring Integration 圖。需要依賴 spring-integration-core
    loggers 显示和修改應用程序中日誌的配置
    logfile 返回日誌文件的內容(如果已設置logging.file.name或logging.file.path屬性)
    metrics 獲取系統度量指標信息
    mappings 显示所有@RequestMapping路徑的整理列表
    scheduledtasks 显示應用程序中的計劃任務
    sessions 允許從Spring Session支持的會話存儲中檢索和刪除用戶會話。需要使用Spring Session的基於Servlet的Web應用程序
    shutdown 關閉應用,要求endpoints.shutdown.enabled設置為true,默認為 false
    threaddump 獲取系統線程轉儲信息
    heapdump 返回hprof堆轉儲文件
    jolokia 通過HTTP公開JMX bean(當Jolokia在類路徑上時,不適用於WebFlux)。需要依賴 jolokia-core
    prometheus 以Prometheus服務器可以抓取的格式公開指標。需要依賴 micrometer-registry-prometheus

    Actuator 使用及配置

    快速使用

    項目依賴

    <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <!-- actuator -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    </dependencies>

    配置文件

    management.endpoints.enabled-by-default=true
    #啟動所有端點
    management.endpoints.web.exposure.include=*
    #自定義管理端點路徑
    #management.endpoints.web.base-path=/manage

    Spring Boot 2.X 中,Actuator 默認只開放 health 和 info 兩個端點。

    添加management.endpoints.web.exposure.include=*配置后啟動應用,訪問 http://127.0.0.1:8080/actuator 我們可以看到所有的 Actuator 端點列表。

    如果將management.endpoints.enabled-by-default設置為false,則禁用所有端點,如需啟用則如下:

    management.endpoints.enabled-by-default=false
    management.endpoint.info.enabled=true

    禁用的端點將從應用程序上下文中完全刪除。如果只想更改公開端點,使用include和exclude屬性。使用如下:

    management.endpoints.web.exposure.include=*
    management.endpoints.web.exposure.exclude=env,beans

    management.endpoints.web.base-path=/manage 配置表示將 /actuator 路徑重定義為 /manage。

    常用端點詳解

    health

    主要用來檢測應用的運行狀況,是使用最多的一個監控點。監控軟件通常使用該接口實時監測應用運行狀況,在系統出現故障時把報警信息推送給相關人員,如磁盤空間使用情況、數據庫和緩存等的一些健康指標。
    默認情況下 health 端點是開放的,訪問 http://127.0.0.1:8080/actuator/health 即可看到應用運行狀態。

    {"status":"UP"}

    如果需要看到詳細信息,則需要做添加配置:

    management.endpoint.health.show-details=always

    訪問返回信息如下:

    {"status":"UP","details":{"diskSpace":{"status":"UP","details":{"total":180002725888,"free":8687988736,"threshold":10485760}}}}

    info

    查看應用信息是否在 application.properties 中配置。如我們在項目中配置是:

    info.app.name=Spring Boot Actuator Demo
    info.app.version=v1.0.0
    info.app.description=Spring Boot Actuator Demo

    啟動項目,訪問 http://127.0.0.1:8080/actuator/info 返回信息如下:

    {"app":{"name":"Spring Boot Actuator Demo","version":"v1.0.0","description":"Spring Boot Actuator Demo"}}

    env

    通過 env 可以獲取到所有關於當前 Spring Boot 應用程序的運行環境信息,如:操作系統信息(systemProperties)、環境變量信息、JDK 版本及 ClassPath 信息、當前啟用的配置文件(activeProfiles)、propertySources、應用程序配置信息(applicationConfig)等。

    可以通過 http://127.0.0.1:8080/actuator/env/{name} ,name表示想要查看的信息,可以獨立显示。

    beans

    訪問 http://127.0.0.1:8080/actuator/beans 返回部分信息如下:

    {
        "contexts": {
            "Spring Boot Actuator Demo": {
                "beans": {
                    "endpointCachingOperationInvokerAdvisor": {
                        "aliases": [
                        ],
                        "scope": "singleton",
                        "type": "org.springframework.boot.actuate.endpoint.invoker.cache.CachingOperationInvokerAdvisor",
                        "resource": "class path resource [org/springframework/boot/actuate/autoconfigure/endpoint/EndpointAutoConfiguration.class]",
                        "dependencies": [
                            "environment"
                        ]
                    },
                    "defaultServletHandlerMapping": {
                        "aliases": [
                        ],
                        "scope": "singleton",
                        "type": "org.springframework.web.servlet.HandlerMapping",
                        "resource": "class path resource [org/springframework/boot/autoconfigure/web/servlet/WebMvcAutoConfiguration$EnableWebMvcConfiguration.class]",
                        "dependencies": [
                        ]
                    },
                    ...
                }
            }
        }
    }

    從返回的信息中我們可以看出主要展示了 bean 的別名、類型、是否單例、類的地址、依賴等信息。

    conditions

    通過 conditions 可以在應用運行時查看代碼了某個配置在什麼條件下生效,或者某個自動配置為什麼沒有生效。

    訪問 http://127.0.0.1:8080/actuator/conditions 返回部分信息如下:

    {
        "contexts": {
            "Spring Boot Actuator Demo": {
                "positiveMatches": {
                    "SpringBootAdminClientAutoConfiguration": [
                        {
                            "condition": "OnWebApplicationCondition",
                            "message": "@ConditionalOnWebApplication (required) found 'session' scope"
                        },
                        {
                            "condition": "SpringBootAdminClientEnabledCondition",
                            "message": "matched"
                        }
                    ],
                    "SpringBootAdminClientAutoConfiguration#metadataContributor": [
                        {
                            "condition": "OnBeanCondition",
                            "message": "@ConditionalOnMissingBean (types: de.codecentric.boot.admin.client.registration.metadata.CompositeMetadataContributor; SearchStrategy: all) did not find any beans"
                        }
                    ],
                    ...
                }
            }
        }
    }

    loggers

    獲取系統的日誌信息。

    訪問 http://127.0.0.1:8080/actuator/loggers 返回部分信息如下:

    {
        "levels": [
            "OFF",
            "ERROR",
            "WARN",
            "INFO",
            "DEBUG",
            "TRACE"
        ],
        "loggers": {
            "ROOT": {
                "configuredLevel": "INFO",
                "effectiveLevel": "INFO"
            },
            "cn": {
                "configuredLevel": null,
                "effectiveLevel": "INFO"
            },
            "cn.zwqh": {
                "configuredLevel": null,
                "effectiveLevel": "INFO"
            },
            "cn.zwqh.springboot": {
                "configuredLevel": null,
                "effectiveLevel": "INFO"
            },
            ...
        }
    }

    mappings

    查看所有 URL 映射,即所有 @RequestMapping 路徑的整理列表。

    訪問 http://127.0.0.1:8080/actuator/mappings 返回部分信息如下:

    {
        "contexts": {
            "Spring Boot Actuator Demo": {
                "mappings": {
                    "dispatcherServlets": {
                        "dispatcherServlet": [
                            {
                                "handler": "ResourceHttpRequestHandler [class path resource [META-INF/resources/], class path resource [resources/], class path resource [static/], class path resource [public/], ServletContext resource [/], class path resource []]",
                                "predicate": "/**/favicon.ico",
                                "details": null
                            },
                            ...
                        ]
                    }
                }
            }
        }
    }

    heapdump

    訪問:http://127.0.0.1:8080/actuator/heapdump會自動生成一個 GZip 壓縮的 Jvm 的堆文件 heapdump,我們可以使用 JDK 自帶的 Jvm 監控工具 VisualVM 打開此文件查看。如圖:

    VisualVM下載:https://visualvm.github.io/download.html

    threaddump

    獲取系統線程的轉儲信息,主要展示了線程名、線程ID、線程的狀態、是否等待鎖資源等信息。在工作中,我們可以通過查看線程的情況來排查相關問題。

    訪問 http://127.0.0.1:8080/actuator/threaddump 返回部分信息如下:

    {
        "threads": [
            {
                "threadName": "DestroyJavaVM",
                "threadId": 40,
                "blockedTime": -1,
                "blockedCount": 0,
                "waitedTime": -1,
                "waitedCount": 0,
                "lockName": null,
                "lockOwnerId": -1,
                "lockOwnerName": null,
                "inNative": false,
                "suspended": false,
                "threadState": "RUNNABLE",
                "stackTrace": [
                ],
                "lockedMonitors": [
                ],
                "lockedSynchronizers": [
                ],
                "lockInfo": null
            },
            ...
        ]
    }

    shutdown

    開啟可以接口關閉 Spring Boot 應用,要使用這個功能需要做如下配置:

    management.endpoint.shutdown.enabled=true

    可以通過 post(僅支持 post) 請求訪問 http://127.0.0.1:8080/actuator/shutdown 關閉應用。

    metrics

    訪問 http://127.0.0.1:8080/actuator/metrics 可以獲取系統度量指標信息項如下:

    {
        "names": [
            "jvm.memory.max",
            "jvm.threads.states",
            "jvm.gc.pause",
            "http.server.requests",
            "process.files.max",
            "jvm.gc.memory.promoted",
            "system.load.average.1m",
            "jvm.memory.used",
            "jvm.gc.max.data.size",
            "jvm.memory.committed",
            "system.cpu.count",
            "logback.events",
            "tomcat.global.sent",
            "jvm.buffer.memory.used",
            "tomcat.sessions.created",
            "jvm.threads.daemon",
            "system.cpu.usage",
            "jvm.gc.memory.allocated",
            "tomcat.global.request.max",
            "tomcat.global.request",
            "tomcat.sessions.expired",
            "jvm.threads.live",
            "jvm.threads.peak",
            "tomcat.global.received",
            "process.uptime",
            "tomcat.sessions.rejected",
            "process.cpu.usage",
            "tomcat.threads.config.max",
            "jvm.classes.loaded",
            "jvm.classes.unloaded",
            "tomcat.global.error",
            "tomcat.sessions.active.current",
            "tomcat.sessions.alive.max",
            "jvm.gc.live.data.size",
            "tomcat.threads.current",
            "process.files.open",
            "jvm.buffer.count",
            "jvm.buffer.total.capacity",
            "tomcat.sessions.active.max",
            "tomcat.threads.busy",
            "process.start.time"
        ]
    }

    對應訪問 names 中的指標,可以查看具體的指標信息。如訪問 http://127.0.0.1:8080/actuator/metrics/jvm.memory.used 返回信息如下:

    {
        "name": "jvm.memory.used",
        "description": "The amount of used memory",
        "baseUnit": "bytes",
        "measurements": [
            {
                "statistic": "VALUE",
                "value": 1.16828136E8
            }
        ],
        "availableTags": [
            {
                "tag": "area",
                "values": [
                    "heap",
                    "nonheap"
                ]
            },
            {
                "tag": "id",
                "values": [
                    "Compressed Class Space",
                    "PS Survivor Space",
                    "PS Old Gen",
                    "Metaspace",
                    "PS Eden Space",
                    "Code Cache"
                ]
            }
        ]
    }

    示例代碼

    參考文檔

    https://docs.spring.io/spring-boot/docs/2.2.1.RELEASE/reference/html/production-ready-features.html

    非特殊說明,本文版權歸 所有,轉載請註明出處.

    原文標題:Spring Boot 2.X(十六):應用監控之 Spring Boot Actuator 使用及配置

    原文地址:

    如果文章對您有幫助,請掃碼關注下我的公眾號,文章持續更新中…

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※帶您來了解什麼是 USB CONNECTOR  ?

    ※自行創業 缺乏曝光? 下一步"網站設計"幫您第一時間規劃公司的門面形象

    ※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!!

    ※綠能、環保無空污,成為電動車最新代名詞,目前市場使用率逐漸普及化

    ※廣告預算用在刀口上,網站設計公司幫您達到更多曝光效益

    ※教你寫出一流的銷售文案?

  • go中的數據結構-切片slice

    go中的數據結構-切片slice

    1. 部分基本類型

      go中的類型與c的相似,常用類型有一個特例:byte類型,即字節類型,長度為,默認值是0;

    1 bytes = [5]btye{'h', 'e', 'l', 'l', 'o'}

      變量bytes的類型是[5]byte,一個由5個字節組成的數組。它的內存表示就是連起來的5個字節,就像C的數組。

    1.1 字符串

      字符串在Go語言內存模型中用一個2字長(64位,32位內存布局方式下)的數據結構表示。它包含一個指向字符串數據存儲地方的指針,和一個字符串長度數據如下圖:

      s是一個string類型的字符串,因為string類型不可變,對於多字符串共享同一個存儲數據是安全的。切分操作str[i:j]會得到一個新的2字長結構t,一個可能不同的但仍指向同一個字節序列(即上文說的存儲數據)的指針和長度數據。所以字符串切分不涉及內存分配或複製操作,其效率等同於傳遞下標。

    1.2 數組

      數組是內置(build-in)類型,是一組同類型數據的集合,它是值類型,通過從0開始的下標索引訪問元素值。數組類型定義了長度和元素類型。如, [4]int 類型表示一個四個整數的數組,其長度是固定的,長度是數組類型的一部分( [4]int 和 [5]int 是完全不同的類型)。 數組可以以常規的索引方式訪問,表達式 s[n] 訪問數組的第 n 個元素。數組不需要顯式的初始化;數組的零值是可以直接使用的,數組元素會自動初始化為其對應類型的零值。

    1  var a [4]int
    2  a[0] = 1
    3  i := a[0]
    4  // i == 1
    5  // a[2] == 0, int 類型的零值
    6 [5] int {1,2}  //長度為5的數組,其元素值依次為:1,2,0,0,0 。在初始化時沒有指定初值的元素將會賦值為其元素類型int的默認值0,string的默認值是"" 
    7 [...] int {1,2,3,4,5}  //長度為5的數組,其長度是根據初始化時指定的元素個數決定的 
    8 [5] int { 2:1,3:2,4:3}  //長度為5的數組,key:value,其元素值依次為:0,0,1,2,3。在初始化時指定了2,3,4索引中對應的值:1,2,3 
    9 [...] int {2:1,4:3}  //長度為5的數組,起元素值依次為:0,0,1,0,3。由於指定了最大索引4對應的值3,根據初始化的元素個數確定其長度為5賦值與使用

      Go的數組是值語義。一個數組變量表示整個數組,它不是指向第一個元素的指針(不像 C 語言的數組)。 當一個數組變量被賦值或者被傳遞的時候,實際上會複製整個數組。 (為了避免複製數組,你可以傳遞一個指向數組的指針,但是數組指針並不是數組。) 可以將數組看作一個特殊的struct,結構的字段名對應數組的索引,同時成員的數目固定。

    b := [2]string{"Penn", "Teller"}
    b := [...]string{"Penn", "Teller"}

      這兩種寫法, b 都是對應 [2]string 類型。

    2. 切片slice 

    2.1 結構

      切片類型的寫法是[]T ,T是切片元素的類型。和數組不同的是,切片類型並沒有給定固定的長度。切片的字面值和數組字面值很像,不過切片沒有指定元素個數,切片可以通過數組來初始化,也可以通過內置函數make()初始化。

    letters := []string{"a", "b", "c", "d"}   //直接初始化切片,[]表示是切片類型,{"a", "b", "c", "d"},初始化值依次是a,b,c,d.其cap=len=4
    s := letters [:]  //初始化切片s,是數組letters的引用(a slice referencing the storage of x)
    func make([]T, len, cap) []T    //使用內置函數 make 創建
    s :=make([]int,len,cap)    //通過內置函數make()初始化切片s,[]int 標識為其元素類型為int的切片
    s := arr[startIndex:endIndex]   //將arr中從下標startIndex到endIndex-1 下的元素創建為一個新的切片
    s := arr[startIndex:]   //缺省endIndex時將表示一直到arr的最後一個元素
    s := arr[:endIndex]   //缺省startIndex時將表示從arr的第一個元素開始
    s1 := s[startIndex:endIndex]   //通過切片s初始化切片s1

      slice可以從一個數組或一個已經存在的slice中再次聲明。slice通過array[i:j]來獲取,其中i是數組的開始位置,j是結束位置,但不包含array[j],它的長度是j-i

    1 var ar = [10]byte{'a','b','c','d','e','f','g','h','i','j'}   // 聲明一個含有10個元素元素類型為byte的數組
    2 var a, b []byte  // 聲明兩個含有byte的slice
    3 a = ar[2:5]  //現在a含有的元素: ar[2]、ar[3]和ar[4]
    4  
    5 // b是數組ar的另一個slice
    6 b = ar[3:5]// b的元素是:ar[3]和ar[4]

      一個slice是一個數組某個部分的引用。在內存中它是一個包含三個域的結構體:指向slice中第一個元素的指針ptr,slice的長度數據len,以及slice的容量cap。長度是下標操作的上界,如x[i]中i必須小於長度。容量是分割操作的上界,如x[i:j]中j不能大於容量。slice在Go的運行時庫中就是一個C語言動態數組的實現,在$GOROOT/src/pkg/runtime/runtime.h中定義:

    struct    Slice
    {    // must not move anything
        byte*    array;        // actual data
        uintgo    len;        // number of elements
        uintgo    cap;        // allocated number of elements
    };

      數組的slice會創建一份新的數據結構,包含一個指針,一個指針和一個容量數據。如同分割一個字符串,分割數組也不涉及複製操作,它只是新建了一個結構放置三個數據。如下圖:

      示例中,對[]int{2,3,5,7,11}求值操作會創建一個包含五個值的數組,並設置x的屬性來描述這個數組。分割表達式x[1:3]不重新分配內存數據,只寫了一個新的slice結構屬性來引用相同的存儲數據。上例中,長度為2–只有y[0]和y[1]是有效的索引,但是容量為4–y[0:4]是一個有效的分割表達式。

      因為slice分割操作不需要分配內存,也沒有通常被保存在堆中的slice頭部,這種表示方法使slice操作和在C中傳遞指針、長度對一樣廉價。

    2.2 擴容

      其實slice在Go的運行時庫中就是一個C語言動態數組的實現,要增加切片的容量必須創建一個新的、更大容量的切片,然後將原有切片的內容複製到新的切片。在對slice進行append等操作時,可能會造成slice的自動擴容。其擴容時的大小增長規則是:

    • 如果新的大小是當前大小2倍以上,則大小增長為新大小
    • 否則循環以下操作:如果當前大小小於1024,按每次2倍增長,否則每次按當前大小1/4增長。直到增長的大小超過或等於新大小。

      下面的例子將切片 s 容量翻倍,先創建一個2倍 容量的新切片 t ,複製 s 的元素到 t ,然後將 t 賦值給 s : 

    t := make([]byte, len(s), (cap(s)+1)*2) // +1 in case cap(s) == 0
    for i := range s {
            t[i] = s[i]
    }
    s = t

      循環中複製的操作可以由 copy 內置函數替代,返回複製元素的數目。此外, copy 函數可以正確處理源和目的切片有重疊的情況。

    一個常見的操作是將數據追加到切片的尾部。必要的話會增加切片的容量,最後返回更新的切片:

    func AppendByte(slice []byte, data ...byte) []byte {
        m := len(slice)
        n := m + len(data)
        if n > cap(slice) { // if necessary, reallocate
            // allocate double what's needed, for future growth.
            newSlice := make([]byte, (n+1)*2)
            copy(newSlice, slice)
            slice = newSlice
        }
        slice = slice[0:n]
        copy(slice[m:n], data)
        return slice
    }

      Go提供了一個內置函數 append,也實現了這樣的功能。

    func append(s []T, x ...T) []T
    //append 函數將 x 追加到切片 s 的末尾,並且在必要的時候增加容量。
    a := make([]int, 1)
    // a == []int{0}
    a = append(a, 1, 2, 3)
    // a == []int{0, 1, 2, 3}

      如果是要將一個切片追加到另一個切片尾部,需要使用 ... 語法將第2個參數展開為參數列表。

    a := []string{"John", "Paul"}
    b := []string{"George", "Ringo", "Pete"}
    a = append(a, b...) // equivalent to "append(a, b[0], b[1], b[2])"
    // a == []string{"John", "Paul", "George", "Ringo", "Pete"}

      由於切片的零值 nil 用起來就像一個長度為零的切片,我們可以聲明一個切片變量然後在循環 中向它追加數據:

    // Filter returns a new slice holding only
    // the elements of s that satisfy fn()
    func Filter(s []int, fn func(int) bool) []int {
        var p []int // == nil
        for _, v := range s {
            if fn(v) {
                p = append(p, v)
            }
        }
        return p
    }

    3. 使用切片需要注意的陷阱

      切片操作並不會複製底層的數組。整個數組將被保存在內存中,直到它不再被引用。 有時候可能會因為一個小的內存引用導致保存所有的數據。

      如下, FindDigits 函數加載整個文件到內存,然後搜索第一個連續的数字,最後結果以切片方式返回。

    var digitRegexp = regexp.MustCompile("[0-9]+")
    
    func FindDigits(filename string) []byte {
        b, _ := ioutil.ReadFile(filename)
        return digitRegexp.Find(b)
    }

      這段代碼的行為和描述類似,返回的 []byte 指向保存整個文件的數組。因為切片引用了原始的數組, 導致 GC 不能釋放數組的空間;只用到少數幾個字節卻導致整個文件的內容都一直保存在內存里。要修復整個問題,可以將需要的數據複製到一個新的切片中:

    func CopyDigits(filename string) []byte {
        b, _ := ioutil.ReadFile(filename)
        b = digitRegexp.Find(b)
        c := make([]byte, len(b))
        copy(c, b)
        return c
    }

      使用 append 實現一個更簡潔的版本:

        8  func CopyDigitRegexp(filename string) []byte {
        7     b,_ := ioutil.ReadFile(filename)
        6     b = digitRefexp.Find(b)
        5     var c []intb
        4    // for _,v := range b{
        3         c =append(c, b)
        2     //}
        1     return c
        0  }

    4. make和new

    Go有兩個數據結構創建函數:make和new,也是兩種不同的內存分配機制。

    make和new的基本的區別是new(T)返回一個*T,返回的是一個指針,指向分配的內存地址,該指針可以被隱式地消除引用)。而make(T, args)返回一個普通的T。通常情況下,T內部有一些隱式的指針。所以new返回一個指向已清零內存的指針,而make返回一個T類型的結構。更詳細的區別在後面內存分配的學習里研究。

    5. 數組和切片的區別

    • 數組長度不能改變,初始化后長度就是固定的;切片的長度是不固定的,可以追加元素,在追加時可能使切片的容量增大。
    • 結構不同,數組是一串固定數據,切片描述的是截取數組的一部分數據,從概念上說是一個結構體。
    • 初始化方式不同,如上。另外在聲明時的時候:聲明數組時,方括號內寫明了數組的長度或使用...自動計算長度,而聲明slice時,方括號內沒有任何字符。
    • unsafe.sizeof的取值不同,unsafe.sizeof(slice)返回的大小是切片的描述符,不管slice里的元素有多少,返回的數據都是24。unsafe.sizeof(arr)的值是在隨着arr的元素的個數的增加而增加,是數組所存儲的數據內存的大小。

      unsafe.sizeof總是在編譯期就進行求值,而不是在運行時,這意味着,sizeof的返回值可以賦值給常量。  在編譯期求值,還意味着可以獲得數組所佔的內存大小,因為數組總是在編譯期就指明自己的容量,並且在以後都是不可變的。

      unsafe.sizeof(string)時大小始終是16,不論字符串的len有多大,sizeof始終返回16,這是因為字符串類型對應一個結構體,該結構體有兩個域,第一個域是指向該字符串的指針,第二個域是字符串的長度,每個域佔8個字節,但是並不包含指針指向的字符串的內容。

    6. nil

      按照Go語言規範,任何類型在未初始化時都對應一個零值:布爾類型是false,整型是0,字符串是””,而指針,函數,interface,slice,channel和map的零值都是nil。

    interface

      一個interface在沒有進行初始化時,對應的值是nil。也就是說var v interface{},此時v就是一個nil。在底層存儲上,它是一個空指針。與之不同的情況是,interface值為空。比如:

    1 var v *T
    2 var i interface{}
    3 i = v

      此時i是一個interface,它的值是nil,但它自身不為nil。

    string

      string的空值是””,它是不能跟nil比較的。即使是空的string,它的大小也是兩個機器字長的。slice也類似,它的空值並不是一個空指針,而是結構體中的指針域為空,空的slice的大小也是三個機器字長的。

    channel

      channel跟string或slice有些不同,它在棧上只是一個指針,實際的數據都是由指針所指向的堆上面。

      跟channel相關的操作有:初始化/讀/寫/關閉。channel未初始化值就是nil,未初始化的channel是不能使用的。下面是一些操作規則:

    • 讀或者寫一個nil的channel的操作會永遠阻塞。
    • 讀一個關閉的channel會立刻返回一個channel元素類型的零值。
    • 寫一個關閉的channel會導致panic。

    map

      map也是指針,實際數據在堆中,未初始化的值是nil。

     

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※為什麼 USB CONNECTOR 是電子產業重要的元件?

    網頁設計一頭霧水??該從何著手呢? 找到專業技術的網頁設計公司,幫您輕鬆架站!

    ※想要讓你的商品成為最夯、最多人討論的話題?網頁設計公司讓你強力曝光

    ※想知道最厲害的台北網頁設計公司推薦台中網頁設計公司推薦專業設計師”嚨底家”!!

    新北清潔公司,居家、辦公、裝潢細清專業服務

  • 通俗地說邏輯回歸【Logistic regression】算法(二)sklearn邏輯回歸實戰

    通俗地說邏輯回歸【Logistic regression】算法(二)sklearn邏輯回歸實戰

    前情提要:

    上一篇主要介紹了邏輯回歸中,相對理論化的知識,這次主要是對上篇做一點點補充,以及介紹sklearn 邏輯回歸模型的參數,以及具體的實戰代碼。

    1.邏輯回歸的二分類和多分類

    上次介紹的邏輯回歸的內容,基本都是基於二分類的。那麼有沒有辦法讓邏輯回歸實現多分類呢?那肯定是有的,還不止一種。

    實際上二元邏輯回歸的模型和損失函數很容易推廣到多元邏輯回歸。比如總是認為某種類型為正值,其餘為0值。

    舉個例子,要分類為A,B,C三類,那麼就可以把A當作正向數據,B和C當作負向數據來處理,這樣就可以用二分類的方法解決多分類的問題,這種方法就是最常用的one-vs-rest,簡稱OvR。而且這種方法也可以方便得推廣到其他二分類模型中(當然其他算法可能有更好的多分類辦法)。

    另一種多元邏輯回歸的方法是Many-vs-Many(MvM),它會選擇一部分類別的樣本和另一部分類別的樣本來做邏輯回歸二分類。

    聽起來很不可思議,但其實確實是能辦到的。比如數據有A,B,C三個分類。

    我們將A,B作為正向數據,C作為負向數據,訓練出一個分模型。再將A,C作為正向數據,B作為負向數據,訓練出一個分類模型。最後B,C作為正向數據,C作為負向數據,訓練出一個模型。

    通過這三個模型就能實現多分類,當然這裏只是舉個例子,實際使用中有其他更好的MVM方法。限於篇幅這裏不展開了。

    MVM中最常用的是One-Vs-One(OvO)。OvO是MvM的特例。即每次選擇兩類樣本來做二元邏輯回歸。

    對比下兩種多分類方法,通常情況下,Ovr比較簡單,速度也比較快,但模型精度上沒MvM那麼高。MvM則正好相反,精度高,但速度上比不過Ovr。

    2.邏輯回歸的正則化

    所謂正則化,其目的是為了減弱邏輯回歸模型的精度,難道模型的準確度不是越高越好嘛?看看下面這張圖就明白了:

    左邊那個圖就是過擬合的情況,過擬合其實就是模型的精度太過高了,它能非常好得匹配訓練集的數據,但一旦有新的數據,就會表現得很差。

    而我們要的非過擬合的模型是,精度可以差一些,但泛化性能,也就是對新的數據的識別能力,要比較好。

    正則化就是減弱模型精度,提高泛化效果的這個東西。

    3.sklearn各個參數

    def LogisticRegression(penalty='l2', 
                                        dual=False, 
                                        tol=1e-4, 
                                        C=1.0,
                                        fit_intercept=True, 
                                        intercept_scaling=1, 
                                        class_weight=None,
                                        random_state=None, 
                                        solver='warn', 
                                        max_iter=100,
                                        multi_class='warn', 
                                        verbose=0, 
                                        warm_start=False, 
                                        n_jobs=None,
                                        l1_ratio=None
                                        )
    跟線性回歸一比,邏輯回歸的參數那還真是多啊,不過我們一個一個來看看參數都是什麼意思吧。                                 
    
    - dual:對偶或者原始方法,布爾類型,默認為False。Dual只適用於正則化相為l2的‘liblinear’的情況,通常樣本數大於特徵數的情況下,默認為False。
    
    - tol:停止迭代求解的閾值,單精度類型,默認為1e-4。
    
    - C:正則化係數的倒數,必須為正的浮點數,默認為 1.0,這個值越小,說明正則化效果越強。換句話說,這個值越小,越訓練的模型更泛化,但也更容易欠擬合。
    
    - fit_intercept:是否要使用截距(在決策函數中使用截距),布爾類型,默認為True。
    
    - intercept_scaling:官方解釋比較模糊,我說下個人理解。浮點型,默認值是1.0。這個參數僅在“solver”參數(下面介紹)為“liblinear”“fit_intercept ”參數為True的時候生效。作用是給特徵向量添加一個常量,這個常量就是intercept_scaling。比如原本的向量是[x],那麼添加后就變成[x,intercept_scaling]。
    
    - class_weight:分類權重,可以是一個dict(字典類型),也可以是一個字符串"balanced"字符串。默認是None,也就是不做任何處理,而"balanced"則會去自動計算權重,分類越多的類,權重越低,反之權重越高。也可以自己輸出一個字典,比如一個 0/1 的二元分類,可以傳入{0:0.1,1:0.9},這樣 0 這個分類的權重是0.1,1這個分類的權重是0.9。這樣的目的是因為有些分類問題,樣本極端不平衡,比如網絡攻擊,大部分正常流量,小部分攻擊流量,但攻擊流量非常重要,需要有效識別,這時候就可以設置權重這個參數。
    
    - random_state:設置隨機數種子,可以是int類型和None,默認是None。當"solver"參數為"sag"和"liblinear"的時候生效。
    
    - verbose:輸出詳細過程,int類型,默認為0(不輸出)。當大於等於1時,輸出訓練的詳細過程。僅當"solvers"參數設置為"liblinear"和"lbfgs"時有效。
    
    - warm_start:設置熱啟動,布爾類型,默認為False。若設置為True,則以上一次fit的結果作為此次的初始化,如果"solver"參數為"liblinear"時無效。
    
    - max_iter:最大迭代次數,int類型,默認-1(即無限制)。注意前面也有一個tol迭代限制,但這個max_iter的優先級是比它高的,也就如果限制了這個參數,那是不會去管tol這個參數的。
    

    OK,上述就是對一些比較簡略的參數的說明,但是還有幾個重要的參數沒講到,這是因為這幾個參數我覺得需要單獨拎出來講一講。

    sklearn邏輯回歸參數 –penalty

    正則化類型選擇,字符串類型,可選’l1’,’l2’,’elasticnet’和None,默認是’l2’,通常情況下,也是選擇’l2’。這個參數的選擇是會影響到參數’solver’的選擇的,下面會介紹。

    其中’l1’和’l2’。分別對應L1的正則化和L2的正則化,’elasticnet’則是彈性網絡(這玩意我也不大懂),默認是L2的正則化。

    在調參時如果主要的目的只是為了解決過擬合,一般penalty選擇L2正則化就夠了。但是如果選擇L2正則化發現還是過擬合,即預測效果差的時候,就可以考慮L1正則化。另外,如果模型的特徵非常多,我們希望一些不重要的特徵係數歸零,從而讓模型係數稀疏化的話,也可以使用L1正則化。

    penalty參數的選擇會影響我們損失函數優化算法的選擇。即參數solver的選擇,如果是L2正則化,那麼4種可選的算法{‘newton-cg’,‘lbfgs’,‘liblinear’,‘sag’}都可以選擇。但是如果penalty是L1正則化的話,就只能選擇‘liblinear’了。這是因為L1正則化的損失函數不是連續可導的,而{‘newton-cg’,‘lbfgs’,‘sag’}這三種優化算法時都需要損失函數的一階或者二階連續導數。而‘liblinear’並沒有這個依賴。最後還有一個’elasticnet’,這個只有solver參數為’saga’才能選。

    sklearn邏輯回歸參數 –solver

    優化算法參數,字符串類型,一個有五種可選,分別是”newton-cg”,”lbfgs”,”liblinear”,”sag”,”saga。默認是”liblinear”。分別介紹下各個優化算法:

    • a) liblinear:使用了開源的liblinear庫實現,內部使用了坐標軸下降法來迭代優化損失函數。
    • b) lbfgs:擬牛頓法的一種,利用損失函數二階導數矩陣即海森矩陣來迭代優化損失函數。
    • c) newton-cg:也是牛頓法家族的一種,利用損失函數二階導數矩陣即海森矩陣來迭代優化損失函數。
    • d) sag:即隨機平均梯度下降,是梯度下降法的變種,和普通梯度下降法的區別是每次迭代僅僅用一部分的樣本來計算梯度,適合於樣本數據多的時候。
      在優化參數的選擇上,官方是這樣建議的:
    • e)saga:優化的,無偏估計的sag方法。(‘sag’ uses a Stochastic Average Gradient descent, and ‘saga’ uses its improved, unbiased version named SAGA.)
      對小的數據集,可以選擇”liblinear”,如果是大的數據集,比如說大於10W的數據,那麼選擇”sag”和”saga”會讓訓練速度更快。

    對於多分類問題,只有newton-cg,sag,saga和lbfgs能夠處理多項損失(也就是MvM的情況,還記得上面說到的多分類嘛?),而liblinear僅處理(OvR)的情況。啥意思,就是用liblinear的時候,如果是多分類問題,得先把一種類別作為一個類別,剩餘的所有類別作為另外一個類別。一次類推,遍歷所有類別,進行分類。

    這個的選擇和正則化的參數也有關係,前面說到”penalty”參數可以選擇”l1″,”l2″和None。這裏’liblinear’是可以選擇’l1’正則和’l2’正則,但不能選擇None,’newton-cg’,’lbfgs’,’sag’和’saga’這幾種能選擇’l2’或no penalty,而’saga’則能選怎’elasticnet’正則。好吧,這部分還是挺繞的。

    歸納一下吧,二分類情況下,數據量小,一般默認的’liblinear’的行,數據量大,則使用’sag’。多分類的情況下,在數據量小的情況下,追求高精度,可以用’newton-cg’或’lbfgs’以’MvM’的方式求解。數據量一大還是使用’sag’。

    當然實際情況下還是要調參多次才能確定參數,這裏也只能給些模糊的建議。

    sklearn邏輯回歸參數 –multi_class

    multi_class參數決定了我們分類方式的選擇,有 ovr和multinomial兩個值可以選擇,默認是 ovr。
    ovr即前面提到的one-vs-rest(OvR),而multinomial即前面提到的many-vs-many(MvM)。如果是二元邏輯回歸,ovr和multinomial並沒有任何區別,區別主要在多元邏輯回歸上。

    4.sklearn實例

    實例這部分,就直接引用sklearn官網的,使用邏輯回歸對不同種類的鳶尾花進行分類的例子吧。

    import numpy as np
    import matplotlib.pyplot as plt
    from sklearn import linear_model, datasets
    
    # 加載鳶尾花數據
    iris = datasets.load_iris()
    # 只採用樣本數據的前兩個feature,生成X和Y
    X = iris.data[:, :2]  
    Y = iris.target
    
    h = .02  # 網格中的步長
    
    # 新建模型,設置C參數為1e5,並進行訓練
    logreg = linear_model.LogisticRegression(C=1e5)
    logreg.fit(X, Y)
    
    # 繪製決策邊界。為此我們將為網格 [x_min, x_max]x[y_min, y_max] 中的每個點分配一個顏色。
    x_min, x_max = X[:, 0].min() - .5, X[:, 0].max() + .5
    y_min, y_max = X[:, 1].min() - .5, X[:, 1].max() + .5
    xx, yy = np.meshgrid(np.arange(x_min, x_max, h), np.arange(y_min, y_max, h))
    Z = logreg.predict(np.c_[xx.ravel(), yy.ravel()])
    
    # 將結果放入彩色圖中
    Z = Z.reshape(xx.shape)
    plt.figure(1, figsize=(4, 3))
    plt.pcolormesh(xx, yy, Z, cmap=plt.cm.Paired)
    
    # 將訓練點也同樣放入彩色圖中
    plt.scatter(X[:, 0], X[:, 1], c=Y, edgecolors='k', cmap=plt.cm.Paired)
    plt.xlabel('Sepal length')
    plt.ylabel('Sepal width')
    
    plt.xlim(xx.min(), xx.max())
    plt.ylim(yy.min(), yy.max())
    plt.xticks(())
    plt.yticks(())
    
    plt.show()

    運行上面那段代碼會有如下的結果:

    可以看到,已將三種類型的鳶尾花都分類出來了。

    小結

    邏輯回歸算是比較簡單的一種分類算法,而由於簡單,所以也比較適合初學者初步接觸機器學習算法。學習了之後,對後面一些更複雜的機器學習算法,諸如Svm,或更高級的神經網絡也能有一個稍微感性的認知。

    而實際上,Svm可以看作是邏輯回歸的更高級的演化。而從神經網絡的角度,邏輯回歸甚至可以看作一個最初級,最淺層的神經網絡。

    邏輯回歸就像是金庸小說裏面,獨孤九劍的第一式,最為簡單,卻又是其他威力極大的招式的基礎,其他的招式都又第一式演化而出。

    夯實基礎,才能砥礪前行。

    以上~

    參考文章:

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能

    ※評比前十大台北網頁設計台北網站設計公司知名案例作品心得分享

    ※智慧手機時代的來臨,RWD網頁設計已成為網頁設計推薦首選

    ※評比南投搬家公司費用收費行情懶人包大公開

    ※幫你省時又省力,新北清潔一流服務好口碑

  • HtmlSpanner 使用小結 — 安卓解析html

    HtmlSpanner 使用小結 — 安卓解析html

    如何利用 HtmlSpanner解析 HTML格式 的字符串:

    1. GitHub 下載HtmlSpanner項目 https://github.com/NightWhistler/HtmlSpanner

    2. 最好是直接放在java目錄下在,這樣不需要改引用的包路徑

    3.  引入需要的依賴包

        implementation 'net.sourceforge.htmlcleaner:htmlcleaner:2.21'
        implementation 'com.osbcp:cssparser:1.7'
    

      4. 使用方法:

     // 頁面上用於展示 html格式的文本布局
     TextView textView = findViewById(R.id.htmlSpanner);
     // 直接 new一個 HtmlSpanner對象
     HtmlSpanner htmlSpanner = new HtmlSpanner(); // 格式化
     // 解析 html得到 spannable對象
     Spannable spannable1 = htmlSpanner.fromHtml("<span style='color:red'>html格式的文字1</span>");
     // 显示到 TextView上
     textView.setText(spannable1);
    

     5. 在使用中遇到的問題——當富文本中顏色格式是rgb格式,解析失敗

     

     

     

     

     解決思路:

      1. 首先我們解析的是style=’color:rgb(0,255,255)’ 這種格式,於是看源碼覺得 CSSCompiler 這個類很有問題

      2. 找與顏色相關的於是就找到了 parseCSSColor( String colorString ) 這個方法,看起來就是轉換顏色用的

      3. 源碼的寫法如下:(是沒有對於rgb格式的算法,所以不能解析就很合理啦)

      

     

       4. 想法修改:( 遇到 0rgb格式就先處理成我們的 hex格式,這樣不就完美了嘛 )

      5. 工具類代碼如下:

    package com.xxx.xxx.xxx;
    
    public class ColorUtil {
    
         /**
         * rgb 格式的顏色轉 hex格式顏色
         * @param rgb
         * @return
         */
        public static String rgb2hex(String rgb) {
            int r = 0;
            int g = 0;
            int b = 0;
            int left = rgb.indexOf("(");
            int right = rgb.indexOf(")");
            if (left > -1 && right > -1 && right > left) {
                String substring = rgb.substring(left + 1, right);
                String[] split = substring.split(",");
                if (split.length == 3){
                    r = Integer.valueOf(split[0].trim());
                    g = Integer.valueOf(split[1].trim());
                    b = Integer.valueOf(split[2].trim());
                }
            }
            String rFString, rSString, gFString, gSString,
                    bFString, bSString, result;
            int red, green, blue;
            int rred, rgreen, rblue;
            red = r / 16;
            rred = r % 16;
            if (red == 10) rFString = "A";
            else if (red == 11) rFString = "B";
            else if (red == 12) rFString = "C";
            else if (red == 13) rFString = "D";
            else if (red == 14) rFString = "E";
            else if (red == 15) rFString = "F";
            else rFString = String.valueOf(red);
    
            if (rred == 10) rSString = "A";
            else if (rred == 11) rSString = "B";
            else if (rred == 12) rSString = "C";
            else if (rred == 13) rSString = "D";
            else if (rred == 14) rSString = "E";
            else if (rred == 15) rSString = "F";
            else rSString = String.valueOf(rred);
    
            rFString = rFString + rSString;
    
            green = g / 16;
            rgreen = g % 16;
    
            if (green == 10) gFString = "A";
            else if (green == 11) gFString = "B";
            else if (green == 12) gFString = "C";
            else if (green == 13) gFString = "D";
            else if (green == 14) gFString = "E";
            else if (green == 15) gFString = "F";
            else gFString = String.valueOf(green);
    
            if (rgreen == 10) gSString = "A";
            else if (rgreen == 11) gSString = "B";
            else if (rgreen == 12) gSString = "C";
            else if (rgreen == 13) gSString = "D";
            else if (rgreen == 14) gSString = "E";
            else if (rgreen == 15) gSString = "F";
            else gSString = String.valueOf(rgreen);
    
            gFString = gFString + gSString;
    
            blue = b / 16;
            rblue = b % 16;
    
            if (blue == 10) bFString = "A";
            else if (blue == 11) bFString = "B";
            else if (blue == 12) bFString = "C";
            else if (blue == 13) bFString = "D";
            else if (blue == 14) bFString = "E";
            else if (blue == 15) bFString = "F";
            else bFString = String.valueOf(blue);
    
            if (rblue == 10) bSString = "A";
            else if (rblue == 11) bSString = "B";
            else if (rblue == 12) bSString = "C";
            else if (rblue == 13) bSString = "D";
            else if (rblue == 14) bSString = "E";
            else if (rblue == 15) bSString = "F";
            else bSString = String.valueOf(rblue);
            bFString = bFString + bSString;
            result = "#" + rFString + gFString + bFString;
            return result;
        }
    }
    

     

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    台北網頁設計公司這麼多,該如何挑選?? 網頁設計報價省錢懶人包"嚨底家"

    網頁設計公司推薦更多不同的設計風格,搶佔消費者視覺第一線

    ※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

    南投搬家費用,距離,噸數怎麼算?達人教你簡易估價知識!

    ※教你寫出一流的銷售文案?

  • 深入理解計算機系統 — 信息的表示和處理

    深入理解計算機系統 — 信息的表示和處理

    1. 信息的存儲

        大多數計算機使用 8 位的塊,或者字節,作為最小的尋址內存單位,而非訪問內存中單獨的位,機器級程序將內存視為一個非常大的字節數組,稱為 虛擬內存 ,內存的每個字節都用一個唯一的数字標識,稱為它的 地址 。以 C 語言的指針為例,指針使用時指向某一個存儲塊的首字節的 虛擬地址 ,C 編譯器將指針和其類型信息結合起來,這樣即可以根據指針的類型,生成不同的機器級代碼來訪問存儲在指針所指向位置處的值。每個程序對象可以簡單視為一個字節塊,而程序本身就是一個字節序列。

    1.1 十六進製表示法

        一個字節由 8 位組成。用二進製表示即 00000000 ~ 11111111 。十進製表示為 0 ~ 255 。由於兩者表示要麼過於冗餘,要麼轉換不遍,因此通常使用十六進制來表示一個字節。這幾種進制的轉換在此就不多說了。

    1.2 字數據大小

        每台計算機都會有一個字長(此處字長非字節長度),指明 指針數據的標稱大小(nominal size),因為虛擬地址是以這樣的一個字來進行編碼的,所以字長決定的最重要的一個系統參數即是虛擬地址空間的最大大小。 對於一個字長為 w 位的機器而言,虛擬地址的範圍為 0 ~ (2 ^w )- 1 ,程序最多訪問 2 ^ w 個字節。以 32 位機器為例,32位字長限制虛擬地址空間為 (2 ^32) -1 ,程序最多訪問 2 ^ 32 個字節,大約為 4 x 10^9 字節,即4 GB ( 根據 2 ^ 10 (1024) 約等於 10 ^ 3 (1000) ,可以得到 2 ^ 32 =  4 * 2^30 = 4 * 10 ^ 9 ) 。64位機器的限制虛擬地址空間為 16 EB。大約為 1.84 x 10 ^9 。

    1.3 尋址和字節順序

        對於跨越多個字節的對象,我們必須建立兩個規則:這個對象的地址是什麼以及在內存中如何排列這些字節。在幾乎所有的機器上,多字節對象都被存儲為連續的字節序列,對象的地址為這個字節序列中最小的字節地址。以 int 類型為例,假定int 大小為32 位,有變量 int x = 0x01234567 。若 x 的地址為 0x100 ,則 x 的 4 個字節將被存儲在 0x100 , 0x101 , 0x102, 0x103 的位置,此時 4個字節的值分別為 0x01, 0x23, 0x45, 0x67,那麼在內存中的排列順序有如下兩種情況,

    • 大端法:最高有效字節放在最前面的方式稱為大端法,即將一個数字的最高位字節放在最小的字節地址。
    • 小端法:最低有效字節放在最前面的方式稱為小端法,即將一個数字的最低位字節放在最小的字節地址。

      以上面的 x 為例,x 的最高位字節是 0x01 ,將其放在最小的字節地址即 0x100。x 的最低位字節為 0x67 ,將其放在最小的字節地址 0x100 。即大小端對應高低位字節。對於我們來說,機器的字節順序是完全不可見的,我們大部分情況下也無需關心其字節順序,但是在不同類型的機器之間通過網絡傳遞二進制數據的時候,如小端法機器傳送數據給大端法機器時,接受方接收到的字節序會變成反序,為了避免這種問題的產生,發送方和接收方都需要遵循一個網絡規則,發送方將二進制數據轉換成網絡標準,接收方再將這個網絡標準的字節序轉換成自己的字節序。此外,我們在閱讀機器級代碼的時候,可能會出現如下的情況:

      暫時忽略這條指令的意義,可以看到左邊6個字節分別為 01 05 43 0b 20 00 ,而右邊的指令中的地址為 0x200b43,可以看到從左邊的第三個字節開始,43 0b 20 是右邊指令地址的倒序,因此在閱讀這種機器級代碼的時候,也需要注意字節序的問題。此外還存在一種情況。如下圖所示。

        我們可以看到, show_bytes 這個函數可以打印出 start 指針指向的地址開始的 len 個字節內容,且不受字節序的影響,那麼它是如何做到的呢?在 show_int 函數中,可以看到它將 參數 x 的地址強制類型轉換為了 byte_pointer , 即 unsigned char * 。通過強制類型轉換的 start 指針指向的仍是 x 的最低字節地址,但是其類型改變了,通過其類型編譯器會認為該指針指向的對象大小為 1 個字節,此時將該指針進行 ++ 操作可以得到順延下一個字節的內容,從而得到對應的整個對象的字節序列中每個字節的內容而不受字節序影響。

    1.4 字符串

        在C語言中,字符串被編碼為一個以 null (其值為0 )字符結尾的字符數組。每個字符都有某個標準編碼來表示,最常見的則是 ASCII 字符碼。假如我們調用 show_bytes(“12345”, 6),那麼會輸出 31 32 33 34 35 00 。可以看到最後打印出了一個終止符,所以通常 C 字符串的長度為實際字符串長度 + 1。 在C 標準庫中的 strlen 函數可以傳入一個字符串得出其長度,這裏的長度即是實際長度,不包含終止符。

    2. 整數表示

        在本章節中,介紹了編碼整數的兩種不同的方式,一種只能表示非負數,另一種則能夠表示負數,正數和零。接下來逐一進行介紹。

    2.1 整型數據類型

        C語言中,整數有多種數據類型,如下圖所示,此外可以通過加上 unsigned 符號來限定該數據類型為非負數。這些數據類型有的是根據機器的字長(32位和64位)決定其實際最大值和最小值的範圍。我們可以看到,圖中最小值和最大值的取值範圍是不對稱的,負數的取值範圍比正數大一,當我們考慮如何表現負數時,會看到為什麼會這樣。

        關於無符號整數的編碼,其實與普通的十進制正數轉換成二進制沒有什麼區別,假設字長 w = 32 位,轉換后大於 32 位的数字將被捨去。這裏主要介紹一下關於有符號数字的編碼,通常計算機使用的編碼錶示方式為 補碼 ,在這個表示方式中,將字的最高有效位(即符號位)表示為負權,權重為 – 2^(w-1) ,當 w 位的值為 1 時表示為負數,反之為正數。以 -1 為例,-1 的補碼為1111 1111  …. …. 1111 ,即 -2^31 + 2^30 + … + 2^0 = -1 ,通常我們看到一個負數想要直接將其使用補碼錶示還是有些不方便的,因此我們可以先使用原碼錶示,所謂原碼和普通的十進制數轉二進制數沒有區別,只不過最高位用來表示符號位,然後再求其反碼,即符號位不變,其餘位取反加 1,就可以得到這個負數的補碼了,還是以 -1 舉例, -1 的原碼為 1000 0000 …. 0001 ,其反碼的值為 1111 1111 …. 1111 ,與 -1 的補碼值是相同的。而正數的補碼為其本身,不需要做這種轉換。

        那麼為什麼要使用補碼這種表示方式呢,首先,二進制補碼可以使正負數相加時仍然採用正常加法的邏輯,不需要做特殊的處理,此外,如果不採用補碼錶示,採用原碼的表示方法,那麼會出現幾個問題,正負零的存在,以及提高了減法的計算複雜度,而補碼可以十分簡單的計算正負數相加,只需求出兩者的補碼對其進行加法,更多關於補碼的解釋可以參考  。

    PS: 為什麼正負數補碼相加會得到正確的結果,這裏個人的見解是:由於補碼最高位為負權,而正數與負數補碼相加相當於正數去抵消這個負權。比如 -16 的補碼為 1111 …. 1111 0000,加上正數 1,由於正數的補碼為本身,所以等價於 -16 + 1  == (-2^31 + 2^30 + … + 2^4 ) +  2^ 0 ,相當於多了一個 2^0 的正權去抵消其最高位的負權。

    2.2 有符號數和無符號數之間的轉換

        C語言允許各種不同的数字類型之間進行強制類型轉換, 如 int x= -1 ; unsigned y = (unsigned) x ; 此時會將 x 的值強制類型轉換成 unsigned 類型然後賦值給 y ,那麼此時 y 的值是多少呢?可以通過打印兩者的十六進制值來看有什麼區別。下面為 test.c 的代碼:

    int main()

    {

    int x = -1;

    unsigned y = (unsigned) x;

    printf(“%x \n”, x);

    printf(“%x \n”, x);

    return 0;

    }

    此處為編譯后可執行文件的輸出結果:

    ffffffff
    ffffffff

    可以看到, x 和 y 的十六進制值是相同的,這也說明了,強制類型轉換並不會改變數據底層的位表示,只是改變了解釋位模式的方式。我們可以利用 printf 的指示符進一步驗證這個結果,使用 %d (有符號十進制), %u (無符號十進制), 來打印 x 和 y 的值。以下是代碼:

    int main()

    {

    int x = 1;

    unsigned y = (unsigned) x;

    printf(“x format d = %d , format u = %u \n”, x, x);

    printf(“y format d = %d , format u = %u \n”, y, y);

    return 0;

    }

    這是編譯后可執行文件的對應輸出:

    x format d = -1 , format u = 4294967295
    y format d = -1 , format u = 4294967295

     我們可以看到,我們使用指示符控制了解釋這些位的方式,得到的結果是一致的。

    2.3 整數運算

     關於整數的運算,主要就是加減乘除四種運算,補碼的加減乘除都比較簡單明了,這裏主要說一下除法的舍入問題,首先,我們先確認下 C 語言中的舍入方式,在 C 語言中,浮點數被賦值給整數時,小數位總是被捨去,如

    float f = 1.5;

    int x = f ;

    printf(“%d \n “, x);

    輸出的結果為:

    1

    當 f 為負數時結果又是如何呢 ?

    float f = -1.5 ;

    int x = f;

    printf(“%d \n”, x);

    輸出的結果為:

    -1

    因此我們可以認為,C語言的舍入方式為向零舍入。接下來看一下除法的舍入問題。此處先以除以 2 的冪的無符號除法為例,

    上圖表示 12340 / 2^k 的時候二進制與對應的十進制的表示,此時的舍入是完全沒有問題的。接下來看下除以 2 的冪的有符號除法。

        當k = 4 的時候,-12340 / 2^ 4 == -771.25,此時的正確舍入值應該為 -771,但是其卻舍入成了 -772。這是因為,如果我們單純使用右移來進行除法的時候,其舍入方式為向下舍入,即總是往更小值的方向舍入,在沒有小數位的情況下是正確的,但是如果有小數位的時候,如 -771.25 舍入為 -772, 771.25 舍入為 771。而C語言的舍入方式為向零舍入,即總是往靠近零的值舍入,如 771.25 舍入為 771, -771.25 舍入為 -771。那麼如何實現這種舍入方式呢。當被除數為負數時,我們可以通過加上一個偏置值來糾正這種不正確的舍入方式。

        我們可以觀察一下上圖的有符號除法例子,可以發現,當右移的 k 位單獨拿出來,不為 0 的時候,會導致舍入結果不正確,這是因為,k 位的值不為 0 的時候,表示該結果有小數,所以可以通過 (x + (1 << k) – 1) >> k 得到正確的結果, (1 << k) – 1 可以獲得 k 個 1,x 加上 k 個 1 可以使捨去的 k 位不為 0 時產生進位,x >> k 的結果加一,從而使舍入正確。

    關於整數的表示和運算,個人覺得有幾個需要關注的點,一是溢出問題,由於使用有限的位來表示整數,所以當数字過大的時候可能會產生溢出,溢出的位會被捨去,但是有符號數的溢出可能會使符號位被置反,如 0111 1111 …. 1111 + 1 = 1000 0000 …. 0000,0111 1111 …. 1111 為 INT_MAX , INT_MAX + 1 會得到 INT_MIN。此外,無符號數與有符號數進行比較的時候,會使有符號數強制轉換為無符號數,如果有以下循環代碼:

    for(size_t i = 10; i >= 0 ; i–);

    由於 i 為無符號數,當 i == 0 的時候,判斷還會繼續循環下去, 0 – 1  = -1 , -1 的補碼錶示為 1111 1111 …. 1111 , 剛好是無符號數的最大值,會導致死循環。因此也需要注意一切與無符號類型數據的運算,以及強制類型轉換可能出現的問題。

    3. 浮點數

        終於來到了這一章的重點內容之一(其實感覺這本書哪裡都挺重要的),這裏主要介紹浮點數是如何表示的,並且介紹浮點數舍入的問題(和上面講到的舍入不大一樣),浮點數的表示及其運算標準稱為 IEEE754 標準,初看可能會讓你覺得有些晦澀難懂,但是理解之後會覺得設計的十分巧妙。

    3.1 定點表示法

        首先讓我們先看下十進制的浮點數是如何表示的,浮點數的定義與小數點息息相關,定義在小數點左邊的数字的權是 10 的正冪,右邊的数字為 10 的負冪,如 12.34 表示 1 * 10^ 1 + 2 * 10^0 + 3 * 10 ^-1 + 4 * 10 ^ -2 = 12又34/100,同理可以得到二進制的浮點數表示,即定義在小數點左邊的数字的權是 2 的正冪,右邊的数字為 2 的負冪,如 101.11 = 1 * 2^2 + 0 * 2^1 + 1 * 2^0 + 1 * 2^-1 + 1 * 2^-2 。這種浮點數的表示方法是有缺陷的,無法精準的表示特定的数字,以 1/5 為例,可以用 十進制数字 0.2 表示,但是我們無法用二進制數字錶示它,只能近似的表示它,通過增加二進製表示的長度可以提升表示的精度。如下圖所示。

    3.2 IEEE754標準

        在前面談到的定點表示法不能有效的表示一個比較大的数字,例如 5 x 2^100 是用 101 後面跟隨 100 個零的位模式,我們希望能夠通過給定 x 和 y 的值來表示如 x * 2 ^y 的数字。IEEE754 標準使用 V = ( – 1)^S * M * 2^E 的形式來表示一個數。

    • 符號(Sign): S 決定這個數是負數(S = 1 )還是正數 (S = 0), 對於數值為 0 的符號位做特殊解釋。
    • 尾數(Significand): M 是一個二進制小數,範圍為 1 ~ 2 – e , 或者是 0 ~ 1 – e 。
    • 階碼(Exponent): E 的作用是對浮點數進行加權,這個權重是 2 的 E 次冪(E 可能為負數)。

    通過將浮點數的位劃分為三個字段,分別對這些值進行編碼:

    • 一個單獨的符號位 S 。
    • k 位的階碼字段 ,exp = e(0) e(1) e(2) … e(k-1) ,exp 用來編碼階碼 E。
    • n 位的小数字段 ,   frac = f(n-1) … f(1) f(0) ,frac 用來編碼尾數 M。

    下圖是該標準下封裝到字中的兩種最常見的格式。

    此外,根據階碼值(exp),被編碼的值可以分為下圖幾種情況(階碼值全為 0 ,階碼值全為 1 , 階碼值不全為 0 也不全為 1):

    接下來對這幾種格式進行一一介紹~:

    • 規格化浮點數 : 這是最普遍的情況,當 exp 的值不全為 0 也不全為 1 時,就屬於這種情況,這種情況下,階碼值 E = e – bias ,其中 e 為無符號數,即 exp 的值,而 bias 是一個 2^(k-1) – 1 的偏置值(單精度為 127,雙精度為 1023),而小数字段 frac 被解釋為描述小數值 f ,其中 0 <= f < 1,其二進製表示為 0.f(n-1)…f(1)f(0) 的数字,也就是二進制小數點在最高有效位的左邊的形式。尾數定義為 M = 1 + f 。 有時候這種方式也叫做 隱含 1 開頭的表示(implied leading  1),因為這種定義我們可以把 M 看成一個二進製表示為 1.f(n-1) … f(1)f(0) 的数字。既然我們總是能調整階碼 E ,使得尾數 M 在範圍 1 <= M < 2 之中(假設沒有溢出),那麼這樣可以節約一個位,因為第一位總是為 1 。
    • 非規格化浮點數 : 當 exp 的值全為 0 的時候,所表示的浮點數為非規格化類型,E = 1 – bias ,而尾數的值為 M = f 。不含開頭的 1 。非規格化有兩種用途,首先它提供了表示  0 的方法,因為規格化數使得 M >=  1,所以不能表示 0 ,另外非規格化數另一個功能則是表示那些非常接近於 0.0 的數,他們提供了一種屬性,稱為逐漸溢出,其中,可能的數值均勻分佈接近於 0.0 。
    • 特殊值 : 最後一類數值是指當階碼全為 1 的時候出現的。當小數域全為 0 時,表示為無窮大/小,當我們將兩個非常大的數相乘時,或者除以零時,無窮能夠表示溢出的結果。當小數域為非 0 時,結果為 NaN(Not a Number),一些運算的結果不能為實數或者無窮時,會返回 NaN,比如 根號 -1 ,或者 無窮減無窮。此外,在某些應用中也可以用來表示未初始化的數值。

        首先,通過一個字長為 8 位的例子,來看一下IEEE754標準實際上使用時是如何表示的 :

        上圖為展示了假定 w = 8 的字長,k = 4 的階碼位以及 n = 3 的小數位。偏移量為 2 ^ ( k -1 ) -1 = (2 ^ 3) – 1 = 7。圖中分別展示了非規格化數,規格化數以及特殊值是如何編碼的,以及如何結合在一起表示 V = (2^E) * M。我們可以看到,從最大非規格化數到最小規格化數,其值的轉變十分平滑,從 7/512 到 8/512 。這得益於非規格化數的 E 定義為 1 – bias ,最大的非規格化數的階碼值 E 與最小的規格化數的階碼值 E 是相等的,兩者唯一的區別在於 M 值,規格化數尾數 M = 1 + f ,而非規格化的尾數 M = f ,因為非規格化值是用於表示 [0, 1] 區間的小數的,當 f 達到最大值時, f 接近於 1 ,此時最大的非規格化數再進一位,小數 M 只能表示為 1 ,因為此時限制於 f 的位數,沒有比 f 大又比 1 小的小數值 ,進位後轉換成了規格化數,此時 f = 0 , 在階碼值 E 相等的情況下,讓規格化的 M = 1 + f 恰好可以使兩者進行平滑的轉換。

        假如我們使非規格化數的 E = 0 – bias = -7 ,那麼會導致最大非規格化數和最小規格化數的粒度過大,兩者的值分別為 7/1024 和 8/512 。這種定義可以彌補非規格化數的尾數沒有隱含的 1 。通過上述的例子,我們可以發現 ,假如我們把上述的例子按無符號整數表示的話,會發現它的值是有序上升的,這不是偶然的,IEEE 格式如此設計就是為了浮點數能夠使用整數排序函數進行排序。

        通過練習將整數值轉換為浮點數值形式對理解浮點數很有用,以 12345(十進制) 為例,其二進製表示為 1100 0000 1110 01 . 0  ,通過將小數點左移 13 位得到 1.1000000111001 * 2^13 ,我們丟棄開頭的 1 (這裏的 1 就是規格化數隱含的 1),構造小数字段,當 f 不足 23 位的時候,往後填充 0 ,即 M = 1 + f = 1 + 1000 0001 1100 1000 0000 000 ,當 f 大於 23 位的時候,f 多出的位會被捨棄(這裏可以看出浮點數的兩個性質,以 int 類型和 float 類型舉例,當 int 值 大於 2^24 的時候,int 轉換成 float 兩者很有可能值會不相等,因為多出的部分被捨棄了,二是 float 可以表示的數值遠遠大於 int 類型,V =  (-1 ^ S)  * M * 2^E  ,E 最高可以等於 127 ,float 的最大值為 (2^127) * (1 + f),而 int 最大值為 (2^31) -1。

    3.3 舍入

        浮點數的舍入方式有四種,分別是向上舍入,向下舍入,向零舍入,向偶數舍入。下圖是幾種舍入方式的例子 :

    偶數舍入是浮點數默認的舍入方式,可以看到,向偶數舍入時,當小數值為中間值時,會使最低有效数字總為偶數,如 2.5 和 1.5 都舍入為 2 。為什麼使用向偶數舍入呢,假設我們採用向上舍入,用這種方法舍入一組數值,會在計算這些值的平均值中引入統計偏差。我們採用這種方式舍入得到的平均值總是比這些數本身的平均值要略高一些,反之向下舍入亦然,向偶數舍入則可以使在 50% 的時間內向上舍入,50% 的時間內向下舍入。

    4. 小結

      • 計算機將信息編碼為位(bit),通常組織成字節序列,有不同的編碼方式來表示整數,實數和字符串。不同的計算機模型在編碼数字和多字節數據中的字節順序時使用不同的約定。
      • 絕大部分機器使用補碼來編碼整數。對於浮點數使用 IEEE754 標準來編碼。
      • 在進行對無符號和有符號整數進行強制類型轉換時,底層的位模式是不變的。(浮點數與整數轉換則會進行 改變,如 float f = 1.25; int x = f; 此時打印兩者的十六進制值,可以分別輸出為 f = 92463258 ,x = 1 )
      • 由於編碼的長度有限,當超出表示範圍時,有限長度會引起數值溢出,如 x * x 可能會得到負數。當浮點數非常接近於 0.0 時,轉換成 0 時也會產生下溢。
      • 使用補碼運算 ~x + 1 = -x (不適用於 INT_MIN) 。可以通過 (2^k) – 1 生成一個 k 位的掩碼。
      • 浮點數不具備結合率,因為可能發生溢出或者舍入,從而失去精度。如(le20 * le20) * le-20 = 正無窮,而 le20 * (le20 * le-20) = le20 。此外也不具備分配性,如 le20 * (le20 – le20) = 0.0 ,而 le20 * le20 – le20 * le20 = NaN。

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※帶您來了解什麼是 USB CONNECTOR  ?

    ※自行創業 缺乏曝光? 下一步"網站設計"幫您第一時間規劃公司的門面形象

    ※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!!

    ※綠能、環保無空污,成為電動車最新代名詞,目前市場使用率逐漸普及化

    ※廣告預算用在刀口上,網站設計公司幫您達到更多曝光效益

    ※教你寫出一流的銷售文案?

  • 計算機專業學生常用網站

    計算機專業學生常用網站

    這篇文章我很早之前就想寫了,但奈何一直沒有合適的時間,也不知道應該怎樣去表達。現在自己是一個大三的學生,學習了兩年多的計算機,我不知道自己算不算合格,和那些初中就搞OI,大三實習就業的大佬們相比,我肯定是不行的,但我覺得我這兩年的學習經歷應該更符合一般的計算機專業學生,可能也更有參考性吧。這裏我主要來分享一下我常用的一些網站,這些網站主要受眾還是學生,關注我的人也大都是同輩的學生,大家可以在評論區討論或補充,這篇博客也會一直更新下去。

    1、Google

    這個網站就不必說了吧,我一直有一種觀點,搜索資料對計算機專業的學生來說是一種特別重要的能力。現在的世界有那麼多的知識,誰也不可能都學會,咱們的大腦只是一個cache級別的存儲器,想要獲得知識、解決問題,學會使用搜索引擎必不可少!至於google被牆,使用百度也是可以的,但注意對信息要辨偽存真,多去比較。

    2、GitHub

    這是開發者最為重要的網站了吧,代碼託管網站。大概大一下學期才注意到這個網站,各種資源應有盡有,想要什麼輪子,上去搜就好了。最令我震驚的是,裏面還有這種網課學習資料,清華北大浙大等名校計算機專業所有課程的資料都齊全,互聯網時代真的太便利了。

     

    3、Stack Overflow

    這個網站也挺有用的,之前我查找一個C++問題,搜索的結果都答不到點上,在上面看到一個美國人的回答才如夢初醒。後來學習過程中遇到什麼 問題,上去搜一下,大概率能搜到答案。缺點也很明顯,這是一個英語網站,大多數回答都是英文,所以要有點計算機英語基礎。至於同樣英文網站的GitHub,我只能感慨,中國程序員太厲害了,中文項目一點也不少,可以說GitHub的繁榮離不開中國人。

     

    4、bilibili

    或許最初這隻是一個二次元愛好者的聚集地,但現在B站應該可以算是中國的油管吧。我在高中的時候入坑B站,申請會員需要答題就讓我知道這個網站應該有着素質不錯的成員,果然這裡有無數的沙雕網友逗你開心,逛B站也成為我高中生活最快樂的消遣方式。上了大學才發現B站也可以是一個學習網站,甚至中央都表揚過B站。跟着B站上的老師學了高數、離散數學、線性代數、数字邏輯、概率論、計算機組成原理等等,我一般是在課堂上聽一遍,課後快到考試周了跟着B站視頻複習一遍,很穩!我愛死這個小破站了!(不知道大家有沒有注意到我博客背景上的22娘33娘呢?)

    5、中國大學MOOC

     這個算是對B站的一個補充的,其實B站中很多學校視頻都是轉自這裏的,很多網課其實是侵權的,隨時可能被B站刪掉。雖然有些可能需要收費,但也還能接受,至少質量有保證。

    6、知乎

    為什麼要提知乎這個看似很無關的網站?我主要覺得這是一個可以用來增長見識的社區,雖然現在它一點點的向微博貼吧靠近。

    知乎給自己的定位是一個網絡問答社區,用戶在上面分享自己專業的知識和見解。據統計與計算機相關的用戶佔總用戶很大的比重,可能大家上班都在划水?

    也有很多大佬直接在知乎上寫博客,平時逛逛知乎把握一下行業動向,聽聽大佬吹吹牛逼,很有意思。

    7、博客園

    這個我立足的地方嘛!我在大一下學期才正式開始寫博客,最初搞ACM,師哥讓我們寫題解,最開始真是不愛寫,隨便應付一下,後來發現寫博客的樂趣,一發不可收拾。每天逛一下,大家說話有好聽,我超級喜歡這裏!

    8、CSDN

    這應該是一個邁不過去的話題吧,我也不想修什麼優越感,但是現在CSDN真的令人不悅呀!以前聽前輩講起過它的輝煌,現在也不能說是沒落了吧,依舊有龐大的用戶,龐大的流量,也算是一個成功的商業網址了。CSDN最讓我反感的一點是找一個問題,所有答案都是一樣複製粘貼過來的,很難找到原作者,問轉載者詳情問題詳情也無法解答。我不反對轉載別人的博客,畢竟要有開源精神,但轉載能不能貼一個原文鏈接?還有積分下載,講一個笑話,我一個師哥發了一份JDK1.8,5C幣下載,一年賺了300C幣,這是在收智商稅?

    9、MSDN 我告訴你

    這個網站可就厲害了,整合了許多微軟原版系統鏡像,精簡版本,純凈系統。

    10、W3school

    就算不去學前端,我們多多少少也要了解一些相關知識,這也算是一個前端只是比較全的網站了。

    11、鳩摩搜索

    能夠搜索出不少專業書,配合pandownload使用吧,這個給出pandownload的使用說明

    12、菜鳥教程

     

     有朋友提到了菜鳥教程,這裏也來介紹一下吧,個人覺得菜鳥教程提供了較為全面,系統詳細的教程,廣告少,界面簡約,聽說網站最早是一個人寫的,很牛。這個網站挺適合新手做輔助,個人覺得就是有些教程獲取不到較為詳細的說明。

    13、各大OJ

    北京大學

    杭州电子科技大學

    浙江大學

    codeforces

    PAT

    藍橋杯

     

     

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    ※為什麼 USB CONNECTOR 是電子產業重要的元件?

    網頁設計一頭霧水??該從何著手呢? 找到專業技術的網頁設計公司,幫您輕鬆架站!

    ※想要讓你的商品成為最夯、最多人討論的話題?網頁設計公司讓你強力曝光

    ※想知道最厲害的台北網頁設計公司推薦台中網頁設計公司推薦專業設計師”嚨底家”!!

    新北清潔公司,居家、辦公、裝潢細清專業服務

  • Java I/O體系從原理到應用,這一篇全說清楚了

    Java I/O體系從原理到應用,這一篇全說清楚了

    本文介紹操作系統I/O工作原理,Java I/O設計,基本使用,開源項目中實現高性能I/O常見方法和實現,徹底搞懂高性能I/O之道

    基礎概念

    在介紹I/O原理之前,先重溫幾個基礎概念:

    • (1) 操作系統與內核

    操作系統:管理計算機硬件與軟件資源的系統軟件
    內核:操作系統的核心軟件,負責管理系統的進程、內存、設備驅動程序、文件和網絡系統等等,為應用程序提供對計算機硬件的安全訪問服務

    • 2 內核空間和用戶空間

    為了避免用戶進程直接操作內核,保證內核安全,操作系統將內存尋址空間劃分為兩部分:
    內核空間(Kernel-space),供內核程序使用
    用戶空間(User-space),供用戶進程使用
    為了安全,內核空間和用戶空間是隔離的,即使用戶的程序崩潰了,內核也不受影響

    • 3 數據流

    計算機中的數據是基於隨着時間變換高低電壓信號傳輸的,這些數據信號連續不斷,有着固定的傳輸方向,類似水管中水的流動,因此抽象數據流(I/O流)的概念:指一組有順序的、有起點和終點的字節集合

    抽象出數據流的作用:實現程序邏輯與底層硬件解耦,通過引入數據流作為程序與硬件設備之間的抽象層,面向通用的數據流輸入輸出接口編程,而不是具體硬件特性,程序和底層硬件可以獨立靈活替換和擴展

    I/O 工作原理

    1 磁盤I/O

    典型I/O讀寫磁盤工作原理如下:

    tips: DMA:全稱叫直接內存存取(Direct Memory Access),是一種允許外圍設備(硬件子系統)直接訪問系統主內存的機制。基於 DMA 訪問方式,系統主內存與硬件設備的數據傳輸可以省去CPU 的全程調度

    值得注意的是:

    • 讀寫操作基於系統調用實現
    • 讀寫操作經過用戶緩衝區,內核緩衝區,應用進程並不能直接操作磁盤
    • 應用進程讀操作時需阻塞直到讀取到數據

    2 網絡I/O

    這裏先以最經典的阻塞式I/O模型介紹:

    tips:recvfrom,經socket接收數據的函數

    值得注意的是:

    • 網絡I/O讀寫操作經過用戶緩衝區,Sokcet緩衝區
    • 服務端線程在從調用recvfrom開始到它返回有數據報準備好這段時間是阻塞的,recvfrom返回成功后,線程開始處理數據報

    Java I/O設計

    1 I/O分類

    Java中對數據流進行具體化和實現,關於Java數據流一般關注以下幾個點:

    • (1) 流的方向
      從外部到程序,稱為輸入流;從程序到外部,稱為輸出流

    • (2) 流的數據單位
      程序以字節作為最小讀寫數據單元,稱為字節流,以字符作為最小讀寫數據單元,稱為字符流

    • (3) 流的功能角色

    從/向一個特定的IO設備(如磁盤,網絡)或者存儲對象(如內存數組)讀/寫數據的流,稱為節點流
    對一個已有流進行連接和封裝,通過封裝后的流來實現數據的讀/寫功能,稱為處理流(或稱為過濾流);

    2 I/O操作接口

    java.io包下有一堆I/O操作類,初學時看了容易搞不懂,其實仔細觀察其中還是有規律:
    這些I/O操作類都是在繼承4個基本抽象流的基礎上,要麼是節點流,要麼是處理流

    2.1 四個基本抽象流

    java.io包中包含了流式I/O所需要的所有類,java.io包中有四個基本抽象流,分別處理字節流和字符流:

    • InputStream
    • OutputStream
    • Reader
    • Writer

    2.2 節點流

    節點流I/O類名由節點流類型 + 抽象流類型組成,常見節點類型有:

    • File文件
    • Piped 進程內線程通信管道
    • ByteArray / CharArray (字節數組 / 字符數組)
    • StringBuffer / String (字符串緩衝區 / 字符串)

    節點流的創建通常是在構造函數傳入數據源,例如:

    FileReader reader = new FileReader(new File("file.txt"));
    FileWriter writer = new FileWriter(new File("file.txt"));

    2.3 處理流

    處理流I/O類名由對已有流封裝的功能 + 抽象流類型組成,常見功能有:

    • 緩衝:對節點流讀寫的數據提供了緩衝的功能,數據可以基於緩衝批量讀寫,提高效率。常見有BufferedInputStream、BufferedOutputStream
    • 字節流轉換為字符流:由InputStreamReader、OutputStreamWriter實現
    • 字節流與基本類型數據相互轉換:這裏基本數據類型數據如int、long、short,由DataInputStream、DataOutputStream實現
    • 字節流與對象實例相互轉換:用於實現對象序列化,由ObjectInputStream、ObjectOutputStream實現

    處理流的應用了適配器/裝飾模式,轉換/擴展已有流,處理流的創建通常是在構造函數傳入已有的節點流或處理流:

    FileOutputStream fileOutputStream = new FileOutputStream("file.txt");
    // 擴展提供緩衝寫
    BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
     // 擴展提供提供基本數據類型寫
    DataOutputStream out = new DataOutputStream(bufferedOutputStream);

    3 Java NIO

    3.1 標準I/O存在問題

    Java NIO(New I/O)是一個可以替代標準Java I/O API的IO API(從Java 1.4開始),Java NIO提供了與標準I/O不同的I/O工作方式,目的是為了解決標準 I/O存在的以下問題:

    • (1) 數據多次拷貝

    標準I/O處理,完成一次完整的數據讀寫,至少需要從底層硬件讀到內核空間,再讀到用戶文件,又從用戶空間寫入內核空間,再寫入底層硬件

    此外,底層通過write、read等函數進行I/O系統調用時,需要傳入數據所在緩衝區起始地址和長度
    由於JVM GC的存在,導致對象在堆中的位置往往會發生移動,移動後傳入系統函數的地址參數就不是真正的緩衝區地址了

    可能導致讀寫出錯,為了解決上面的問題,使用標準I/O進行系統調用時,還會額外導致一次數據拷貝:把數據從JVM的堆內拷貝到堆外的連續空間內存(堆外內存)

    所以總共經歷6次數據拷貝,執行效率較低

    • (2) 操作阻塞

    傳統的網絡I/O處理中,由於請求建立連接(connect),讀取網絡I/O數據(read),發送數據(send)等操作是線程阻塞的

    // 等待連接
    Socket socket = serverSocket.accept();
    
    // 連接已建立,讀取請求消息
    StringBuilder req = new StringBuilder();
    byte[] recvByteBuf = new byte[1024];
    int len;
    while ((len = socket.getInputStream().read(recvByteBuf)) != -1) {
        req.append(new String(recvByteBuf, 0, len, StandardCharsets.UTF_8));
    }
    
    // 寫入返回消息
    socket.getOutputStream().write(("server response msg".getBytes()));
    socket.shutdownOutput();

    以上面服務端程序為例,當請求連接已建立,讀取請求消息,服務端調用read方法時,客戶端數據可能還沒就緒(例如客戶端數據還在寫入中或者傳輸中),線程需要在read方法阻塞等待直到數據就緒

    為了實現服務端併發響應,每個連接需要獨立的線程單獨處理,當併發請求量大時為了維護連接,內存、線程切換開銷過大

    3.2 Buffer

    Java NIO核心三大核心組件是Buffer(緩衝區)、Channel(通道)、Selector

    Buffer提供了常用於I/O操作的字節緩衝區,常見的緩存區有ByteBuffer, CharBuffer, DoubleBuffer, FloatBuffer, IntBuffer, LongBuffer, ShortBuffer,分別對應基本數據類型: byte, char, double, float, int, long, short,下面介紹主要以最常用的ByteBuffer為例,Buffer底層支持Java堆內(HeapByteBuffer)或堆外內存(DirectByteBuffer)

    堆外內存是指與堆內存相對應的,把內存對象分配在JVM堆以外的內存,這些內存直接受操作系統管理(而不是虛擬機,相比堆內內存,I/O操作中使用堆外內存的優勢在於:

    • 不用被JVM GC線回收,減少GC線程資源佔有
    • 在I/O系統調用時,直接操作堆外內存,可以節省一次堆外內存和堆內內存的複製

    ByteBuffer底層堆外內存的分配和釋放基於malloc和free函數,對外allocateDirect方法可以申請分配堆外內存,並返回繼承ByteBuffer類的DirectByteBuffer對象:

    public static ByteBuffer allocateDirect(int capacity) {
        return new DirectByteBuffer(capacity);
    }

    堆外內存的回收基於DirectByteBuffer的成員變量Cleaner類,提供clean方法可以用於主動回收,Netty中大部分堆外內存通過記錄定位Cleaner的存在,主動調用clean方法來回收;
    另外,當DirectByteBuffer對象被GC時,關聯的堆外內存也會被回收

    tips: JVM參數不建議設置-XX:+DisableExplicitGC,因為部分依賴Java NIO的框架(例如Netty)在內存異常耗盡時,會主動調用System.gc(),觸發Full GC,回收DirectByteBuffer對象,作為回收堆外內存的最後保障機制,設置該參數之後會導致在該情況下堆外內存得不到清理

    堆外內存基於基礎ByteBuffer類的DirectByteBuffer類成員變量:Cleaner對象,這個Cleaner對象會在合適的時候執行unsafe.freeMemory(address),從而回收這塊堆外內存

    Buffer可以見到理解為一組基本數據類型,存儲地址連續的的數組,支持讀寫操作,對應讀模式和寫模式,通過幾個變量來保存這個數據的當前位置狀態:capacity、 position、 limit:

    • capacity 緩衝區數組的總長度
    • position 下一個要操作的數據元素的位置
    • limit 緩衝區數組中不可操作的下一個元素的位置:limit <= capacity

    3.3 Channel

    Channel(通道)的概念可以類比I/O流對象,NIO中I/O操作主要基於Channel:
    從Channel進行數據讀取 :創建一個緩衝區,然後請求Channel讀取數據
    從Channel進行數據寫入 :創建一個緩衝區,填充數據,請求Channel寫入數據

    Channel和流非常相似,主要有以下幾點區別:

    • Channel可以讀和寫,而標準I/O流是單向的
    • Channel可以異步讀寫,標準I/O流需要線程阻塞等待直到讀寫操作完成
    • Channel總是基於緩衝區Buffer讀寫

    Java NIO中最重要的幾個Channel的實現:

    • FileChannel: 用於文件的數據讀寫,基於FileChannel提供的方法能減少讀寫文件數據拷貝次數,後面會介紹
    • DatagramChannel: 用於UDP的數據讀寫
    • SocketChannel: 用於TCP的數據讀寫,代表客戶端連接
    • ServerSocketChannel: 監聽TCP連接請求,每個請求會創建會一個SocketChannel,一般用於服務端

    基於標準I/O中,我們第一步可能要像下面這樣獲取輸入流,按字節把磁盤上的數據讀取到程序中,再進行下一步操作,而在NIO編程中,需要先獲取Channel,再進行讀寫

    FileInputStream fileInputStream = new FileInputStream("test.txt");
    FileChannel channel = fileInputStream.channel();

    tips: FileChannel僅能運行在阻塞模式下,文件異步處理的 I/O 是在JDK 1.7 才被加入的 java.nio.channels.AsynchronousFileChannel

    // server socket channel:
    ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
    serverSocketChannel.bind(new InetSocketAddress(InetAddress.getLocalHost(), 9091));
    
    while (true) {
        SocketChannel socketChannel = serverSocketChannel.accept();
        ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
        int readBytes = socketChannel.read(buffer);
        if (readBytes > 0) {
            // 從寫數據到buffer翻轉為從buffer讀數據
            buffer.flip();
            byte[] bytes = new byte[buffer.remaining()];
            buffer.get(bytes);
            String body = new String(bytes, StandardCharsets.UTF_8);
            System.out.println("server 收到:" + body);
        }
    }

    3.4 Selector

    Selector(選擇器) ,它是Java NIO核心組件中的一個,用於檢查一個或多個NIO Channel(通道)的狀態是否處於可讀、可寫。實現單線程管理多個Channel,也就是可以管理多個網絡連接

    Selector核心在於基於操作系統提供的I/O復用功能,單個線程可以同時監視多個連接描述符,一旦某個連接就緒(一般是讀就緒或者寫就緒),能夠通知程序進行相應的讀寫操作,常見有select、poll、epoll等不同實現

    Java NIO Selector基本工作原理如下:

    • (1) 初始化Selector對象,服務端ServerSocketChannel對象
    • (2) 向Selector註冊ServerSocketChannel的socket-accept事件
    • (3) 線程阻塞於selector.select(),當有客戶端請求服務端,線程退出阻塞
    • (4) 基於selector獲取所有就緒事件,此時先獲取到socket-accept事件,向Selector註冊客戶端SocketChannel的數據就緒可讀事件事件
    • (5) 線程再次阻塞於selector.select(),當有客戶端連接數據就緒,可讀
    • (6) 基於ByteBuffer讀取客戶端請求數據,然後寫入響應數據,關閉channel

    示例如下,完整可運行代碼已經上傳github(https://github.com/caison/caison-blog-demo):

    Selector selector = Selector.open();
    ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
    serverSocketChannel.bind(new InetSocketAddress(9091));
    // 配置通道為非阻塞模式
    serverSocketChannel.configureBlocking(false);
    // 註冊服務端的socket-accept事件
    serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
    
    while (true) {
        // selector.select()會一直阻塞,直到有channel相關操作就緒
        selector.select();
        // SelectionKey關聯的channel都有就緒事件
        Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator();
    
        while (keyIterator.hasNext()) {
            SelectionKey key = keyIterator.next();
            // 服務端socket-accept
            if (key.isAcceptable()) {
                // 獲取客戶端連接的channel
                SocketChannel clientSocketChannel = serverSocketChannel.accept();
                // 設置為非阻塞模式
                clientSocketChannel.configureBlocking(false);
                // 註冊監聽該客戶端channel可讀事件,併為channel關聯新分配的buffer
                clientSocketChannel.register(selector, SelectionKey.OP_READ, ByteBuffer.allocateDirect(1024));
            }
    
            // channel可讀
            if (key.isReadable()) {
                SocketChannel socketChannel = (SocketChannel) key.channel();
                ByteBuffer buf = (ByteBuffer) key.attachment();
    
                int bytesRead;
                StringBuilder reqMsg = new StringBuilder();
                while ((bytesRead = socketChannel.read(buf)) > 0) {
                    // 從buf寫模式切換為讀模式
                    buf.flip();
                    int bufRemain = buf.remaining();
                    byte[] bytes = new byte[bufRemain];
                    buf.get(bytes, 0, bytesRead);
                    // 這裏當數據包大於byteBuffer長度,有可能有粘包/拆包問題
                    reqMsg.append(new String(bytes, StandardCharsets.UTF_8));
                    buf.clear();
                }
                System.out.println("服務端收到報文:" + reqMsg.toString());
                if (bytesRead == -1) {
                    byte[] bytes = "[這是服務回的報文的報文]".getBytes(StandardCharsets.UTF_8);
    
                    int length;
                    for (int offset = 0; offset < bytes.length; offset += length) {
                        length = Math.min(buf.capacity(), bytes.length - offset);
                        buf.clear();
                        buf.put(bytes, offset, length);
                        buf.flip();
                        socketChannel.write(buf);
                    }
                    socketChannel.close();
                }
            }
            // Selector不會自己從已selectedKeys中移除SelectionKey實例
            // 必須在處理完通道時自己移除 下次該channel變成就緒時,Selector會再次將其放入selectedKeys中
            keyIterator.remove();
        }
    }

    tips: Java NIO基於Selector實現高性能網絡I/O這塊使用起來比較繁瑣,使用不友好,一般業界使用基於Java NIO進行封裝優化,擴展豐富功能的Netty框架來優雅實現

    高性能I/O優化

    下面結合業界熱門開源項目介紹高性能I/O的優化

    1 零拷貝

    零拷貝(zero copy)技術,用於在數據讀寫中減少甚至完全避免不必要的CPU拷貝,減少內存帶寬的佔用,提高執行效率,零拷貝有幾種不同的實現原理,下面介紹常見開源項目中零拷貝實現

    1.1 Kafka零拷貝

    Kafka基於Linux 2.1內核提供,並在2.4 內核改進的的sendfile函數 + 硬件提供的DMA Gather Copy實現零拷貝,將文件通過socket傳送

    函數通過一次系統調用完成了文件的傳送,減少了原來read/write方式的模式切換。同時減少了數據的copy, sendfile的詳細過程如下:

    基本流程如下:

    • (1) 用戶進程發起sendfile系統調用
    • (2) 內核基於DMA Copy將文件數據從磁盤拷貝到內核緩衝區
    • (3) 內核將內核緩衝區中的文件描述信息(文件描述符,數據長度)拷貝到Socket緩衝區
    • (4) 內核基於Socket緩衝區中的文件描述信息和DMA硬件提供的Gather Copy功能將內核緩衝區數據複製到網卡
    • (5) 用戶進程sendfile系統調用完成並返回

    相比傳統的I/O方式,sendfile + DMA Gather Copy方式實現的零拷貝,數據拷貝次數從4次降為2次,系統調用從2次降為1次,用戶進程上下文切換次數從4次變成2次DMA Copy,大大提高處理效率

    Kafka底層基於java.nio包下的FileChannel的transferTo:

    public abstract long transferTo(long position, long count, WritableByteChannel target)

    transferTo將FileChannel關聯的文件發送到指定channel,當Comsumer消費數據,Kafka Server基於FileChannel將文件中的消息數據發送到SocketChannel

    1.2 RocketMQ零拷貝

    RocketMQ基於mmap + write的方式實現零拷貝:
    mmap() 可以將內核中緩衝區的地址與用戶空間的緩衝區進行映射,實現數據共享,省去了將數據從內核緩衝區拷貝到用戶緩衝區

    tmp_buf = mmap(file, len); 
    write(socket, tmp_buf, len);

    mmap + write 實現零拷貝的基本流程如下:

    • (1) 用戶進程向內核發起系統mmap調用
    • (2) 將用戶進程的內核空間的讀緩衝區與用戶空間的緩存區進行內存地址映射
    • (3) 內核基於DMA Copy將文件數據從磁盤複製到內核緩衝區
    • (4) 用戶進程mmap系統調用完成並返回
    • (5) 用戶進程向內核發起write系統調用
    • (6) 內核基於CPU Copy將數據從內核緩衝區拷貝到Socket緩衝區
    • (7) 內核基於DMA Copy將數據從Socket緩衝區拷貝到網卡
    • (8) 用戶進程write系統調用完成並返回

    RocketMQ中消息基於mmap實現存儲和加載的邏輯寫在org.apache.rocketmq.store.MappedFile中,內部實現基於nio提供的java.nio.MappedByteBuffer,基於FileChannel的map方法得到mmap的緩衝區:

    // 初始化
    this.fileChannel = new RandomAccessFile(this.file, "rw").getChannel();
    this.mappedByteBuffer = this.fileChannel.map(MapMode.READ_WRITE, 0, fileSize);

    查詢CommitLog的消息時,基於mappedByteBuffer偏移量pos,數據大小size查詢:

    public SelectMappedBufferResult selectMappedBuffer(int pos, int size) {
        int readPosition = getReadPosition();
        // ...各種安全校驗
        
        // 返回mappedByteBuffer視圖
        ByteBuffer byteBuffer = this.mappedByteBuffer.slice();
        byteBuffer.position(pos);
        ByteBuffer byteBufferNew = byteBuffer.slice();
        byteBufferNew.limit(size);
        return new SelectMappedBufferResult(this.fileFromOffset + pos, byteBufferNew, size, this);
    }

    tips: transientStorePoolEnable機制
    Java NIO mmap的部分內存並不是常駐內存,可以被置換到交換內存(虛擬內存),RocketMQ為了提高消息發送的性能,引入了內存鎖定機制,即將最近需要操作的CommitLog文件映射到內存,並提供內存鎖定功能,確保這些文件始終存在內存中,該機制的控制參數就是transientStorePoolEnable

    因此,MappedFile數據保存CommitLog刷盤有2種方式:

    • 1 開啟transientStorePoolEnable:寫入內存字節緩衝區(writeBuffer) -> 從內存字節緩衝區(writeBuffer)提交(commit)到文件通道(fileChannel) -> 文件通道(fileChannel) -> flush到磁盤
    • 2 未開啟transientStorePoolEnable:寫入映射文件字節緩衝區(mappedByteBuffer) -> 映射文件字節緩衝區(mappedByteBuffer) -> flush到磁盤

    RocketMQ 基於 mmap+write 實現零拷貝,適用於業務級消息這種小塊文件的數據持久化和傳輸
    Kafka 基於 sendfile 這種零拷貝方式,適用於系統日誌消息這種高吞吐量的大塊文件的數據持久化和傳輸

    tips: Kafka 的索引文件使用的是 mmap+write 方式,數據文件發送網絡使用的是 sendfile 方式

    1.3 Netty零拷貝

    Netty 的零拷貝分為兩種:

    • 1 基於操作系統實現的零拷貝,底層基於FileChannel的transferTo方法
    • 2 基於Java 層操作優化,對數組緩存對象(ByteBuf )進行封裝優化,通過對ByteBuf數據建立數據視圖,支持ByteBuf 對象合併,切分,當底層僅保留一份數據存儲,減少不必要拷貝

    2 多路復用

    Netty中對Java NIO功能封裝優化之後,實現I/O多路復用代碼優雅了很多:

    // 創建mainReactor
    NioEventLoopGroup boosGroup = new NioEventLoopGroup();
    // 創建工作線程組
    NioEventLoopGroup workerGroup = new NioEventLoopGroup();
    
    final ServerBootstrap serverBootstrap = new ServerBootstrap();
    serverBootstrap 
         // 組裝NioEventLoopGroup 
        .group(boosGroup, workerGroup)
         // 設置channel類型為NIO類型
        .channel(NioServerSocketChannel.class)
        // 設置連接配置參數
        .option(ChannelOption.SO_BACKLOG, 1024)
        .childOption(ChannelOption.SO_KEEPALIVE, true)
        .childOption(ChannelOption.TCP_NODELAY, true)
        // 配置入站、出站事件handler
        .childHandler(new ChannelInitializer<NioSocketChannel>() {
            @Override
            protected void initChannel(NioSocketChannel ch) {
                // 配置入站、出站事件channel
                ch.pipeline().addLast(...);
                ch.pipeline().addLast(...);
            }
        });
    
    // 綁定端口
    int port = 8080;
    serverBootstrap.bind(port).addListener(future -> {
        if (future.isSuccess()) {
            System.out.println(new Date() + ": 端口[" + port + "]綁定成功!");
        } else {
            System.err.println("端口[" + port + "]綁定失敗!");
        }
    });

    3 頁緩存(PageCache)

    頁緩存(PageCache)是操作系統對文件的緩存,用來減少對磁盤的 I/O 操作,以頁為單位的,內容就是磁盤上的物理塊,頁緩存能幫助程序對文件進行順序讀寫的速度幾乎接近於內存的讀寫速度,主要原因就是由於OS使用PageCache機制對讀寫訪問操作進行了性能優化:

    頁緩存讀取策略:當進程發起一個讀操作 (比如,進程發起一個 read() 系統調用),它首先會檢查需要的數據是否在頁緩存中:

    • 如果在,則放棄訪問磁盤,而直接從頁緩存中讀取
    • 如果不在,則內核調度塊 I/O 操作從磁盤去讀取數據,並讀入緊隨其後的少數幾個頁面(不少於一個頁面,通常是三個頁面),然後將數據放入頁緩存中

    頁緩存寫策略:當進程發起write系統調用寫數據到文件中,先寫到頁緩存,然後方法返回。此時數據還沒有真正的保存到文件中去,Linux 僅僅將頁緩存中的這一頁數據標記為“臟”,並且被加入到臟頁鏈表中

    然後,由flusher 回寫線程周期性將臟頁鏈表中的頁寫到磁盤,讓磁盤中的數據和內存中保持一致,最後清理“臟”標識。在以下三種情況下,臟頁會被寫回磁盤:

    • 空閑內存低於一個特定閾值
    • 臟頁在內存中駐留超過一個特定的閾值時
    • 當用戶進程調用 sync() 和 fsync() 系統調用時

    RocketMQ中,ConsumeQueue邏輯消費隊列存儲的數據較少,並且是順序讀取,在page cache機制的預讀取作用下,Consume Queue文件的讀性能幾乎接近讀內存,即使在有消息堆積情況下也不會影響性能,提供了2種消息刷盤策略:

    • 同步刷盤:在消息真正持久化至磁盤后RocketMQ的Broker端才會真正返回給Producer端一個成功的ACK響應
    • 異步刷盤,能充分利用操作系統的PageCache的優勢,只要消息寫入PageCache即可將成功的ACK返回給Producer端。消息刷盤採用後台異步線程提交的方式進行,降低了讀寫延遲,提高了MQ的性能和吞吐量

    Kafka實現消息高性能讀寫也利用了頁緩存,這裏不再展開

    參考

    《深入理解Linux內核 —— Daniel P.Bovet》

    更多精彩,歡迎關注公眾號 分佈式系統架構

    本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能

    ※評比前十大台北網頁設計台北網站設計公司知名案例作品心得分享

    ※智慧手機時代的來臨,RWD網頁設計已成為網頁設計推薦首選

    ※評比南投搬家公司費用收費行情懶人包大公開

    ※幫你省時又省力,新北清潔一流服務好口碑