標籤: 台中電動車

  • mysql大表在不停機的情況下增加字段該怎麼處理

    mysql大表在不停機的情況下增加字段該怎麼處理

    MySQL中給一張千萬甚至更大量級的表添加字段一直是比較頭疼的問題,遇到此情況通常該如果處理?本文通過常見的三種場景進行案例說明。

    1、 環境準備

    數據庫版本: 5.7.25-28(Percona 分支)

    服務器配置:  3台centos 7虛擬機,配置均為2CPU  2G內存

    數據庫架構: 1主2從的MHA架構(為了方便主從切換場景的演示,如開啟GTID,則兩節點即可),關於MHA搭建可參考此文 MySQL高可用之MHA集群部署

    準備測試表:  創建一張2kw記錄的表,快速創建的方法可以參考快速創建連續數

    本次對存儲過程稍作修改,多添加幾個字段,存儲過程如下:

    DELIMITER $$
    CREATE  PROCEDURE `sp_createNum`(cnt INT )
    BEGIN
        DECLARE i INT  DEFAULT 1;
        DROP TABLE  if exists  tb_add_columns;
        CREATE TABLE if not exists tb_add_columns(id int primary key,col1 int,col2 varchar(32));
        INSERT INTO tb_add_columns(id,col1,col2) SELECT i  as id ,i%7 as col1,md5(i) as col2;
        
        WHILE i < cnt DO
          BEGIN
            INSERT INTO tb_add_columns(id,col1,col2) SELECT id + i   as id ,( id + i) %7 as col1,md5( id + i) as col2  FROM tb_add_columns WHERE id <=cnt - i ;
            SET i = i*2;
          END;
        END WHILE;
    END$$
    DELIMITER ;

    調用存儲過程,完成測試表及測試數據的創建。

    mysql> call sp_createNum(20000000);

     2.  直接添加字段

    使用場景: 在系統不繁忙或者該表訪問不多的情況下,如符合ONLINE DDL的情況下,可以直接添加。

    模擬場景: 創建一個測試腳本,每10s訪問該表隨機一條記錄,然後給該表添加字段

    訪問腳本如下

    #!/bin/bash
    # gjc
    
    for i in  {1..1000000000}                    # 訪問次數1000000000,按需調整即可
    do
        id=$RANDOM                          #生成隨機數    
        mysql -uroot -p'123456' --socket=/data/mysql3306/tmp/mysql.sock  -e "select  a.*,now() from  testdb.tb_add_columns a where id = "$id     # 訪問數據
        sleep 10                            #  暫停10s
    done

    運行腳本

    sh  test.sh

     給表添加字段

    mysql> alter table  testdb.tb_add_columns add col3 int;

      此時,訪問正常。

     附ONLINE DDL的場景如下,建議DBA們必須弄清楚

    (圖片轉載於https://blog.csdn.net/finalkof1983/article/details/88355314)

     

     (圖片轉載於https://blog.csdn.net/finalkof1983/article/details/88355314)

    3.   使用工具在線添加

    雖然Online DDL添加字段時,表依舊可以讀寫,但是生產環境使用場景中對大表操作使用最多的還是使用工具pt-osc或gh-ost添加。

    本文主要介紹 pt-osc(pt-online-schema-change) 來添加字段,該命令是Percona Toolkit工具中的使用頻率最高的一種

    關於Percona Toolkit的安裝及主要使用可以參考  五分鐘學會Percona Toolkit 安裝及使用

    添加字段

    root@mha1 ~]# pt-online-schema-change --alter "ADD COLUMN  col4  int" h=localhost,P=3306,p=123456,u=root,D=testdb,t=tb_add_columns,S=/data/mysql3306/tmp/mysql.sock  --charset=utf8mb4 --execute

    主要過程如下:

    1> Cannot connect to A=utf8mb4,P=3306,S=/data/mysql3306/tmp/mysql.sock,h=192.168.28.132,p=...,u=root
    1> Cannot connect to A=utf8mb4,P=3306,S=/data/mysql3306/tmp/mysql.sock,h=192.168.28.131,p=...,u=root
    No slaves found.  See --recursion-method if host mha1 has slaves.  #  因為使用的是socket方式連接數據庫 且未配置root遠程連接賬號,所以會有此提示
    
    # A software update is available:
    Operation, tries, wait:
      analyze_table, 10, 1                                     
      copy_rows, 10, 0.25                                       
      create_triggers, 10, 1                      
      drop_triggers, 10, 1
      swap_tables, 10, 1
      update_foreign_keys, 10, 1
    Altering `testdb`.`tb_add_columns`...
    Creating new table...                                     #  創建中間表,表名為"_原表名_new"
    Created new table testdb._tb_add_columns_new OK.           
    Altering new table...                                     #  修改表,也就是在新表上添加字段,因新表無數據,因此很快加完
    Altered `testdb`.`_tb_add_columns_new` OK.                  
    2020-06-20T12:23:43 Creating triggers...                  #  創建觸發器,用於在原表拷貝到新表的過程中原表有數據的變動(新增、修改、刪除)時,也會自動同步至新表中
    2020-06-20T12:23:43 Created triggers OK.
    2020-06-20T12:23:43 Copying approximately 19920500 rows... # 拷貝數據,數據庫量是統計信息里的,不準確
    Copying `testdb`.`tb_add_columns`:  11% 03:50 remain       #  分批拷貝數據(根據表的size切分每批拷貝多少數據),拷貝過程中可以用show processlist看到對應的sql
    Copying `testdb`.`tb_add_columns`:  22% 03:22 remain
    Copying `testdb`.`tb_add_columns`:  32% 03:10 remain
    Copying `testdb`.`tb_add_columns`:  42% 02:45 remain
    Copying `testdb`.`tb_add_columns`:  51% 02:21 remain
    Copying `testdb`.`tb_add_columns`:  62% 01:48 remain
    Copying `testdb`.`tb_add_columns`:  72% 01:21 remain
    Copying `testdb`.`tb_add_columns`:  81% 00:53 remain
    Copying `testdb`.`tb_add_columns`:  91% 00:24 remain
    2020-06-20T12:28:40 Copied rows OK.                       # 拷貝數據完成
    2020-06-20T12:28:40 Analyzing new table...                # 優化新表
    2020-06-20T12:28:40 Swapping tables...                    # 交換表名,將原表改為"_原表名_old",然後把新表表名改為原表名
    2020-06-20T12:28:41 Swapped original and new tables OK.    
    2020-06-20T12:28:41 Dropping old table...                 #  刪除舊錶(也可以添加參數不刪除舊錶)
    2020-06-20T12:28:41 Dropped old table `testdb`.`_tb_add_columns_old` OK.
    2020-06-20T12:28:41 Dropping triggers...                  # 刪除觸發器
    2020-06-20T12:28:41 Dropped triggers OK.
    Successfully altered `testdb`.`tb_add_columns`.            # 完成

    修改過程中,讀寫均不受影響,大家可以寫個程序包含讀寫的

    注:  無論是直接添加字段還是用pt-osc添加字段,首先都得拿到該表的元數據鎖,然後才能添加(包括pt-osc在創建觸發器和最後交換表名時都涉及),因此,如果一張表是熱表,讀寫特別頻繁或者添加時被其他會話佔用,則無法添加。

    例如: 鎖住一條記錄

    用pt-osc添加字段,會發現一直卡在創建觸發器那一步

     此時查看對應的SQL正在等待獲取元數據鎖

    換成直接添加也一樣,例如

     當達到鎖等待后將會報錯放棄添加字段

    mysql> alter table  testdb.tb_add_columns add col5 int;
    ERROR 1205 (HY000): Lock wait timeout exceeded; try restarting transaction

    對於此情況,需等待系統不繁忙情況下添加,或者使用後續的在從庫創建再進行主從切換

    4  先在從庫修改,再進行主從切換

    使用場景: 如果遇到上例中一張表數據量大且是熱表(讀寫特別頻繁),則可以考慮先在從庫添加,再進行主從切換,切換后再將其他幾個節點上添加字段。

    先在從庫添加(本文在備選節點添加)

    mysql> alter table  testdb.tb_add_columns add col5 int;
    Query OK, 0 rows affected (1 min 1.91 sec)
    Records: 0  Duplicates: 0  Warnings: 0

    進行主從切換

    使用MHA腳本進行在線切換

    masterha_master_switch  --conf=/etc/masterha/app1.conf --master_state=alive  --orig_master_is_new_slave --new_master_host=192.168.28.131  --new_master_port=3306

    切換完成后再對其他節點添加字段

    /* 原主庫上添加192.168.28.128  */
    mysql>  alter table  testdb.tb_add_columns add col5 int;
    Query OK, 0 rows affected (1 min 8.36 sec)
    Records: 0  Duplicates: 0  Warnings: 0
    
    /* 另一個從庫上添加192.168.28.132  */
    mysql>  alter table  testdb.tb_add_columns add col5 int;
    Query OK, 0 rows affected (1 min 8.64 sec)
    Records: 0  Duplicates: 0  Warnings: 0

    這樣就完成了字段添加。

    5.  小結

    生產環境MySQL添加或修改字段主要通過如下三種方式進行,實際使用中還有很多注意事項,大家要多多總結。

    • 直接添加

    如果該表讀寫不頻繁,數據量較小(通常1G以內或百萬以內),直接添加即可(可以了解一下online ddl的知識)

    •  使用pt_osc添加

    如果表較大 但是讀寫不是太大,且想盡量不影響原表的讀寫,可以用percona tools進行添加,相當於新建一張添加了字段的新表,再降原表的數據複製到新表中,複製歷史數據期間的數據也會同步至新表,最後刪除原表,將新表重命名為原表表名,實現字段添加

    •  先在從庫添加 再進行主從切換

    如果一張表數據量大且是熱表(讀寫特別頻繁),則可以考慮先在從庫添加,再進行主從切換,切換后再將其他幾個節點上添加字段

     

     

     

     

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • Gogoro擴點台中南投屏東,全台將有360個換電站

    Gogoro擴點台中南投屏東,全台將有360個換電站

    徹底改寫電動機車市場銷售紀錄的新創公司Gogoro,在短短兩年內已突破20,000 輛的銷售數字,並建置了300 多個電池交換站,充分展現了積極搶攻市場版圖的超高效率與決心。Gogoro 13 日宣布,將在4 月底開始投入在台中海線的3 個城鎮以及屏東地區首座換電站的設置;5 月底前則將進入南投。

    Gogoro 能源服務副總經理潘璟倫表示,Gogoro 在第一季的布站目標主要著力在高雄及台南地區,共於該區新增了19 個換電站。第二季,則會強化在六都以外的建置計畫,除預計在屏東市、東港、南投市、草屯、員林等地設置首座換電站外,也會在清水,沙鹿,大甲與鹿港4 個城鎮分別設置換電站以串連、打通台中彰化的海線。Gogoro 最南端的換電站,也預期在第二季末於東港設立。這些都是依據大數據分析的結果所進行的計畫,後續,大家也可以很快地可以看到在不同的區域,看到GoStation 電池交換站。

    在六都地區,Gogoro 仍以「一公里一座換電站」為能源網路目標,從北台灣一路往南延伸,透過與加油站、捷運站、學校、便利商店、賣場等單位異業結盟,合作布點的方式,積極擴大台灣綠色生活圈。

    依照Gogoro 第二季的計畫,6 月底前,全台將會有360 個換電站。這讓Gogoro 更貼近其將在2017 年底完成西岸走廊串連,讓基隆到屏東的西部都會區得以北南縱走,暢騎無阻的承諾。

    (合作媒體:。圖片出處:Gogoro)

    本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • 圖像處理中的valid卷積與same卷積

    valid卷積

    在full卷積的卷積過程中,會遇到\(K_{flip}\)靠近I的邊界(K矩陣與I矩陣),就會有部分延申到I之外,這時候忽略邊界,只考慮I完全覆蓋\(K_{flip}\)內的值情況,這個的過程就是valid卷積。一個高為H1,寬為W1的矩陣I與高為H2,寬為W2的矩陣K,在H1大於等於H2,W1大於等於W2的情況下,valid卷積的結果就是一個(H1-H2+1)*(W-W+1)的矩陣\(C_{valid}\)

    \[C_{valid}與C_{full}的對應關係為: C_{valid} = C_{full}( Rect (W_{2}-1,H_{2}-1,W_{1}-W_{2}+1,H_{1}-H_{2}+1) ) \]

    same卷積

    無論是full卷積還是valid卷積都不會得到正好的尺寸,要麼比原尺寸大要麼比原尺寸小,這時就需要same卷積來解決這個問題。若想得到寬和高都正好的矩陣我們首先需要給\(K_{flip}\)一個錨點,將錨點放在(循環)圖像矩陣的(r,c)處,((r,c)在矩陣之內),將對應位置的元素逐個相乘,最終將所有的積進行求和作為輸出圖像矩陣在(r,c)處的輸出值。這個過程稱為same卷積。
    OpenCv函數copyMakeBorder的參數表

    參數 解釋
    src 輸入矩陣
    dst 輸出矩陣
    top 上側擴充的行數
    bottom 下側擴充的行數
    left 左側擴充的行數
    right 右側擴充的行數
    borderType 邊界擴充的類型
    value border Type= BORDER_CONSTANT事的常數

    其中borderType有多種類型,比如:BORDER_REPLICATE(邊界複製)、BORDER_CONSTANT(常數擴充)、BORDER_REFLECT(反射擴充)等。
    在使用Python進行卷積操作時用到包Scipy,其中有關的操作函數為convolve2d(in1,in2,mode=’full’,boundary=’fill’,fillvalue=0)

    參數 解釋
    in1 輸入數組
    in2 輸入數組,代表K(卷積算子)
    mode 卷積類型,也就是以上提到的三種類型:full,valid,same
    boundary 邊界填充:fill\wrap\symm
    fillvalue 當boundary=’fill’時,設置邊界填充的值,默認為0

    在這裏需要注意的是當model為same時卷積算子的錨點位置由不同尺寸而不同,假設K(卷積算子)的寬和高分別為W、H。

    W和H的值 錨點位置
    均為奇數 默認為中心點
    H為偶數、W為奇數 (H-1,(W-1)/2)
    H為奇數,W為偶數 ((H-1)/2,W-1)
    均為偶數 (H-1,W-1)

    代碼實現:

    import numpy as np
    from scipy import signal
    
    if __name__ == "__main__":
    
        I = np.array([[1,2],[3,4],np.float32])
        #I的高和寬
        H1,W1 = I.shape[:2]
        #卷積算子
        k = np.array([[-1,-2],[2,1],np.float32])
        #K的寬和高
        H2,W2 = k.shape[:2]
        #計算full卷積
        c_full = signal.convolve2d(I,k,mode='full')
        #設定錨點
        r,c = 0,0
        #根據錨點來從full卷積中截取same卷積
        c_same= c_full[H2-r-1:H1-r-1,W2-c-1:W1+W2-c-1]
    

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • SpringMVC之文件上傳

    SpringMVC之文件上傳

    一、環境搭建

    1、新建項目

    (1)在” main”目錄下新建” java”與” resources”目錄

    (2)將” java”設置為”Sources Root”

    (3)將” resources”設置為”Resources Root”

    (4)在”java”目錄下新建”StudyProject.Controller”包

    (5)在”StudyProject.Controller”包下新建”TestController”類

    (6)在”resources”目錄下新建”Spring.xml”

    (7)在”WEB-INF”目錄下新建文件夾”Pages”

    (8)在“Pages”目錄下新建”success.jsp”

    2、整體框架

    3、TestController類和success.jsp

    (1)TestController類

    原代碼

    1 package StudyProject.Controller;
    2 
    3 public class TestController {
    4 }

    編寫前端控制器及路徑

    修改后

    1 package StudyProject.Controller;
    2 
    3 import org.springframework.stereotype.Controller;
    4 import org.springframework.web.bind.annotation.RequestMapping;
    5 
    6 @Controller
    7 @RequestMapping(path="/testController")
    8 public class TestController {
    9 }

    (2)success.jsp

    原代碼

    1 <%@ page contentType="text/html;charset=UTF-8" language="java" %>
    2 <html>
    3 <head>
    4     <title>Title</title>
    5 </head>
    6 <body>
    7 
    8 </body>
    9 </html>

    添加一個跳轉成功提示

    修改后

     1 <%@ page contentType="text/html;charset=UTF-8" language="java" isELIgnored="false" %>
     2 <html>
     3 <head>
     4     <title>Title</title>
     5 </head>
     6 <body>
     7 
     8     <h3>跳轉成功</h3>
     9 
    10 </body>
    11 </html>

    4、配置文件

    (1)pom.xml

    原代碼

    1   <properties>
    2     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    3     <maven.compiler.source>1.7</maven.compiler.source>
    4     <maven.compiler.target>1.7</maven.compiler.target>
    5   </properties>

    修改版本,並且加上spring.version

    修改后

    1   <properties>
    2     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    3     <maven.compiler.source>14.0.1</maven.compiler.source>
    4     <maven.compiler.target>14.0.1</maven.compiler.target>
    5     <spring.version>5.0.2.RELEASE</spring.version>
    6   </properties>

    原代碼

    1   <dependencies>
    2     <dependency>
    3       <groupId>junit</groupId>
    4       <artifactId>junit</artifactId>
    5       <version>4.11</version>
    6       <scope>test</scope>
    7     </dependency>
    8   </dependencies>

    在<dependencies></dependency>里加入坐標依賴,原有的可以刪去

    修改后

     1   <!-- 導入坐標依賴 -->
     2   <dependencies>
     3     <dependency>
     4       <groupId>org.springframework</groupId>
     5       <artifactId>spring-context</artifactId>
     6       <version>${spring.version}</version>
     7     </dependency>
     8     <dependency>
     9       <groupId>org.springframework</groupId>
    10       <artifactId>spring-web</artifactId>
    11       <version>${spring.version}</version>
    12     </dependency>
    13     <dependency>
    14       <groupId>org.springframework</groupId>
    15       <artifactId>spring-webmvc</artifactId>
    16       <version>${spring.version}</version>
    17     </dependency>
    18     <dependency>
    19       <groupId>javax.servlet</groupId>
    20       <artifactId>servlet-api</artifactId>
    21       <version>2.5</version>
    22       <scope>provided</scope>
    23     </dependency>
    24     <dependency>
    25       <groupId>javax.servlet.jsp</groupId>
    26       <artifactId>jsp-api</artifactId>
    27       <version>2.0</version>
    28       <scope>provided</scope>
    29     </dependency>
    30   </dependencies>

    (2)web.xml

    原代碼

    1 <!DOCTYPE web-app PUBLIC
    2  "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
    3  "http://java.sun.com/dtd/web-app_2_3.dtd" >
    4 
    5 <web-app>
    6   <display-name>Archetype Created Web Application</display-name>
    7 </web-app>

    配置前段控制器與解決中文亂碼的過濾器

    修改后

     1 <!DOCTYPE web-app PUBLIC
     2  "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
     3  "http://java.sun.com/dtd/web-app_2_3.dtd" >
     4 
     5 <web-app>
     6   <display-name>Archetype Created Web Application</display-name>
     7 
     8   <!--配置解決中文亂碼的過濾器-->
     9   <filter>
    10     <filter-name>characterEncodingFilter</filter-name>
    11     <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
    12     <init-param>
    13       <param-name>encoding</param-name>
    14       <param-value>UTF-8</param-value>
    15     </init-param>
    16   </filter>
    17   <filter-mapping>
    18   <filter-name>characterEncodingFilter</filter-name>
    19   <url-pattern>/*</url-pattern>
    20   </filter-mapping>
    21 
    22   <!-- 配置前端控制器 -->
    23   <servlet>
    24     <servlet-name>dispatcherServlet</servlet-name>
    25     <!-- 創建前端控制器DispatcherServlet對象 -->
    26     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    27     <!-- 使前端控制器初始化時讀取Spring.xml文件創建Spring核心容器 -->
    28     <init-param>
    29       <param-name>contextConfigLocation</param-name>
    30       <param-value>classpath*:Spring.xml</param-value>
    31     </init-param>
    32     <!-- 設置該Servlet的優先級別為最高,使之最早創建(在應用啟動時就加載並初始化這個servlet -->
    33     <load-on-startup>1</load-on-startup>
    34   </servlet>
    35   <servlet-mapping>
    36     <servlet-name>dispatcherServlet</servlet-name>
    37     <url-pattern>/</url-pattern>
    38   </servlet-mapping>
    39 
    40 </web-app>

    (3)Spring.xml

    原代碼

    1 <?xml version="1.0" encoding="UTF-8"?>
    2 <beans xmlns="http://www.springframework.org/schema/beans"
    3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    5 
    6 </beans>

    配置spring創建容器時掃描的包、視圖解析器、開啟spring註解支持等

    修改后

     1 <?xml version="1.0" encoding="UTF-8"?>
     2 <beans xmlns="http://www.springframework.org/schema/beans"
     3        xmlns:mvc="http://www.springframework.org/schema/mvc"
     4        xmlns:context="http://www.springframework.org/schema/context"
     5        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     6        xsi:schemaLocation="
     7         http://www.springframework.org/schema/beans
     8         http://www.springframework.org/schema/beans/spring-beans.xsd
     9         http://www.springframework.org/schema/mvc
    10         http://www.springframework.org/schema/mvc/spring-mvc.xsd
    11         http://www.springframework.org/schema/context
    12         http://www.springframework.org/schema/context/spring-context.xsd">
    13 
    14     <!-- 配置spring創建容器時掃描的包 -->
    15     <context:component-scan base-package="StudyProject.Controller"></context:component-scan>
    16 
    17     <!-- 配置視圖解析器,用於解析項目跳轉到的文件的位置 -->
    18     <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
    19         <!-- 尋找包的路徑 -->
    20         <property name="prefix" value="/WEB-INF/pages/"></property>
    21         <!-- 尋找文件的後綴名 -->
    22         <property name="suffix" value=".jsp"></property>
    23     </bean>
    24 
    25     <!-- 配置spring開啟註解mvc的支持 -->
    26     <mvc:annotation-driven></mvc:annotation-driven>
    27 </beans>

    5、Tomcat服務器(本地已建SpringMVC項目,Spring_MVC項目僅做示範)

    點擊”Add Configurations”配置Tomcat服務器

    二、文件上傳

    1、傳統方式上傳文件

    (1)TestController類

    在控制器內部新增”testMethod_Traditional”方法

     1 @Controller
     2 @RequestMapping(path="/testController")
     3 public class TestController {
     4 
     5     @RequestMapping(path="/testMethod_Traditional")
     6     public String testMethod_Traditional(HttpServletRequest request) throws Exception {
     7         System.out.println("執行了testMethod_Traditional方法");
     8 
     9         //獲取文件上傳目錄
    10         String path = request.getSession().getServletContext().getRealPath("/uploads");
    11         //創建file對象
    12         File file = new File(path);
    13         //判斷路徑是否存在,若不存在,創建該路徑
    14         if (!file.exists()) {
    15             file.mkdir();
    16         }
    17 
    18         //創建磁盤文件項工廠
    19         DiskFileItemFactory factory = new DiskFileItemFactory();
    20         ServletFileUpload fileUpload = new ServletFileUpload(factory);
    21         //解析request對象
    22         List<FileItem> list = fileUpload.parseRequest(request);
    23         //遍歷
    24         for (FileItem fileItem:list) {
    25             // 判斷文件項是普通字段,還是上傳的文件
    26             if (fileItem.isFormField()) {
    27                 //普通字段
    28             } else {
    29                 //上傳文件項
    30                 //獲取上傳文件項的名稱
    31                 String filename = fileItem.getName();
    32                 String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
    33                 filename = uuid+"_"+filename;
    34                 //上傳文件
    35                 fileItem.write(new File(file,filename));
    36                 //刪除臨時文件
    37                 fileItem.delete();
    38             }
    39         }
    40 
    41         System.out.println("上傳路徑:"+path);
    42         System.out.println("上傳成功");
    43         return "success";
    44     }
    45 
    46 }

    (2)index.jsp

    添加form表單

    1     <form action="testController/testMethod_Traditional" method="post" enctype="multipart/form-data">
    2         圖片 <input type="file" name="uploadfile_Traditional"> <br>
    3         <input type="submit" value="傳統方式上傳文件">
    4     </form>

    (3)結果演示

    點擊服務器”SpringMVC”右側的運行按鈕

    選擇文件然後進行上傳

    點擊上傳按鈕后,執行成功,跳到”success.jsp”界面显示跳轉成功

    在IDEA輸出台查看文件路徑

    按照路徑查看文件是否上傳成功

    2、SpringMVC方式上傳文件

    (1)pom.xml添加文件上傳坐標依賴

    在pom.xml文件<dependencies></dependencies>內添加文件上傳坐標依賴

     1     <!-- 文件上傳 -->
     2     <dependency>
     3       <groupId>commons-fileupload</groupId>
     4       <artifactId>commons-fileupload</artifactId>
     5       <version>1.3.1</version>
     6     </dependency>
     7     <dependency>
     8       <groupId>commons-io</groupId>
     9       <artifactId>commons-io</artifactId>
    10       <version>2.4</version>
    11     </dependency>

    (2)Spring.xml配置文件解析器對象

    在Spring.xml文件<beans></beans>內配置文件解析器對象

    1     <!-- 配置文件解析器對象 -->
    2     <bean id="multipartResolver"
    3           class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
    4         <property name="defaultEncoding" value="utf-8"></property>
    5         <property name="maxUploadSize" value="10485760"></property>
    6     </bean>

    (3)TestController類

    在控制器內部新增”testMethod_SpringMVC”方法

     1 @Controller
     2 @RequestMapping(path="/testController")
     3 public class TestController {
     4 
     5     @RequestMapping(path="/testMethod_SpringMVC")
     6     public String testMethod_SpringMVC(HttpServletRequest request,MultipartFile uploadfile_SpringMVC) throws Exception {
     7         System.out.println("執行了testMethod_SpringMVC方法");
     8 
     9         //獲取文件上傳目錄
    10         String path = request.getSession().getServletContext().getRealPath("/uploads");
    11         //創建file對象
    12         File file = new File(path);
    13         //判斷路徑是否存在,若不存在,創建該路徑
    14         if (!file.exists()) {
    15             file.mkdir();
    16         }
    17 
    18         //獲取到上傳文件的名稱
    19         String filename = uploadfile_SpringMVC.getOriginalFilename();
    20         String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
    21         filename = uuid+"_"+filename;
    22         //上傳文件
    23         uploadfile_SpringMVC.transferTo(new File(file,filename));
    24 
    25         System.out.println("上傳路徑:"+path);
    26         System.out.println("上傳成功");
    27         return "success";
    28     }
    29 
    30 }

    (4)index.jsp

    添加form表單

    1     <form action="testController/testMethod_SpringMVC" method="post" enctype="multipart/form-data">
    2         圖片 <input type="file" name="uploadfile_SpringMVC"> <br>
    3         <input type="submit" value="SpringMVC上傳文件">
    4     </form>

    (5)結果演示

    點擊服務器”SpringMVC”右側的運行按鈕

    選擇文件然後進行上傳

    點擊上傳按鈕后,執行成功,跳到”success.jsp”界面显示跳轉成功

    在IDEA輸出台查看文件路徑

    按照路徑查看文件是否上傳成功

    3、跨服務器上傳文件

    (1)新建”FileuploadServer”項目(過程不再演示)

    不需要建立”java””resources”等文件夾,只需要”index.jsp”显示界面即可

    “index.jsp”代碼

    1 <html>
    2 <body>
    3 <h2>Hello! FileuploadServer</h2>
    4 </body>
    5 </html>

    (2)配置服務器

    點擊”Edit Configurations”配置Tomcat服務器

    為與”SpringMVC”服務器區分,修改”HTTP port”為”9090”,修改”JMX port”為”1090”

    (3)pom.xml添加跨服務器文件上傳坐標依賴

     1     <!-- 跨服務器文件上傳 -->
     2     <dependency>
     3       <groupId>com.sun.jersey</groupId>
     4       <artifactId>jersey-core</artifactId>
     5       <version>1.18.1</version>
     6     </dependency>
     7     <dependency>
     8       <groupId>com.sun.jersey</groupId>
     9       <artifactId>jersey-client</artifactId>
    10       <version>1.18.1</version>
    11     </dependency>

    (4)TestController類

    在控制器內部新增”testMethod_AcrossServer”方法

     1 @Controller
     2 @RequestMapping(path="/testController")
     3 public class TestController {
     4 
     5     @RequestMapping(path="/testMethod_AcrossServer")
     6     public String testMethod_AcrossServer(MultipartFile uploadfile_AcrossServer) throws Exception {
     7         System.out.println("執行了testMethod_AcrossServer方法");
     8 
     9         //定義上傳文件服務器路徑
    10         String path = "http://localhost:9090/FileuploadServer_war_exploded/uploads/";
    11 
    12         //獲取到上傳文件的名稱
    13         String filename = uploadfile_AcrossServer.getOriginalFilename();
    14         String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
    15         filename = uuid+"_"+filename;
    16 
    17         //創建客戶端對象
    18         Client client = Client.create();
    19         //連接圖片服務器
    20         WebResource webResourcer = client.resource(path+filename);
    21         //向圖片服務器上傳文件
    22         webResourcer.put(uploadfile_AcrossServer.getBytes());
    23 
    24         System.out.println("上傳路徑:"+path);
    25         System.out.println("上傳成功");
    26         return "success";
    27     }
    28 
    29 }

    (5)index.jsp

    添加form表單

    1     <form action="testController/testMethod_AcrossServer" method="post" enctype="multipart/form-data">
    2         圖片 <input type="file" name="uploadfile_AcrossServer"> <br>
    3         <input type="submit" value="跨服務器上傳文件">
    4     </form>

    (6)結果演示

    運行”FileuploadServer”服務器

    運行”SpringMVC”服務器

    在”FileuploadServer”項目的”target/FileuploadServer/”目錄下新建文件夾”uploads”

    選擇文件並進行上傳,上傳成功跳轉到”success.jsp”

    查看IDEA輸出信息

    此時路徑應為”FileuploadServer/target/FileuploadServer/uploads”,在路徑下查看文件是否上傳成功

    三、注意事項

    1、傳統方式上傳文件

    傳統方式上傳時不需要在Spring.xml內配置文件解析器對象使用該方法時需要註釋掉該對象,否則會造成運行成功但上傳文件為空。

    1     <!-- 配置文件解析器對象 -->
    2     <bean id="multipartResolver"
    3           class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
    4         <property name="defaultEncoding" value="utf-8"></property>
    5         <property name="maxUploadSize" value="10485760"></property>
    6     </bean>

    即使用傳統方式上傳文件時,應當註釋掉該段代碼

    2、跨服務器上傳文件

    (1)需要修改Tomcat服務器的web.xml配置文件的權限,增加可以寫入的權限,否則會出現405的錯誤。如我所下載的Tomcat-9.0.36的web.xml路徑為”apache-tomcat-9.0.36/conf/web.xml”

    此時IEDA輸出為

    web.xml文件修改處原內容

    應修改為

    修改后的代碼

     1     <servlet>
     2         <servlet-name>default</servlet-name>
     3         <servlet-class>org.apache.catalina.servlets.DefaultServlet</servlet-class>
     4         <init-param>
     5             <param-name>debug</param-name>
     6             <param-value>0</param-value>
     7         </init-param>
     8         <init-param>
     9             <param-name>listings</param-name>
    10             <param-value>false</param-value>
    11         </init-param>
    12         <init-param>
    13             <param-name>readonly</param-name>
    14             <param-value>false</param-value>
    15         </init-param>
    16         <load-on-startup>1</load-on-startup>
    17     </servlet>

    (2)在跨服務器上傳文件時,需要在”FileuploadServer”項目的”target/FileuploadServer/”目錄下新建文件夾”uploads”,否則會出現409的錯誤

    四、完整代碼

    1、pom.xml(SpringMVC)

      1 <?xml version="1.0" encoding="UTF-8"?>
      2 
      3 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      5   <modelVersion>4.0.0</modelVersion>
      6 
      7   <groupId>org.example</groupId>
      8   <artifactId>SpringMVC</artifactId>
      9   <version>1.0-SNAPSHOT</version>
     10   <packaging>war</packaging>
     11 
     12   <name>SpringMVC Maven Webapp</name>
     13   <!-- FIXME change it to the project's website -->
     14   <url>http://www.example.com</url>
     15 
     16   <properties>
     17     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     18     <maven.compiler.source>14.0.1</maven.compiler.source>
     19     <maven.compiler.target>14.0.1</maven.compiler.target>
     20     <spring.version>5.0.2.RELEASE</spring.version>
     21   </properties>
     22 
     23   <!-- 導入坐標依賴 -->
     24   <dependencies>
     25     <dependency>
     26       <groupId>org.springframework</groupId>
     27       <artifactId>spring-context</artifactId>
     28       <version>${spring.version}</version>
     29     </dependency>
     30     <dependency>
     31       <groupId>org.springframework</groupId>
     32       <artifactId>spring-web</artifactId>
     33       <version>${spring.version}</version>
     34     </dependency>
     35     <dependency>
     36       <groupId>org.springframework</groupId>
     37       <artifactId>spring-webmvc</artifactId>
     38       <version>${spring.version}</version>
     39     </dependency>
     40     <dependency>
     41       <groupId>javax.servlet</groupId>
     42       <artifactId>servlet-api</artifactId>
     43       <version>2.5</version>
     44       <scope>provided</scope>
     45     </dependency>
     46     <dependency>
     47       <groupId>javax.servlet.jsp</groupId>
     48       <artifactId>jsp-api</artifactId>
     49       <version>2.0</version>
     50       <scope>provided</scope>
     51     </dependency>
     52 
     53     <!-- 文件上傳(採用傳統方式上傳時需註釋掉該部分) -->
     54     <dependency>
     55       <groupId>commons-fileupload</groupId>
     56       <artifactId>commons-fileupload</artifactId>
     57       <version>1.3.1</version>
     58     </dependency>
     59     <dependency>
     60       <groupId>commons-io</groupId>
     61       <artifactId>commons-io</artifactId>
     62       <version>2.4</version>
     63     </dependency>
     64 
     65     <!-- 跨服務器文件上傳 -->
     66     <dependency>
     67       <groupId>com.sun.jersey</groupId>
     68       <artifactId>jersey-core</artifactId>
     69       <version>1.18.1</version>
     70     </dependency>
     71     <dependency>
     72       <groupId>com.sun.jersey</groupId>
     73       <artifactId>jersey-client</artifactId>
     74       <version>1.18.1</version>
     75     </dependency>
     76 
     77   </dependencies>
     78 
     79   <build>
     80     <finalName>SpringMVC</finalName>
     81     <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
     82       <plugins>
     83         <plugin>
     84           <artifactId>maven-clean-plugin</artifactId>
     85           <version>3.1.0</version>
     86         </plugin>
     87         <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging -->
     88         <plugin>
     89           <artifactId>maven-resources-plugin</artifactId>
     90           <version>3.0.2</version>
     91         </plugin>
     92         <plugin>
     93           <artifactId>maven-compiler-plugin</artifactId>
     94           <version>3.8.0</version>
     95         </plugin>
     96         <plugin>
     97           <artifactId>maven-surefire-plugin</artifactId>
     98           <version>2.22.1</version>
     99         </plugin>
    100         <plugin>
    101           <artifactId>maven-war-plugin</artifactId>
    102           <version>3.2.2</version>
    103         </plugin>
    104         <plugin>
    105           <artifactId>maven-install-plugin</artifactId>
    106           <version>2.5.2</version>
    107         </plugin>
    108         <plugin>
    109           <artifactId>maven-deploy-plugin</artifactId>
    110           <version>2.8.2</version>
    111         </plugin>
    112       </plugins>
    113     </pluginManagement>
    114   </build>
    115 </project>

    2、web.xml(SpringMVC)

     1 <!DOCTYPE web-app PUBLIC
     2  "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
     3  "http://java.sun.com/dtd/web-app_2_3.dtd" >
     4 
     5 <web-app>
     6   <display-name>Archetype Created Web Application</display-name>
     7 
     8   <!--配置解決中文亂碼的過濾器-->
     9   <filter>
    10     <filter-name>characterEncodingFilter</filter-name>
    11     <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
    12     <init-param>
    13       <param-name>encoding</param-name>
    14       <param-value>UTF-8</param-value>
    15     </init-param>
    16   </filter>
    17   <filter-mapping>
    18   <filter-name>characterEncodingFilter</filter-name>
    19   <url-pattern>/*</url-pattern>
    20   </filter-mapping>
    21 
    22   <!-- 配置前端控制器 -->
    23   <servlet>
    24     <servlet-name>dispatcherServlet</servlet-name>
    25     <!-- 創建前端控制器DispatcherServlet對象 -->
    26     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    27     <!-- 使前端控制器初始化時讀取Spring.xml文件創建Spring核心容器 -->
    28     <init-param>
    29       <param-name>contextConfigLocation</param-name>
    30       <param-value>classpath*:Spring.xml</param-value>
    31     </init-param>
    32     <!-- 設置該Servlet的優先級別為最高,使之最早創建(在應用啟動時就加載並初始化這個servlet -->
    33     <load-on-startup>1</load-on-startup>
    34   </servlet>
    35   <servlet-mapping>
    36     <servlet-name>dispatcherServlet</servlet-name>
    37     <url-pattern>/</url-pattern>
    38   </servlet-mapping>
    39 
    40 </web-app>

    3、Spring.xml(SpringMVC)

     1 <?xml version="1.0" encoding="UTF-8"?>
     2 <beans xmlns="http://www.springframework.org/schema/beans"
     3        xmlns:mvc="http://www.springframework.org/schema/mvc"
     4        xmlns:context="http://www.springframework.org/schema/context"
     5        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     6        xsi:schemaLocation="
     7         http://www.springframework.org/schema/beans
     8         http://www.springframework.org/schema/beans/spring-beans.xsd
     9         http://www.springframework.org/schema/mvc
    10         http://www.springframework.org/schema/mvc/spring-mvc.xsd
    11         http://www.springframework.org/schema/context
    12         http://www.springframework.org/schema/context/spring-context.xsd">
    13 
    14     <!-- 配置spring創建容器時掃描的包 -->
    15     <context:component-scan base-package="StudyProject.Controller"></context:component-scan>
    16 
    17     <!-- 配置視圖解析器,用於解析項目跳轉到的文件的位置 -->
    18     <bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
    19         <!-- 尋找包的路徑 -->
    20         <property name="prefix" value="/WEB-INF/pages/"></property>
    21         <!-- 尋找文件的後綴名 -->
    22         <property name="suffix" value=".jsp"></property>
    23     </bean>
    24 
    25     <!-- 配置文件解析器對象 -->
    26     <bean id="multipartResolver"
    27           class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
    28         <property name="defaultEncoding" value="utf-8"></property>
    29         <property name="maxUploadSize" value="10485760"></property>
    30     </bean>
    31     
    32     <!-- 配置spring開啟註解mvc的支持 -->
    33     <mvc:annotation-driven></mvc:annotation-driven>
    34 </beans>

    4、TestController類(SpringMVC)

      1 package StudyProject.Controller;
      2 
      3 import com.sun.jersey.api.client.Client;
      4 import com.sun.jersey.api.client.WebResource;
      5 import org.apache.commons.fileupload.FileItem;
      6 import org.apache.commons.fileupload.disk.DiskFileItemFactory;
      7 import org.apache.commons.fileupload.servlet.ServletFileUpload;
      8 import org.springframework.stereotype.Controller;
      9 import org.springframework.web.bind.annotation.RequestMapping;
     10 import org.springframework.web.multipart.MultipartFile;
     11 import javax.servlet.http.HttpServletRequest;
     12 import java.io.File;
     13 import java.util.List;
     14 import java.util.UUID;
     15 
     16 @Controller
     17 @RequestMapping(path="/testController")
     18 public class TestController {
     19 
     20     @RequestMapping(path="/testMethod_Traditional")
     21     public String testMethod_Traditional(HttpServletRequest request) throws Exception {
     22         System.out.println("執行了testMethod_Traditional方法");
     23 
     24         //獲取文件上傳目錄
     25         String path = request.getSession().getServletContext().getRealPath("/uploads");
     26         //創建file對象
     27         File file = new File(path);
     28         //判斷路徑是否存在,若不存在,創建該路徑
     29         if (!file.exists()) {
     30             file.mkdir();
     31         }
     32 
     33         //創建磁盤文件項工廠
     34         DiskFileItemFactory factory = new DiskFileItemFactory();
     35         ServletFileUpload fileUpload = new ServletFileUpload(factory);
     36         //解析request對象
     37         List<FileItem> list = fileUpload.parseRequest(request);
     38         //遍歷
     39         for (FileItem fileItem:list) {
     40             // 判斷文件項是普通字段,還是上傳的文件
     41             if (fileItem.isFormField()) {
     42                 //普通字段
     43             } else {
     44                 //上傳文件項
     45                 //獲取上傳文件項的名稱
     46                 String filename = fileItem.getName();
     47                 String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
     48                 filename = uuid+"_"+filename;
     49                 //上傳文件
     50                 fileItem.write(new File(file,filename));
     51                 //刪除臨時文件
     52                 fileItem.delete();
     53             }
     54         }
     55 
     56         System.out.println("上傳路徑:"+path);
     57         System.out.println("上傳成功");
     58         return "success";
     59     }
     60 
     61     @RequestMapping(path="/testMethod_SpringMVC")
     62     public String testMethod_SpringMVC(HttpServletRequest request,MultipartFile uploadfile_SpringMVC) throws Exception {
     63         System.out.println("執行了testMethod_SpringMVC方法");
     64 
     65         //獲取文件上傳目錄
     66         String path = request.getSession().getServletContext().getRealPath("/uploads");
     67         //創建file對象
     68         File file = new File(path);
     69         //判斷路徑是否存在,若不存在,創建該路徑
     70         if (!file.exists()) {
     71             file.mkdir();
     72         }
     73 
     74         //獲取到上傳文件的名稱
     75         String filename = uploadfile_SpringMVC.getOriginalFilename();
     76         String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
     77         filename = uuid+"_"+filename;
     78         //上傳文件
     79         uploadfile_SpringMVC.transferTo(new File(file,filename));
     80 
     81         System.out.println("上傳路徑:"+path);
     82         System.out.println("上傳成功");
     83         return "success";
     84     }
     85 
     86     @RequestMapping(path="/testMethod_AcrossServer")
     87     public String testMethod_AcrossServer(MultipartFile uploadfile_AcrossServer) throws Exception {
     88         System.out.println("執行了testMethod_AcrossServer方法");
     89 
     90         //定義上傳文件服務器路徑
     91         String path = "http://localhost:9090/FileuploadServer_war_exploded/uploads/";
     92 
     93         //獲取到上傳文件的名稱
     94         String filename = uploadfile_AcrossServer.getOriginalFilename();
     95         String uuid = UUID.randomUUID().toString().replaceAll("-","").toUpperCase();
     96         filename = uuid+"_"+filename;
     97 
     98         //創建客戶端對象
     99         Client client = Client.create();
    100         //連接圖片服務器
    101         WebResource webResourcer = client.resource(path+filename);
    102         //向圖片服務器上傳文件
    103         webResourcer.put(uploadfile_AcrossServer.getBytes());
    104 
    105         System.out.println("上傳路徑:"+path);
    106         System.out.println("上傳成功");
    107         return "success";
    108     }
    109 
    110 }

    5、index.jsp(SpringMVC)

     1 <%@ page contentType="text/html;charset=UTF-8" language="java" %>
     2 <html>
     3 <head>
     4     <title>Title</title>
     5 </head>
     6 <body>
     7 
     8     <form action="testController/testMethod_Traditional" method="post" enctype="multipart/form-data">
     9         圖片 <input type="file" name="uploadfile_Traditional"> <br>
    10         <input type="submit" value="傳統方式上傳文件">
    11     </form>
    12 
    13     <br><br><br>
    14 
    15     <form action="testController/testMethod_SpringMVC" method="post" enctype="multipart/form-data">
    16         圖片 <input type="file" name="uploadfile_SpringMVC"> <br>
    17         <input type="submit" value="SpringMVC上傳文件">
    18     </form>
    19 
    20     <br><br><br>
    21 
    22     <form action="testController/testMethod_AcrossServer" method="post" enctype="multipart/form-data">
    23         圖片 <input type="file" name="uploadfile_AcrossServer"> <br>
    24         <input type="submit" value="跨服務器上傳文件">
    25     </form>
    26 
    27 </body>
    28 </html>

    6、success.jsp(SpringMVC)

     1 <%@ page contentType="text/html;charset=UTF-8" language="java" isELIgnored="false" %>
     2 <html>
     3 <head>
     4     <title>Title</title>
     5 </head>
     6 <body>
     7 
     8     <h3>跳轉成功</h3>
     9 
    10 </body>
    11 </html>

    7、index.jsp(FileuploadServer)

    1 <html>
    2 <body>
    3 <h2>Hello! FileuploadServer</h2>
    4 </body>
    5 </html>

    學習資料來源:黑馬程序員

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • 印度抗霾害,2030年全面改賣電動車

    印度抗霾害,2030年全面改賣電動車

    在川普總統發出豪語,宣布美國將退出「巴黎氣候協議」的同時,印度能源部門卻宣布,為了對抗日益嚴重的空氣污染,預計在2030 年後印度將只賣電動車。

    CNNMoney 報導,做為開發中國家之一,印度的經濟以驚人速度成長中,但在產業與交通持續發展的情況下,嚴重的空氣污染也隨之而來,根據研究估計,空污每年約造成印度120 萬人因喪命,甚至有醫師如此形容,「在首都新德里呼吸,就像是每天抽10 根菸」。

    不僅是空氣污染,蓬勃發展的經濟也讓印度成為全球第三大石油進口國,每年在石油上花費將近1,500 億美元,電動車發展將能使石油需求大幅下降,因此印度政府宣布,在2030 年後,在印度銷售的每輛汽車都必須仰賴電力,而非石油。

    為了達到目標,印度開始推行「全國電動車計畫」(National Electric Mobility Mission Plan),希望至2020 年時,電動車和混合動力車的年銷量能達到600-700 萬輛,能源部長Piyush Goyal 表示,在電動車市場起步階段,政府會透過經費補助來協助成長,但在那之後,車商就得仰賴市場需求去推動產能上升。

    對於電動車大廠特斯拉(Tesla)來說,這當然是非常好的消息,儘管特斯拉還並未進入印度市場,但馬斯克(Elon Musk)也隨即在新聞出現後發布了一條推特,稱讚印度政府對於太陽能、電動車等環保能源產業的支持。

    在馬斯克發文後,印度當地最大的電動車商馬璽達(Mahindra)執行長也在推特表示,歡迎特斯拉這個強力的競爭對手盡快加入,「馬斯克你該來了,你不會希望把整個市場都拱手讓給馬璽達吧?人多才熱鬧,也會更加環保。」

    為了改善空污情況,印度政府一直有在嘗試相關措施,在2016 年1 月時,新德里政府就宣布,男子開車必須「做一休一」,允許開車的日數以車牌尾數的奇偶來決定,單身婦女則每日都允許被開車。

    這項規定對減少空污取得了很大成功,但一但市場轉向純電動車,對於環境將會造成更正面的影響,根據世界經濟論壇報導指出,在採取這項計畫後,至2030 年前,印度將有望將碳排放量減少37%。

    (本文由《報》授權提供。照片來源: shared by CC 2.0)

     

    本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • 上海兩萬張純電動車牌照已開始免費發放

    上海已開始免費發放兩萬張牌照,這是繼廣州之後,又一地方性新能源汽車扶持政策出臺。

    據瞭解,今年8月起廣州開始實行車牌拍賣,但針對新能源車開闢“綠色通道”,可直接申請增量配置指標,不受汽車限牌政策影響。然而,在近期出臺的新能源購車細則中,上海市可謂是最積極的,此次補貼力度非常可觀:上海市本身補貼每輛4萬元,加上中央政府對地方私人購買新能源汽車補貼每輛最高6萬元,以及一塊價值約6萬元的免費汽車“滬”牌,合計相當於一次性補貼16萬元。

    近期全國很多城市都會出臺政策支援新能源汽車,側重點也各不相同。上海補貼力度相對較大,這對新能源汽車及電池類相關企業等上市公司都是利好。據不完全統計,今明兩年預計有40款新能源車密集上市,即將推出新能源車的自主品牌廠家包括上海汽車、比亞迪、吉利、長城等。

    本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • 挖洞入門_union型SQL注入

    挖洞入門_union型SQL注入

    簡介:在漏洞盒子挖洞已經有一段時間了,雖說還不是大佬,但技術也有所進步,安全行業就是這樣,只有自己動手去做,才能將理論的知識變為個人的經驗。本篇文章打算分享一下我在挖union型SQL注入漏洞過程中的一些個人理解,如有不足也請大佬不吝指教。

    0x00:什麼是SQL注入

    SQL注入,相信大多數人一開始接觸安全,聽說的第一種漏洞類型就會是SQL注入,眾所周知,其本質就是將用戶輸入的數據當成了SQL語句來執行

    開發過網站的朋友應該都清楚,大多數的小型企業或個人的站點大都採用了LAMP結構,即Linux + Apache + MySQL + PHP,當然還有一些其它常見的技術如下錶:

    操作系統 Web服務器 數據庫 編程語言
    Linux Apache MySQL PHP
    Windows Server Nginx Oracle JSP
    Tomcat SQL Server ASP
    Python

    總的來說,絕大多數網站都採用了動態Web開發技術,而動態Web開發離不開數據庫,如果沒有處理好這兩者之間的關係,那麼SQL注入就會隨之而來了。

    舉例來說,當我們想要通過參數id來獲取相對應的新聞時,整個過程簡單來說就是用戶通過URL請求新聞–>後台通過用戶請求去數據庫查詢相對應的新聞–>將查詢到的新聞回傳給用戶。在第二步查詢相對應的新聞時,後台會執行SQL語句來查詢,就像SELECT * FROM news WHERE id=''id的值是用戶來控制的,當id=1時,就會返回id=1的新聞,id=2時返回id=2的新聞,以此類推,就可以動態的控制web界面了。

    這時,當用戶輸入的id值不正確時,後台就無法獲取相對應的新聞,前端就會沒有數據显示,可當用戶輸入的數據為1'; DROP TABLE news-- a時,恐怖的事情就發生了,數據庫中的news表被刪除了,這就說明這個參數存在SQL注入

    回到剛才用戶輸入的數據,拼接到後台查詢數據時,整個SQL語句就變成了SELECT * FROM news WHERE id='1'; DROP TABLE news-- a',分析這條語句可知,用戶輸入的單引號閉合了id的值分號閉合了SELECT語句,然後又新建了一條DROP語句刪除了表news,最後的— a註釋掉了id值后的那個單引號,SQL注入就這麼產生了。

    當一個站點存在SQL注入時用戶的輸入就可以傳入數據庫執行,理論上這樣可以獲得數據庫的全部數據,也就是常說的脫庫了。獲得數據的方法也多種多樣,可以通過頁面直接返回想要查詢的數據,也可以通過sleep延時函數猜測數據,都不行的話我們還可以使用DNS解析日誌來獲得數據。其中,最簡單的一種方法就是union型的SQL注入了。

    union型SQL注入只是SQL注入的其中一種,也是最簡單的一種,對於這種漏洞的防範也特別簡單,可這種漏洞在互聯網中仍不計其數…這也可見全國乃至全球對於網絡安全知識普及的不足,接下來,我會從三個方面來講講這種漏洞,分別是為什麼會產生怎麼利用以及怎麼防範

    0x01:為什麼會產生union型SQL注入

    union型SQL注入,看名字就能知道,使用這種方法可以直接在頁面中返回我們要查詢的數據,方法也很簡單,即使用UNION聯合查詢即可。

    但使用UNION聯合查詢時還要滿足一個條件,那就是我們構造的SELECT語句的字段數要和當前表的字段數相同才能聯合查詢,即首先我們要確定當前表的字段數。order by x是數據庫中的一個排序語句,order by 1即通過第一個字段進行排序。這時我們就可以構造SELECT * FROM news WHERE id='1' order by x-- a'來猜測當前表的字段數,x值遞增,當頁面返回數據異常時,即無當前字段時,用當前的x值減一即可得到當前表的字段數了。

    知道了當前表的字段數,就可以進行UNION聯合查詢了。但聯合查詢時,頁面只會显示查詢到數據的第一條,也就是UNION前的SELECT語句的結果,想要显示我們自己聯合查詢的結果時,還必須使前一條語句失效,這裏我們構造and 1=2使前一句SELECT語句失效。回到剛才的案例,假設當前表的字段數為3,我們就可以構造SELECT * FROM news WHERE id='1' and 1=2 UNION SELECT 1,2,3-- a'來查詢當前頁面的顯錯點了,通過下圖的案例可知,當前的顯錯點為第一字段第三字段

    這個顯錯點又是什麼意思呢?比如當前表中共有三個字段,一個是標題(title)、一個是時間(time)、一個是內容(data),而我們前端不需要显示時間,只需要展示標題和內容即可。那麼從數據庫獲得的數據中,也只有標題字段和內容字段會展示在頁面上,這兩個點就是顯錯點

    通過這裏的顯錯點,用戶就可以獲得數據庫中的所有數據了。當用戶輸入的數據為1' and 1=2 UNION SELECT 1,2,database()-- a時,即SQL語句為SELECT * FROM news WHERE id='1' and 1=2 UNION SELECT 1,2,database()-- a'時,就可以直接得到數據庫的庫名

    0x02:怎麼利用union型SQL注入

    1.判斷是否存在注入

    構造and 1=1/and 1=2查看頁面是否有異常,若有異常,即有可能存在注入,另外還可通過該語句判斷該站點是否有WAF,若有WAF的話會有攔截警告,當然,WAF也是可以繞過的。。。

    2.查詢當前表的字段數

    構造order by x,當頁面返回異常時,利用x減一即可得到當前表的字段數

    3.查詢顯錯點

    構造and 1=2 union select 1,2,3,若頁面显示了我們構造的1,2,3,則對應的字段即為顯錯點

    4.查詢數據庫庫名

    構造and 1=2 union select 1,2,database(),即可在顯錯點显示當前數據庫庫名

    一般挖漏洞的話到此步驟就可以提交了,切記千萬不可非法獲得數據,挖洞有風險,同志需謹慎!

    5.查詢數據庫中的表名

    構造and 1=2 union select 1,2,table_name from information_schema.tables where table_schema=database() limit 0,1,即可在顯錯點显示當前庫中的表名,因為顯錯點一次只能显示一條數據,這時可以通過limit語句選擇不同的表名進行查看。

    6.查詢選擇表中的字段名

    構造and 1=2 union select 1,2,column_name from information_schema.columns where table_schema=database() and table_name='XXX' limit 0,1,即可在顯錯點显示字段名,這裏也是通過limit語句選擇不同的字段名進行查看。

    7.查詢數據庫中的數據

    構造and 1=2 union select 1,2,XXX from XXX limit 0,1,即可獲得數據庫中的數據了。

    0x03:怎麼防範union型SQL注入

    針對union型SQL注入,我們可以對用戶輸入的數據進行一次篩查,設置黑名單,攔截注入常用的一些關鍵詞,比如andorder byunionselectfrom等。

    除了設置黑名單外,還有一種比較靠譜的方法,即使用預編譯語句,而不是動態的生成SQL語句,這樣可以有效的避免用戶輸入的數據連接到數據庫執行,就是實現起來比較複雜,需要設置大量的預編譯語句。

    另外還有一種目前最靠譜的方法,實現起來還簡單,就是上硬件防火牆。。。就是有點小貴。

    0x04:互聯網中的一些案例

    依據網絡安全法,本文旨在分享個人學習經驗,內容禁止用於違法犯罪行為!

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • 貝斯女王島走出油污陰霾 褐鵜鶘庇護區揭牌

    摘錄自2020年3月3日公視報導

    美國路易斯安那州的貝斯女王島,是褐鵜鶘主要的棲地,過去因為遭到漏油事件重創,環境危害嚴重。不過在肇事的英國石油公司賠償下,將擴建庇護區。

    路易斯安那州官員為重建的水鳥庇護區揭牌同時表示,過去人類對牠們棲地所造成的傷害長達10年,現在要還給牠們更乾淨、更安全的家。各界也希望今年夏天,貝斯女王島能跟往年一樣有約6500隻褐鵜鶘,以及約3000隻較小的水鳥遷徙到這裡築巢。

    2010年墨西哥灣漏油事件,造成11人死亡,87天內超過1億加侖的原油洩漏。當時貝斯女王島72公里海岸線布滿油汙,褐鵜鶘全身浸泡在黑色汙泥的景象極為駭人,島上許多植物被遭毀,造成的生態浩劫引發全球擔憂。肇事的英國石油公司賠償200億美元,其中部分金額用來擴建養護1700公頃的海岸跟小島,今年還將投入8億美元持續重建工程。

    本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • Typescript的interface、class和abstract class

    interface,class,和abstract class這3個概念,既有聯繫,又有區別,本文嘗試着結合官方文檔來闡述這三者之間的關係。

    1. Declaration Merging

    Declaration Type Namespace Type Value
    Namespace X X
    Class X X
    Enum X X
    Interface X
    Type Alias X
    Function X
    Variable X

    首先我們來講一下上面這張表格,當我們第一列的關鍵字進行聲明時,我們在做什麼。

    namespace job {
       haircut(): void;
    }
    
    class Man{
    	name: string;
    }
    let imgss = new Man();
    
    enum Color {red, blue, yellow}
    
    interface dogfood {
    
      brand: string;
      price: number
    }
    type event = 'mouse' | 'keyboard';
    
    function foo(){}
    
    let a = 2;
    var b = {};
    const c = null;
    	
    

    namespace用來聲明一個命名空間,比較著名的命名空間有lodash,裏面有一堆工具函數,統統放在一個叫_的namespace裏面,同時你也可以let $ = _;所以namespace也聲明了一個值。

    class聲明了一個值,也聲明了一種類型,你可以把Man賦值給一個變量,所以class是一種值,也可以說imgss是一個Man(類型),此時Man承擔了一種類型的角色。

    enum聲明了一個值,也聲明了一種類型。我們說red是一種Color,Color在這裏承擔類型的角色,也可以把Color賦值給一個變量

    interface聲明了一種類型,但是你不能把dogfood賦值給某個變量,否則你會得到一個報錯“dogfood’ only refers to a type, but is being used as a value here`

    其他function,let,var,const都在聲明一個值,你 不能說xxx是一個a,或者xxx是一個foo,不能把值當成類型使用。

    2. interface和class

    我們知道,不算symbol,js中有6種基本類型,number,string,boolean,null, undefined, object。但是只依靠這幾種類型,來描述某個函數需要傳什麼樣的參數,是遠遠不夠的,這也是interface的使命–描述一個值(value)的形狀(type)。

    現在我們來看class,class首先也具有interface的能力,描述一個形狀,或者說代表一種類型。此外class還提供了實現,也就是說可以被實例化;

    所以class可以implements interface:

    interface ManLike {
      speak(): void;
      leg: number;
      hand: number;
    }
    class Human implements ManLike {
      leg: number = 2;
      hand: number = 2;
      speak() {
        console.log('i can speak');
      }
    }
    

    而interface可以extends class,此時的class承擔類型的角色

    interface Chinese extends Human {
      country: string;
    }
    

    那麼interface能不能extends enum或者type alias呢,這兩個兄弟也聲明了type啊,答案是不行的,官方報錯的信息:

    An interface can only extend an object type or intersection of object types with statically known members.
    

    3. class和abstract class

    class和abstract class的區別主要是abstract class不能被實例化:

    abstract Human {
    	name: string;
        abstract lang(): void;
    	toString() {
        	return `<human:${this.name}>`
        }
    }
    new Human // Cannot create an instance of an abstract class.
    

    4. interface和abstract class

    兩者都不能被實例化,但是abstract class 也可以被賦值給變量。
    interface 裏面不能有方法的實現,abstract class 可以提供部分的方法實現,這些方法可以被子類調用。

    參考: https://www.typescriptlang.org/docs/handbook/declaration-merging.html

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案

  • EM(最大期望)算法推導、GMM的應用與代碼實現

    EM(最大期望)算法推導、GMM的應用與代碼實現

      EM算法是一種迭代算法,用於含有隱變量的概率模型參數的極大似然估計。

    使用EM算法的原因

      首先舉李航老師《統計學習方法》中的例子來說明為什麼要用EM算法估計含有隱變量的概率模型參數。

      假設有三枚硬幣,分別記作A, B, C。這些硬幣正面出現的概率分別是$\pi,p,q$。進行如下擲硬幣試驗:先擲硬幣A,根據其結果選出硬幣B或C,正面選硬幣B,反面邊硬幣C;然後擲選出的硬幣,擲硬幣的結果出現正面記作1,反面記作0;獨立地重複$n$次試驗,觀測結果為$\{y_1,y_2,…,y_n\}$。問三硬幣出現正面的概率。

      三硬幣模型(也就是第二枚硬幣正反面的概率)可以寫作

    $ \begin{aligned} &P(y|\pi,p,q) \\ =&\sum\limits_z P(y,z|\pi,p,q)\\ =&\sum\limits_z P(y|z,\pi,p,q)P(z|\pi,p,q)\\ =&\pi p^y(1-p)^{1-y}+(1-\pi)q^y(1-q)^{1-y} \end{aligned} $

      其中$z$表示硬幣A的結果,也就是前面說的隱變量。通常我們直接使用極大似然估計,即最大化似然函數

    $ \begin{aligned} &\max\limits_{\pi,p,q}\prod\limits_{i=1}^n P(y_i|\pi,p,q) \\ =&\max\limits_{\pi,p,q}\prod\limits_{i=1}^n[\pi p^{y_i}(1-p)^{1-y_i}+(1-\pi)q^{y_i}(1-q)^{1-y_i}]\\ =&\max\limits_{\pi,p,q}\sum\limits_{i=1}^n\log[\pi p^{y_i}(1-p)^{1-y_i}+(1-\pi)q^{y_i}(1-q)^{1-y_i}]\\ =&\max\limits_{\pi,p,q}L(\pi,p,q) \end{aligned} $

      分別對$\pi,p,q$求偏導並等於0,求解線性方程組來估計這三個參數。但是,由於它是帶有隱變量的,在獲取最終的隨機變量之前有一個分支選擇的過程,導致這個$\log$的內部是加和的形式,計算導數十分困難,而待求解的方程組不是線性方程組。當複雜度一高,解這種方程組幾乎成為不可能的事。以下推導EM算法,它以迭代的方式來求解這些參數,應該也算一種貪心吧。

    算法導出與理解

      對於參數為$\theta$且含有隱變量$Z$的概率模型,進行$n$次抽樣。假設隨機變量$Y$的觀察值為$\mathcal{Y} = \{y_1,y_2,…,y_n\}$,隱變量$Z$的$m$個可能的取值為$\mathcal{Z}=\{z_1,z_2,…,z_m\}$。

      寫出似然函數:

    $ \begin{aligned} L(\theta) &= \sum\limits_{Y\in\mathcal{Y}}\log P(Y|\theta)\\ &=\sum\limits_{Y\in\mathcal{Y}}\log \sum\limits_{Z\in \mathcal{Z}} P(Y,Z|\theta)\\ \end{aligned} $

      EM算法首先初始化參數$\theta = \theta^0$,然後每一步迭代都會使似然函數增大,即$L(\theta^{k+1})\ge L(\theta^k)$。如何做到不斷變大呢?考慮迭代前的似然函數(為了方便不用$\theta^{k+1}$):

    $ \begin{gather} \begin{aligned} L(\theta)=&\sum\limits_{Y\in \mathcal{Y}} \log\sum\limits_{Z\in \mathcal{Z}} P(Y,Z|\theta)\\ =&\sum\limits_{Y\in \mathcal{Y}} \log\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\frac{P(Y,Z|\theta)}{P(Z|Y,\theta^k)}\\ \end{aligned} \label{} \end{gather} $

      至於上式的第二個等式為什麼取出$P(Z|Y,\theta^k)$而不是別的,正向的原因我想不出來,馬後炮原因在後面記錄。

      考慮其中的求和

    $ \sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)=1$

      且由於$\log$函數是凹函數,因此由Jenson不等式得

    $ \begin{gather} \begin{aligned} L(\theta) \ge&\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log\frac{P(Y,Z|\theta)}{P(Z|Y,\theta^k)}\\ =&B(\theta,\theta^k) \end{aligned}\label{} \end{gather} $

      當$\theta = \theta^k$時,有

    $ \begin{gather} \begin{aligned} L(\theta^k) \ge& B(\theta^k,\theta^k)\\ =&\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log\frac{P(Y,Z|\theta^k)}{P(Z|Y,\theta^k)}\\ =&\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log P(Y|\theta^k)\\ =&\sum\limits_{Y\in \mathcal{Y}}\log P(Y|\theta^k)\\ =&L(\theta^k)\\ \end{aligned} \label{} \end{gather} $

      也就是在這時,$(2)$式取等,即$L(\theta^k) = B(\theta^k,\theta^k)$。取

    $ \begin{gather} \theta^*=\text{arg}\max\limits_{\theta}B(\theta,\theta^k)\label{} \end{gather} $

      可得不等式

    $L(\theta^*)\ge B(\theta^*,\theta^k)\ge B(\theta^k,\theta^k) = L(\theta^k)$

      所以,我們只要優化$(4)$式,讓$\theta^{k+1} = \theta^*$,即可保證每次迭代的非遞減勢頭,有$L(\theta^{k+1})\ge L(\theta^k)$。而由於似然函數是概率乘積的對數,一定有$L(\theta) < 0$,所以迭代有上界並且會收斂。以下是《統計學習方法》中EM算法一次迭代的示意圖:

      進一步簡化$(4)$式,去掉優化無關項:

    $ \begin{aligned} \theta^*=&\text{arg}\max\limits_{\theta}B(\theta,\theta^k) \\ =&\text{arg}\max\limits_{\theta}\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log\frac{P(Y,Z|\theta)}{P(Z|Y,\theta^k)} \\ =&\text{arg}\max\limits_{\theta}\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log P(Y,Z|\theta) \\ =&\text{arg}\max\limits_{\theta}Q(\theta,\theta^k) \\ \end{aligned} $

      $Q$函數使用導數求極值的方程與沒有隱變量的方程類似,容易求解。

      綜上,EM算法的流程為:

      1. 設置$\theta^0$的初值。EM算法對初值是敏感的,不同初值迭代出來的結果可能不同。

      2. 更新$\theta^k = \text{arg}\max\limits_{\theta}Q(\theta,\theta^{k-1})$。理解上來說,通常將這一步分為計算$Q$與極大化$Q$兩步,即求期望E與求極大M,但在代碼中並不會將它們分出來,因此這裏濃縮為一步。另外,如果這個優化很難計算的話,因為有不等式的保證,直接取$\theta^k$為某個$\hat{\theta}$,只要有$Q(\hat{\theta},\theta^{k-1})\ge Q(\theta^{k-1},\theta^{k-1})$即可。

      3. 比較$\theta^k$與$\theta^{k-1}$的差異,比如求它們的差的二范數,若小於一定閾值就結束迭代,否則重複步驟2。

      下面記錄一下我對$(1)$式取出$P(Z|Y,\theta^k)$而不取別的$P$的理解:

      經過以上的推導,我認為這是為了給不等式取等創造條件。如果不能確定$L(\theta^k)$與$Q(\theta^k,\theta^k)$能否取等,那麼取$Q$的最大值$Q(\theta^*,\theta^k)$時,儘管有$Q(\theta^*,\theta^k)\ge Q(\theta^k,\theta^k)$,但並不能保證$L(\theta^*)\ge L(\theta^k)$,迭代的不減性質就就沒了。

      我這裏暫且把它看做一種巧合,是研究EM算法的大佬,碰巧想用Jenson不等式來迭代而構造出來的一種做法。本人段位還太弱,無法正向理解其中的緣故,只能以這種方式來揣度大佬的思路了。知乎大佬發的EM算法九層理解(點擊鏈接),我當前只能到第3層,有時間一定要拜讀一下深度學習之父的著作。

    高斯混合模型的應用

    迭代式推導

      假設高斯混合模型混合了$m$個高斯分佈,參數為$\theta = (\alpha_1,\theta_1,\alpha_2,\theta_2,…,\alpha_m,\theta_m),\theta_i=(\mu_i,\sigma_i)$則整個概率分佈為:

    $\displaystyle P(y|\theta) = \sum\limits_{i=1}^m\alpha_i \phi(y|\theta_i) =  \sum\limits_{i=1}^m\frac{\alpha_i }{\sqrt{2\pi}\sigma_i}\exp\left(-\frac{(y-\mu_i)^2}{2\sigma_i^2}\right),\;\text{where}\;\sum\limits_{j=1}^m\alpha_j = 1$

      對混合分佈抽樣$n$次得到$\{y_1,…,y_n\}$,則在第$k+1$次迭代,待優化式為:

    $\begin{gather}\begin{aligned} &\max\limits_{\theta}Q(\theta,\theta^k) \\ =&\max\limits_{\theta}\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta^k)\log P(Y,Z|\theta) \\ =&\max\limits_{\theta}\sum\limits_{Y\in \mathcal{Y}}\sum\limits_{Z\in \mathcal{Z}} \frac{P(Z,Y|\theta^k)}{P(Y|\theta^k)}\log P(Y,Z|\theta) \\ =&\max\limits_{\theta}\sum\limits_{i=1}^n\sum\limits_{j=1}^m \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)} \log \left[\alpha_j\phi(y_i|\theta_j)\right] \\ =&\max\limits_{\theta}\sum\limits_{i=1}^n\sum\limits_{j=1}^m \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)} \log \left[ \frac{\alpha_j}{\sqrt{2\pi}\sigma_j}\exp\left(-\frac{(y_i-\mu_j)^2}{2\sigma_j^2}\right) \right]\\ =&\max\limits_{\theta}\sum\limits_{j=1}^m \sum\limits_{i=1}^n \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)} \left[ \log \alpha_j – \log \sigma_j-\frac{(y_i-\mu_j)^2}{2\sigma_j^2} \right]\\  \end{aligned} \label{}\end{gather}$

    計算α

      定義

    $\displaystyle n_j = \sum\limits_{i=1}^n \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)}$

      則對於$\alpha$,優化式為

    $\begin{gather} \begin{aligned} \max\limits_{\alpha}\sum\limits_{j=1}^m n_j \log \alpha_j \end{aligned} \label{}\end{gather}$

      又因為$\sum\limits_{j=1}^m \alpha_j=1$,所以只需優化$m-1$個參數,上式變為:

    $ \max\limits_\alpha \left[ \begin{matrix} n_1&n_2&\cdots &n_{m-1}&n_{m}\\ \end{matrix} \right] \cdot \left[ \begin{matrix} \log\alpha_1\\ \log\alpha_2\\ \vdots\\ \log\alpha_{m-1}\\ \log(1-\alpha_1-\cdots-\alpha_{m-1})\\ \end{matrix} \right] $

      對每個$\alpha_j$求導並等於0,得到線性方程組:

    $\left[\begin{matrix}n_1+n_m&n_1&n_1&\cdots&n_1\\n_2&n_2+n_m&n_2&\cdots&n_2\\n_3&n_3&n_3+n_m&\cdots&n_3\\&&&\vdots&\\n_{m-1}&n_{m-1}&n_{m-1}&\cdots&n_{m-1}+n_m\\\end{matrix}\right]\cdot\left[\begin{matrix}\alpha_1\\\alpha_2\\\alpha_3\\\vdots\\\alpha_{m-1}\\\end{matrix}\right]=\left[\begin{matrix}n_1\\n_2\\n_3\\\vdots\\n_{m-1}\\\end{matrix}\right]$

      求解這個爪形線性方程組,得到

    $\left[\begin{matrix}\sum_{j=1}^mn_j/n_1&0&0&\cdots&0\\-n_2/n_1&1&0&\cdots&0\\-n_3/n_1&0&1&\cdots&0\\&&&\vdots&\\-n_{m-1}/n_1&0&0&\cdots&1\\\end{matrix}\right]\cdot\left[\begin{matrix}\alpha_1\\\alpha_2\\\alpha_3\\\vdots\\\alpha_{m-1}\\\end{matrix}\right]=\left[\begin{matrix}1\\0\\0\\\vdots\\0\\\end{matrix}\right]$

      因為

    $\displaystyle \sum\limits_{j=1}^m n_j =   \sum\limits_{j=1}^m\sum\limits_{i=1}^n \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)}=\sum\limits_{i=1}^n \sum\limits_{j=1}^m \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)} =\sum\limits_{i=1}^n 1 =  n$

      解得

    $\displaystyle\alpha_j = \frac{n_j}{n} = \frac{1}{n}\sum\limits_{i=1}^n \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)}$

    計算σ與μ

      與$\alpha$不同,它的方程組是所有$\alpha_j$之間聯立的;而$\sigma,\mu$的方程組則是$\sigma_j$與$\mu_j$之間聯立的。定義

    $\displaystyle p_{ji} = \frac{\alpha_j^k\phi(y_i|\theta_j^k)} {\sum\limits_{l=1}^m \alpha_l^k\phi(y_i|\theta_l^k)}$

      則對於$\sigma_j,\mu_j$,優化式為(比較$(6),(7)$式的區別)

    $\begin{gather}\displaystyle\min\limits_{\sigma_j,\mu_j}\sum\limits_{i=1}^n p_{ji} \left(\log \sigma_j+\frac{(y_i-\mu_j)^2}{2\sigma_j^2} \right)\label{}\end{gather}$

      對上式求導等於0,解得

    $ \begin{aligned} &\mu_j = \frac{\sum\limits_{i=1}^np_{ji}y_i}{\sum\limits_{i=1}^np_{ji}} = \frac{\sum\limits_{i=1}^np_{ji}y_i}{n_j} = \frac{\sum\limits_{i=1}^np_{ji}y_i}{n\alpha_j}\\ &\sigma^2_j = \frac{\sum\limits_{i=1}^np_{ji}(y_i-\mu_j)^2}{\sum\limits_{i=1}^np_{ji}} = \frac{\sum\limits_{i=1}^np_{ji}(y_i-\mu_j)^2}{n_j} = \frac{\sum\limits_{i=1}^np_{ji}(y_i-\mu_j)^2}{n\alpha_j} \end{aligned} $

    代碼實現

      對於概率密度為$P(x) = −2x+2,x\in (0,1)$的隨機變量,以下代碼實現GMM對這一概率密度的的擬合。共10000個抽樣,GMM混合了100個高斯分佈。

    #%%定義參數、函數、抽樣
    import numpy as np
    import matplotlib.pyplot as plt
    
    dis_num = 100 #用於擬合的分佈數量
    sample_num = 10000 #用於擬合的分佈數量
    alphas = np.random.rand(dis_num) 
    alphas /= np.sum(alphas)  
    mus = np.random.rand(dis_num)
    sigmas = np.random.rand(dis_num)**2#方差,不是標準差
    samples = 1-(1-np.random.rand(sample_num))**0.5 #樣本
    C_pi = (2*np.pi)**0.5
    
    dis_val = np.zeros([sample_num,dis_num])    #每個樣本在每個分佈成員上都有值,形成一個sample_num*dis_num的矩陣
    pij = np.zeros([sample_num,dis_num])        #pij矩陣
    def calc_dis_val(sample,alpha,mu,sigma,c_pi):
        return alpha*np.exp(-(sample[:,np.newaxis]-mu)**2/(2*sigma))/(c_pi*sigma**0.5) 
    def calc_pij(dis_v):  
        return dis_v / dis_v.sum(axis = 1)[:,np.newaxis]      
    #%%優化 
    for i in range(1000):
        print(i)
        dis_val = calc_dis_val(samples,alphas,mus,sigmas,C_pi)
        pij = calc_pij(dis_val)  
        nj = pij.sum(axis = 0)
        alphas_before = alphas
        alphas = nj / sample_num
        mus = (pij*samples[:,np.newaxis]).sum(axis=0)/nj
        sigmas = (pij*(samples[:,np.newaxis] - mus)**2 ).sum(axis=0)/nj
        a = np.linalg.norm(alphas_before - alphas)
        print(a)
        if  a< 0.001:
            break
    
    #%%繪圖 
    plt.rcParams['font.sans-serif']=['SimHei'] #用來正常显示中文標籤
    plt.rcParams['axes.unicode_minus']=False #用來正常显示負號
    def get_dis_val(x,alpha,sigma,mu,c_pi):
        y = np.zeros([len(x)]) 
        for a,s,m in zip(alpha,sigma,mu):   
            y += a*np.exp(-(x-m)**2/(2*s))/(c_pi*s**0.5)   
        return y
    def paint(alpha,sigma,mu,c_pi,samples):
        x = np.linspace(-1,2,500)
        y = get_dis_val(x,alpha,sigma,mu,c_pi) 
        fig = plt.figure()
        ax = fig.add_subplot(111)
        ax.hist(samples,density = True,label = '抽樣分佈') 
        ax.plot(x,y,label = "擬合的概率密度")
        ax.legend(loc = 'best')
        plt.show()
    paint(alphas,sigmas,mus,C_pi,samples)

      以下是擬合結果圖,有點像是核函數估計,但是完全不同:

    EM算法的推廣

      EM算法的推廣是對EM算法的另一種解釋,最終的結論是一樣的,它可以使我們對EM算法的理解更加深入。它也解釋了我在$(1)$式下方提出的疑問:為什麼取出$P(Z|Y,\theta^k)$而不是別的。

      定義$F$函數,即所謂Free energy自由能(自由能具體是啥先不研究了):

    $ \begin{aligned} F(\tilde{P},\theta) &= E_{\tilde{P}}(\log P(Y,Z|\theta)) + H(\tilde{P})\\ &= \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log P(Y,Z|\theta) – \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log \tilde{P}(Z)\\ \end{aligned} $

      其中$\tilde{P}$是$Z$的某個概率分佈(不一定是單獨的分佈,可能是在某個條件下的分佈),$E_{\tilde{P}}$表示分佈$\tilde{P}$下的期望,$H$表示信息熵。

      我們計算一下,對於固定的$\theta$,什麼樣的$\tilde{P}$會使$F(\tilde{P},\theta) $最大。也就是找到一個函數$\tilde{P}_{\theta}$,使$F$極大,寫成優化的形式就是(這裡是找函數而不是找參數哦,理解上可能要用到泛函分析的內容):

    $ \begin{aligned} &\max\limits_{\tilde{P}} \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log P(Y,Z|\theta) – \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log \tilde{P}(Z)\\ &\;\text{s.t.}\; \sum\limits_{Z\in \mathcal{Z}}\tilde{P}(Z) = 1 \end{aligned} $

      拉格朗日函數(拉格朗日對偶性,點擊鏈接)為:

    $ \begin{aligned} L =  \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log P(Y,Z|\theta) – \sum\limits_{Z\in \mathcal{Z}} \tilde{P}(Z)\log \tilde{P}(Z)+ \lambda\left(1-\sum\limits_{Z\in \mathcal{Z}}\tilde{P}(Z)\right) \end{aligned} $

      因為每個$\tilde{P}(Z)$之間都是求和,沒有其它其它諸如乘積的操作,所以可以直接令$L$對某個$\tilde{P}(Z)$求導等於$0$來計算極值:

    $ \begin{aligned} \frac{\partial L}{\partial \tilde{P}(Z)} = \log P(Y,Z|\theta) – \log \tilde{P}(Z) -1 -\lambda = 0 \end{aligned} $

      於是可以推出:

    $ \begin{aligned} P(Y,Z|\theta) = e^{1+\lambda}\tilde{P}(Z) \end{aligned} $

      又由約束$\sum\limits_{Z\in \mathcal{Z}}\tilde{P}(Z) = 1$:

    $P(Y|\theta) = e^{1+\lambda}$

      於是得到

    $\begin{gather}\tilde{P}_{\theta}(Z) = P(Z|Y,\theta)\label{}\end{gather}$

      代回$F(\tilde{P},\theta)$,得到

    $ \begin{aligned} F(\tilde{P}_\theta,\theta) &= \sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta)\log P(Y,Z|\theta) – \sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta)\log P(Z|Y,\theta)\\ &= \sum\limits_{Z\in \mathcal{Z}} P(Z|Y,\theta)\log \frac{P(Y,Z|\theta)}{P(Z|Y,\theta)}\\ &= \log P(Y|\theta)\\ \end{aligned} $

      也就是說,對$F$關於$\tilde{P}$進行最大化后,$F$就是待求分佈的對數似然;然後再關於$\theta$最大化,也就算得了最終要估計的參數$\hat{\theta}$。所以,EM算法也可以解釋為$F$的極大-極大算法。優化結果$(8)$式也解釋了我之前在$(1)$式下方的提問。

      那麼,怎麼使用$F$函數進行估計呢?還是要用迭代來算,迭代方式是和前面介紹的一樣的(懶得記錄了,統計學習方法上直接看吧)。實際上,$F$函數的方法只是提供了EM算法的另一種解釋,具體方法上並沒有提升之處。

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

    【其他文章推薦】

    網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

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

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

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

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

    ※超省錢租車方案