環境資訊中心綜合外電；姜唯 編譯；林大利 審校
本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線
※Google地圖已可更新顯示潭子電動車充電站設置地點!!
※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益
※別再煩惱如何寫文案,掌握八大原則!
※網頁設計最專業,超強功能平台可客製化
分類: 3C資訊
-
印尼帝汶島海灘驚現大鯨魚屍體
摘錄自2020年7月24日法廣印尼報導
印度尼西亞南部帝汶島沙灘附近，發現了一具上百噸重大鯨魚的屍體。當局目前還沒搞懂這頭大型哺乳動物的死因。
當地漁民是在20日早上發現這具長達29米的大鯨魚。海事當局認為這頭海洋生物已有70歲，無生命的漂移，可能已長達數年之久。死因則尚無定論。其屍體上沒有發現任何傷痕，但當地媒體提到了上一個的案例。
2018年，另一頭鯨魚曾擱淺在附近的另個小島Kapota。那頭鯨魚的胃裡發現了眾多塑膠垃圾：115個塑膠杯，還有4個塑膠瓶。這一發現讓人感到震驚，儘管這最終並沒有被確定是造成大鯨魚死亡的原因，但已足以引起科學界的重視。
本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線
※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益
※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面
※南投搬家公司費用需注意的眉眉角角，別等搬了再說!
※教你寫出一流的銷售文案?
-
漢娜颶風肆虐德州 吹倒美墨邊境圍牆
摘錄自2020年7月27日東森國際新聞美國報導
美國德州（Texas）新冠肺炎疫情持續肆虐，周末又遭颶風漢娜（Hanna）侵襲。漢娜是今年第一個颶風，它已經摧毀許多船隻、淹沒街道、造成電力中斷、甚至吹倒一部分美墨邊境圍牆，災情相當嚴重。
據外媒《WDSU News》報導，國家颶風中心（National Hurricane Center）表示，目前颶風漢娜已降為熱帶低氣壓，以每小時超過50英里的風速橫越美墨邊境，並在德州南部和墨西哥東北部的部分地區降下了超過300毫米的豪雨。
州長格雷格·阿博特 (Greg Abbott)於週六（25日）在一場記者會中表示，「任何颶風都是一場巨大的挑戰，但這次的挑戰非常複雜，必且比以往更加嚴峻，因為這場颶風正在席捲著新冠肺炎的其中一個震央。」
本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※想知道最厲害的網頁設計公司"嚨底家"!
※別再煩惱如何寫文案,掌握八大原則!
※產品缺大量曝光嗎?你需要的是一流包裝設計!
-
Redis學習筆記（十八） 集群（下）
複製和故障轉移
Redis集群中的節點分為主節點（master）和從節點（slave），其中主節點用於處理槽，而從節點則用於複製某個主節點，並在被複制 的主節點下線時，代替下線主節點繼續處理命令請求。
設置從節點：CLUSTER REPLICATE < node_id >可以讓接收命令的節點稱為node_id 所指定節點的從節點，並開始對主節點進行複製。
1）接收到該命令的節點首先會在自己的clusterState.nodes字典中找到node_id所對應節點的clusterNode結構，並將自己的clusterState.myself.slaveof指針指向這個結構，以此來記錄這個節點正在複製的主節點：
struct clusterNode{ //如果這個時一個從節點，那麼指向主節點 struct clusterNode *slaveof; }
2）節點修改自己的clusterState.myself.flags中的屬性，關閉原本的REDIS_NODE_MASTER標識，打開REDIS_NODE_SLAVE標識，標識這個節點已經由原來的主節點變成了從節點。
3）節點會調用複製代碼，根據clusterState.myself.slaveof指向clusterNode結構所保存的IP地址和端口號，對節點進行複製。
一個節點稱為從節點，並開始複製某個主節點這一信息會通過消息發送給集群中的其他節點，最終集群中的所有節點都會知道某個從節點正在複製某個主節點。
集群中的所有節點都會在代表主節點的clusterNode結構的slaves屬性和numslaves屬性中記錄正在複製這個主節點的從節點名單：
struct clusterNode{ //正在複製這個主節點的從節點數量 int numslaves; //數組，每個數組項指向一個正在複製這個主節點的從節點的clusterNode struct clusterNode **slaves; }
集群中的每個節點都會定期地向集群中的其他節點發送PING消息，一次來檢測對方是否在線，如果接收PING消息的節點沒有在規定的時間內，向發送PING消息的節點返回PONG消息，那麼發送PING消息的節點就會將階段后PING消息的節點標記為疑似下線（PFAIL）。
集群中的各個節點會通過相互發送消息的方式來交換集群中各個節點的狀態信息：某個節點處於在線狀態、疑似下線、已下線狀態。
當一個主節點A通過罅隙得知主節點B認為主節點C進入疑似下線狀態時，主節點A會在自己的clusterState.nodes字典中找到主節點C所對應的clusterNode結構，並將主節點B的下線報告添加到clusterNode結構的fail_reports鏈表中
status clusterNode{ list *fali_reports;//鏈表，記錄所有其他節點對該節點的下線報告 };
下線報告結構：
struct c;isterNodeFailReport{ //報告目標節點已經下線的節點 struct clusterNode *node; //最後一個從node節點收到下線報告的時間（程序使用這個時間戳來檢查下線報告是否過期） mstime_t time; } typedef clusterNodeFailReport;
如果集群里半數以上負責處理槽的主節點都將某個主節點x報告未疑似下線，那麼這個主節點x將被標記未已下線，將主節點x標記為已下線的節點會向集群廣播一條關於主節點x的FAIL罅隙，所有收到這條罅隙的節點都會立即將主節點x標記為已下線。
故障轉移的步驟：
1）複製下線主節點的所有從節點裏面，會有一個從節點被選中，
2）被選中的從節點會執行SLAVEOF no one命令，成為新的主節點。
3）新的主節點會撤銷所有對已下線主節點的槽指派，並將這些槽指派給自己。
4）新的主節點向集群廣播一條PONG消息，這條消息讓其他集群中的其他節點立即知道這個節點已經由從節點變為主節點，並且這個主節點已經接管了原本已下線節點負責處理的槽。
5）新的主節點開始接收和自己負責處理的槽有關的命令請求，故障轉移完成。
選舉新的主節點：
1）集群的配置紀元是一個計數器。他的初始值為0；
2）當集群中的某個節點開始一次故障轉移操作時，集群配置紀元的值會被加1。
3）集群裏面每個負責處理槽的主節點都有一次投票機會，而第一個向主節點要求投票的從節點將獲得主節點的投票。
4）當從節點發現自己正在複製的主節點進入下線狀態時，從節點會向集群官博一條CLUSTERMSG_TYPE_FAILOVER_AUTH_REQUEST消息，要求所有收到這個消息、並且具有投票權的主節點向這個從節點投票。
5）如果一個主節點具有投票權，並且這個主節點尚未投票給其他從節點，那麼主節點將向要求投票的從節點返回一條CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK消息，表示這個主節點支持從節點成為新的主節點。
6）每個參与選舉的從節點都會收到CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK消息，並根據自己收到了多少條這種消息來統計自己獲得了多少主節點支持。
7）如果集群中有N個具有投票權的主節點，那麼當一個從節點大於等於N/2+1張支持票時，這個從節點就當選成為新的主節點。
8）如果在一個配置紀元裏面沒有從節點收集到足夠多的支持票，那麼集群進入下一個紀元，再次進行選舉，直到選出新的主節點為止。
消息
集群中各個節點通過發送和接收消息來進行通信，我們稱發送消息的節點為發送者，接收消息的節點為接收者：
1）MEET消息，當發送者接到客戶端發送的CLUSTER MEET命令時，發送者會向接收者發送MEET消息，請求接收者加入到發送者當前所處的集群裏面。
2）PING消息，集群裏面的每個節點默認每隔一秒鐘就會從已知節點列表中隨機選出五個節點，然後對這五個節點中最長時間沒有發送過PING消息的節點發送PING消息，以此檢測被選中的節點是否在線。除此之外，如果節點A最後一次收到節點B發送的PONG消息的時間，距離當前時間已超過了節點A的cluster-node-timeout選項設置時長的一半，那麼節點A也會向節點B發送PING消息，這可以防止節點A因長時間沒有隨機選中節點B作為PING消息的發送對象而導致節點B的信息更新滯后。
3）PONG消息，當接收者收到發送者發來的MEET消息或者PING時，為了向發送者確認這條MEET、PING消息已到達，接收者會向發送者返回一條PONG消息。另外，一個節點也可以通過向集群發送集群廣播自己的PONG消息來讓集群中的其他節點立即刷新關於這個節點的認識。
4）FAIL消息，當一個主節點A判斷另一個主節點B已經進入FAIL狀態時，節點A會會向集群廣播一條關於節點B的FAIL消息，所有接收到這條消息的節點都會立即將節點B標記為已下線。
5）PUBLISH消息，當節點接收到一個PUBLISH命令時，節點會執行這個命令，並向集群廣播一條PUBLISH消息，所有接收到這條PUBLISH消息的節點都會執行相同的PUBLISH命令。
一條消息由消息頭（header）和消息正文（data組成）
消息頭：
typedef struct { //消息的長度（消息頭的長度和消息正文的長度） uint32_t totlen; //消息的類型 uint16_t type; //消息正文包含的節點信息數量 //只有發送MEET、PING、PONG這三種Gossip協議消息時使用 uint16_t count; //薩松這所處的配置紀元 uint64_t currentEpoch; //如果發送者是一個主節點，那麼這裏面記錄的時發送者的配置紀元 //如果發送者時一個從節點，那麼這裏面記錄的時發送者正在複製的主節點的配置紀元 uint64_t configEpoch; //發送者的名稱（ID） char sender[REDIS_CLUSTER_NAMELEN]； //發送者目前的槽指派信息 unsigned char myslots[REDIS_CLUSTER_SLOTS/8]； //如果發送者是一個從節點，記錄的是發送者正在複製的主節點的名稱 //如果發送者是一個主節點，那麼這裏記錄的是REDIS_NODE_NULL_NAME char slaveof[REDIS_CLUSTER_NAMELEN]; //發送者的端口號 uint16_t port; //發送者的標識值 uint16_t flags; //發送者所處集群的狀態 unsigned char state; //消息正文 union clusterMsgData data; } clusterMsg;
clusterMsg.data 結構：
union clusterMsgData{ //MEET PING PONG 消息正文 struct{ //每條MEET PING PONG消息都包含兩個 clusterMsgDataGossip 結構 clusterMsgDataGossip gossip[1] } ping; //FAIL 消息正文 struct{ clusterMsgDataFail about; } fali; //PUBLISH消息正文 struct{ clusterMsgDataPublish msg; } publish; }
clusterMsgDataGossip結構記錄了選中節點的名字，發送者與被選中節點最後一次發送和接收PING消息和PONG消息的時間戳，被選中節點的IP地址和端口號，以及被選中節點的標識值：
typedef struct { //節點的名字 char nodename[REDIS_CLUSTER_NAMELEN]; //最後一次向該節點發送PING消息的時間戳 uint32_t ping_sent; //最後一次從該 節點接收到PONG消息的時間戳 uint32_t pong_received; //節點的IP地址 char ip[16]; //節點的端口號 uint16_t port; //節點的標識值 uint16_t flags; } clusterMsgDataGossip;
每天學一點，總會有收穫。
說明：尊重作者知識產權，文中內容參考《Redis設計與實現》，僅在此做學習與大家分享。
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益
※教你寫出一流的銷售文案?
-
【Spring註解驅動開發】使用@Import註解給容器中快速導入一個組件
寫在前面
我們可以將一些bean組件交由Spring管理，並且Spring支持單實例bean和多實例bean。我們自己寫的類，可以通過包掃描+標註註解（@Controller、@Servcie、@Repository、@Component）的形式將其註冊到IOC容器中，如果不是我們自己寫的類，比如，我們在項目中引入了一些第三方的類庫，此時，我們需要將這些第三方類庫中的類註冊到Spring容器中，該怎麼辦呢？此時，我們就可以使用@Bean和@Import註解將這些類快速的導入Spring容器中。接下來，我們來一起探討下如何使用@Import註解給容器中快速導入一個組件。
項目工程源碼已經提交到GitHub：https://github.com/sunshinelyz/spring-annotation
註冊bean的方式
向Spring容器中註冊bean通常有以下幾種方式：
- 包掃描+標註註解（@Controller、@Servcie、@Repository、@Component），通常用於自己寫的類。
- @Bean註解，通常用於導入第三方包中的組件。
- @Import註解，快速向Spring容器中導入組件。
@Import註解概述
Spring 3.0之前，創建Bean可以通過xml配置文件與掃描特定包下面的類來將類注入到Spring IOC容器內。而在Spring 3.0之後提供了JavaConfig的方式，也就是將IOC容器里Bean的元信息以java代碼的方式進行描述。我們可以通過@Configuration與@Bean這兩個註解配合使用來將原來配置在xml文件里的bean通過java代碼的方式進行描述
@Import註解提供了@Bean註解的功能，同時還有xml配置文件里 標籤組織多個分散的xml文件的功能，當然在這裡是組織多個分散的@Configuration
先看一下@Import註解的源碼：
@Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Import { /** * {@link Configuration}, {@link ImportSelector}, {@link ImportBeanDefinitionRegistrar} * or regular component classes to import. */ Class<?>[] value(); }從源碼里可以看出@Import可以配合
Configuration,ImportSelector,ImportBeanDefinitionRegistrar來使用，下面的or表示也可以把Import當成普通的Bean使用。@Import只允許放到類上面，不能放到方法上。下面我們來看具體的使用方式。
@Import註解的使用方式
@Import註解的三種用法主要包括：
- 直接填class數組方式
- ImportSelector方式【重點】
- ImportBeanDefinitionRegistrar方式
注意：我們先來看第一種方法：直接填class數組的方式，其他的兩種方式我們後面繼續講。
@Import導入組件的簡單示例
沒有使用@Import註解的效果
首先，我們創建一個Department類，這個類是一個空類，沒有成員變量和方法，如下所示。
package io.mykit.spring.plugins.register.bean; /** * @author binghe * @version 1.0.0 * @description 測試@Import註解的bean */ public class Department { }接下來，我們先在SpringBeanTest類中創建testAnnotationConfig7()方法，輸出Spring容器中所有的bean，來查看是否存在Department類對應的bean實例，以此來判斷Spring容器中是否註冊有Department類對應的bean實例。
@Test public void testAnnotationConfig7(){ ApplicationContext context = new AnnotationConfigApplicationContext(PersonConfig2.class); String[] names = context.getBeanDefinitionNames(); Arrays.stream(names).forEach(System.out::println); }運行SpringBeanTest類的testAnnotationConfig7()方法，輸出的結果信息如下所示。
org.springframework.context.annotation.internalConfigurationAnnotationProcessor org.springframework.context.annotation.internalAutowiredAnnotationProcessor org.springframework.context.annotation.internalCommonAnnotationProcessor org.springframework.context.event.internalEventListenerProcessor org.springframework.context.event.internalEventListenerFactory personConfig2 person binghe001可以看到Spring容器中並沒有Department類對應的bean實例。
使用@Import註解的效果
我們在PersonConfig2類上添加@Import註解，並將Department類標註到註解中，如下所示。
@Configuration @Import(Department.class) public class PersonConfig2 {此時，我們再次運行SpringBeanTest類的testAnnotationConfig7()方法，輸出的結果信息如下所示。
org.springframework.context.annotation.internalConfigurationAnnotationProcessor org.springframework.context.annotation.internalAutowiredAnnotationProcessor org.springframework.context.annotation.internalCommonAnnotationProcessor org.springframework.context.event.internalEventListenerProcessor org.springframework.context.event.internalEventListenerFactory personConfig2 io.mykit.spring.plugins.register.bean.Department person binghe001可以看到，輸出結果中打印了io.mykit.spring.plugins.register.bean.Department，說明使用@Import導入bean時，id默認是組件的全類名。
@Import註解支持同時導入多個類，例如，我們再次創建一個Employee類，如下所示。
package io.mykit.spring.plugins.register.bean; /** * @author binghe * @version 1.0.0 * @description 測試@Import註解的bean */ public class Employee { }接下來，我們也將Employee類添加到@Import註解中，如下所示。
@Configuration @Import({Department.class, Employee.class}) public class PersonConfig2 {此時，我們再次運行SpringBeanTest類的testAnnotationConfig7()方法，輸出的結果信息如下所示。
org.springframework.context.annotation.internalConfigurationAnnotationProcessor org.springframework.context.annotation.internalAutowiredAnnotationProcessor org.springframework.context.annotation.internalCommonAnnotationProcessor org.springframework.context.event.internalEventListenerProcessor org.springframework.context.event.internalEventListenerFactory personConfig2 io.mykit.spring.plugins.register.bean.Department io.mykit.spring.plugins.register.bean.Employee person binghe001可以看到，結果信息中同時輸出了io.mykit.spring.plugins.register.bean.Department和io.mykit.spring.plugins.register.bean.Employee，說明Department類的bean實例和Employee類的bean實例都導入到Spring容器中了。
好了，咱們今天就聊到這兒吧！別忘了給個在看和轉發，讓更多的人看到，一起學習一起進步！！
項目工程源碼已經提交到GitHub：https://github.com/sunshinelyz/spring-annotation
寫在最後
如果覺得文章對你有點幫助，請微信搜索並關注「 冰河技術 」微信公眾號，跟冰河學習Spring註解驅動開發。公眾號回復“spring註解”關鍵字，領取Spring註解驅動開發核心知識圖，讓Spring註解驅動開發不再迷茫。
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※為什麼 USB CONNECTOR 是電子產業重要的元件?
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※台北網頁設計公司全省服務真心推薦
※想知道最厲害的網頁設計公司"嚨底家"!
※推薦評價好的iphone維修中心
-
面試官突然問我MySQL存儲過程，我竟然連基礎都不會！（詳細）
所有知識體系文章，GitHub已收錄，歡迎Star！再次感謝，願你早日進入大廠！
GitHub地址： https://github.com/Ziphtracks/JavaLearningmanual
MySQL存儲過程
一、存儲過程
1.1 什麼是存儲過程
存儲過程（Stored Procedure）是在大型數據庫系統中，一組為了完成特定功能的SQL 語句集，它存儲在數據庫中，一次編譯后永久有效，用戶通過指定存儲過程的名字並給出參數（如果該存儲過程帶有參數）來執行它。存儲過程是數據庫中的一個重要對象。在數據量特別龐大的情況下利用存儲過程能達到倍速的效率提升
1.2 數據庫存儲過程程序
當我們了了解存儲過程是什麼之後，就需要了解數據庫中存在的這三種類型的數據庫存儲類型程序，如下：
- 存儲過程： 存儲過程是最常見的存儲程序，存儲過程是能夠接受輸入和輸出參數並且能夠在請求時被執行的程序單元。
- 存儲函數： 存儲函數和存儲過程很相像，但是它的執行結果會返回一個值。最重要的是存儲函數可以被用來充當標準的 SQL 語句，允許程序員有效的擴展 SQL 語言的能力。
- 觸發器： 觸發器是用來響應激活或者觸發數據庫行為事件的存儲程序。通常，觸發器用來作為數據庫操作語言的響應而被調用，觸發器可以被用來作為數據校驗和自動反向格式化。
注意： 其他的數據庫提供了別的數據存儲程序，包括包和類。目前MySQL不提供這種結構。
1.3 為什麼要使用存儲程序
雖然目前的開發中存儲程序我們使用的並不是很多，但是不一定就否認它。其實存儲程序會為我們使用和管理數據庫帶來了很多優勢：
- 使用存儲程序更加安全。
- 存儲程序提供了一種數據訪問的抽象機制，它能夠極大的改善你的代碼在底層數據結構演化過程中的易維護性。
- 存儲程序可以降低網絡擁阻，因為屬於數據庫服務器的內部數據，這相比在網上傳輸數據要快的多。
- 存儲程序可以替多種使用不同構架的外圍應用實現共享的訪問例程，無論這些構架是基於數據庫服務器外部還是內部。
- 以數據為中心的邏輯可以被獨立的放置於存儲程序中，這樣可以為程序員帶來更高、更為獨特的數據庫編程體驗。
- 在某些情況下，使用存儲程序可以改善應用程序的可移植性。（在另外某些情況下，可移植性也會很差！）
這裏我大致解釋一下上述幾種使用存儲程序的優勢：
我們要知道在Java語言中，我們使用數據庫與Java代碼結合持久化存儲需要引入JDBC來完成。會想到JDBC，我們是否還能想起SQL注入問題呢？雖然使用PreparedStatement解決SQL注入問題，那就真的是絕對安全嗎？不，它不是絕對安全的。
這時候分析一下數據庫與Java代碼的連接操作流程。在BS結構中，一般都是瀏覽器訪問服務器的，再由服務器發送SQL語句到數據庫，在數據庫中對SQL語句進行編譯運行，最後把結果通過服務器處理再返回瀏覽器。在此操作過程中，瀏覽器對服務器每發送一次對數據庫操作的請求就會調用對應的SQL語句編譯和執行，這是一件十分浪費性能的事情，性能下降 了就說明對數據庫的操作效率低 了。
還有一種可能是，在這個過程中進行發送傳輸的SQL語句是對真實的庫表進行操作的SQL語句，如果在發送傳輸的過程中被攔截了，一些不法分子會根據他所攔截的SQL語句推斷出我們數據庫中的庫表結構，這是一個很大的安全隱患 。
關於可維護性的提高，這裏模擬一個場景。通常數據庫在公司中是由DBA來管理的，如果管理數據庫多年的DBA辭職了，此時數據庫會被下一任DBA來管理。這裏時候問題來了，數據庫中這麼多的數據和SQL語句顯然對下一任管理者不太友好。就算管理多年的DBA長時間不操作查看數據庫也會忘記點什麼東西。所以，我們在需要引入存儲程序來進行SQL語句的統一編寫和編譯，為維護提供了便利 。（其實我覺得這個例子並不生動合理，但是為了大家能理解，請體諒！）
講了很多存儲程序的優勢演變過程，其核心就是： 需要將編譯好的一段或多段SQL語句放置在數據庫端的存儲程序中，以便解決以上問題並方便開發者直接調用。
二、存儲過程的使用步驟
2.1 存儲過程的開發思想
存儲過程時數據庫的一個重要的對象，可以封裝SQL語句集，可以用來完成一些較複雜的業務邏輯，並且可以入參（傳參）、出參（返回參數），這裏與Java中封裝方式十分相似。
而且創建時會預先編譯后保存，開發者後續的調用都不需要再次編譯。
2.2 存儲過程的優缺點
存儲過程使用的優缺點其實在1.3中的優勢中說到了。這裏我簡單羅列一下存儲過程的優點與缺點。
- 優點：
- 在生產環境下，可以通過直接修改存儲過程的方式修改業務邏輯或bug，而不用重啟服務器。
- 執行速度快，存儲過程經過編譯之後會比單獨一條一條編譯執行要快很多。
- 減少網絡傳輸流量。
- 便於開發者或DBA使用和維護。
- 在相同數據庫語法的情況下，改善了可移植性。
- 缺點：
- 過程化編程，複雜業務處理的維護成本高。
- 調試不便。
- 因為不同數據庫語法不一致，不同數據庫之間可移植性差。
2.3 MySQL存儲過程的官方文檔
英語好或者有能力的小夥伴可以去參考一下官方文檔。如果不參考官方文檔，沒關係，我在下面也會詳細講述MySQL存儲過程的各個知識點。
1https://dev.mysql.com/doc/refman/5.6/en/preface.html2.3 存儲過程的使用語法
1create PROCEDURE 過程名( in|out|inout 參數名 數據類型 , ...)
2begin
3 sql語句;
4end;
5call 過程名(參數值);in是定義傳入參數的關鍵字。out是定義出參的關鍵字。inout是定義一個出入參數都可以的參數。如果括號內什麼都不定義，就說明該存儲過程時一個無參的函數。在後面會有詳細的案例分析。注意： SQL語句默認的結束符為
;，所以在使用以上存儲過程時，會報1064的語法錯誤。我們可以使用DELIMITER關鍵字臨時聲明修改SQL語句的結束符為//，如下：1-- 臨時定義結束符為"//"
2DELIMITER //
3create PROCEDURE 過程名( in|out 參數名 數據類型 , ...)
4begin
5 sql語句;
6end//
7-- 將結束符重新定義回結束符為";"
8DELIMITER ;例如： 使用存儲過程來查詢員工的工資（無參）
注意： 如果在特殊的必要情況下，我們還可以通過
delimiter關鍵字將;結束符聲明回來使用，在以下案例中我並沒有這樣將結束符聲明回原來的;，在此請大家注意~為什麼我在這裏提供了drop（刪除）呢？
是因為我們在使用的時候如果需要修改存儲過程中的內容，我們需要先刪除現有的存儲過程后，再creat重新創建。
1# 聲明結束符為//
2delimiter //
3
4# 創建存儲過程(函數)
5create procedure se()
6begin
7 select salary from employee;
8end //
9
10# 調用函數
11call se() //
12
13# 刪除已存在存儲過程——se()函數
14drop procedure if exists se //三、存儲過程的變量和賦值
3.1 局部變量
聲明局部變量語法：
declare var_name type [default var_value];賦值語法：
注意： 局部變量的定義，在begin/end塊中有效。
使用set為參數賦值
1# set賦值
2
3# 聲明結束符為//
4delimiter //
5
6# 創建存儲過程
7create procedure val_set()
8begin
9 # 聲明一個默認值為unknown的val_name局部變量
10 declare val_name varchar(32) default 'unknown';
11 # 為局部變量賦值
12 set val_name = 'Centi';
13 # 查詢局部變量
14 select val_name;
15end //
16
17# 調用函數
18call val_set() //
19使用into接收參數
1delimiter //
2create procedure val_into()
3begin
4 # 定義兩個變量存放name和age
5 declare val_name varchar(32) default 'unknown';
6 declare val_age int;
7 # 查詢表中id為1的name和age並放在定義的兩個變量中
8 select name,age into val_name,val_age from employee where id = 1;
9 # 查詢兩個變量
10 select val_name,val_age;
11end //
12
13call val_into() //
143.2 用戶變量
用戶自定義用戶變量，當前會話（連接）有效。與Java中的成員變量相似。
- 語法：
@val_name - 注意： 該用戶變量不需要提前聲明，使用即為聲明。
1delimiter //
2create procedure val_user()
3begin
4 # 為用戶變量賦值
5 set @val_name = 'Lacy';
6end //
7
8# 調用函數
9call val_user() //
10
11# 查詢該用戶變量
12select @val_name //3.3 會話變量
會話變量是由系統提供的，只在當前會話（連接）中有效。
語法：
@@session.val_name1# 查看所有會話變量
2show session variables;
3# 查看指定的會話變量
4select @@session.val_name;
5# 修改指定的會話變量
6set @@session.val_name = 0;這裏我獲取了一下所有的會話變量，大概有500條會話變量的記錄。等我們深入學習MySQL后，了解了各個會話變量值的作用，可以根據需求和場景來修改會話變量值。
1delimiter //
2create procedure val_session()
3begin
4 # 查看會話變量
5 show session variables;
6end //
7
8call val_session() //
9image-20200610112512964
3.4 全局變量
全局變量由系統提供，整個MySQL服務器內有效。
語法：
@@global.val_name1# 查看全局變量中變量名有char的記錄
2show global variables like '%char%' //
3# 查看全局變量character_set_client的值
4select @@global.character_set_client //3.5 入參出參
入參出參的語法我們在文章開頭已經提過了，但是沒有演示，在這裏我將演示一下入參出參的使用。
語法：
in|out|inout 參數名 數據類型 , ...in定義出參；out定義入參；inout定義出參和入參。出參in
使用出參in時，就是需要我們傳入參數，在這裏可以對參入的參數加以改變。簡單來說in只負責傳入參數到存儲過程中，類似Java中的形參。
1delimiter //
2create procedure val_in(in val_name varchar(32))
3begin
4 # 使用用戶變量出參(為用戶變量賦參數值)
5 set @val_name1 = val_name;
6end //
7
8# 調用函數
9call val_in('DK') //
10
11# 查詢該用戶變量
12select @val_name1 //入參out
在使用out時，需要傳入一個參數。而這個參數相當於是返回值，可以通過調用、接收來獲取這個參數的內容。簡單來說out只負責作返回值。
1delimiter //
2# 創建一個入參和出參的存儲過程
3create procedure val_out(in val_id int,out val_name varchar(32))
4begin
5 # 傳入參數val_id查詢員工返回name值(查詢出的name值用出參接收並返回)
6 select name into val_name from employee where id = val_id;
7end //
8
9# 調用函數傳入參數並聲明傳入一個用戶變量
10call val_out(1, @n) //
11
12# 查詢用戶變量
13select @n //入參出參inout
inout關鍵字，就是把in和out合併成了一個關鍵字使用。被關鍵字修飾的參數既可以出參也可以入參。
1delimiter //
2create procedure val_inout(in val_name varchar(32), inout val_age int)
3begin
4 # 聲明一個a變量
5 declare a int;
6 # 將傳入的參數賦值給a變量
7 set a = val_age;
8 # 通過name查詢age並返回val_age
9 select age into val_age from employee where name = val_name;
10 # 將傳入的a與-和查詢age結果字符串做拼接並查詢出來(concat——拼接字符串)
11 select concat(a, '-', val_age);
12end //
13
14# 聲明一個用戶變量並賦予參數為40
15set @ages = '40' //
16# 調用函數並傳入參數值
17call val_inout('Ziph', @ages) //
18# 執行結果
19# 40-18四、存儲過程中的流程控制
4.1 if 條件判斷（推薦）
擴展：
timestampdiff(unit, exp1, exp2)為exp2 – exp1得到的差值，而單位是unit。（常用於日期）擴展例子：
select timestampdiff(year,’2020-6-6‘,now()) from emp e where id = 1;解釋擴展例子： 查詢員工表中id為1員工的年齡，exp2就可以為該員工的出生年月日，並以年為單位計算。
語法：
1IF 條件判斷 THEN 結果
2 [ELSEIF 條件判斷 THEN 結果] ...
3 [ELSE 結果]
4END IF舉例： 傳入所查詢的id參數查詢工資標準（s<=6000為低工資標準；6000 =15000為高工資標準）
1delimiter //
2create procedure s_sql(in val_id int)
3begin
4 # 聲明一個局部變量result存放工資標準結果
5 declare result varchar(32);
6 # 聲明一個局部變量存放查詢得到的工資
7 declare s double;
8 # 根據入參id查詢工資
9 select salary into s from employee where id = val_id;
10 # if判斷的使用
11 if s <= 6000 then
12 set result = '低工資標準';
13 elseif s <= 10000 then
14 set result = '中工資標準';
15 elseif s <= 15000 then
16 set result = '中上工資標準';
17 else
18 set result = '高工資標準';
19 end if;
20 # 查詢工資標準結果
21 select result;
22end //
23
24# 調用函數，傳入參數
25call s_sql(1);4.2 case條件判斷
關於case語句，不僅僅在存儲過程中可以使用，MySQL基礎查詢語句中也有用到過。相當於是Java中的switch語句。
語法：
1# 語法一
2CASE case_value
3 WHEN when_value THEN 結果
4 [WHEN when_value THEN 結果] ...
5 [ELSE 結果]
6END CASE
7
8# 語法二(推薦語法)
9CASE
10 WHEN 條件判斷 THEN 結果
11 [WHEN 條件判斷 THEN 結果] ...
12 [ELSE 結果]
13END CASE舉例：
1# 語法一
2delimiter //
3create procedure s_case(in val_id int)
4begin
5 # 聲明一個局部變量result存放工資標準結果
6 declare result varchar(32);
7 # 聲明一個局部變量存放查詢得到的工資
8 declare s double;
9 # 根據入參id查詢工資
10 select salary into s from employee where id = val_id;
11 case s
12 when 6000 then set result = '低工資標準';
13 when 10000 then set result = '中工資標準';
14 when 15000 then set result = '中上工資標準';
15 else set result = '高工資標準';
16 end case;
17 select result;
18end //
19
20call s_case(1);
21
22# 語法二(推薦)
23delimiter //
24create procedure s_case(in val_id int)
25begin
26 # 聲明一個局部變量result存放工資標準結果
27 declare result varchar(32);
28 # 聲明一個局部變量存放查詢得到的工資
29 declare s double;
30 # 根據入參id查詢工資
31 select salary into s from employee where id = val_id;
32 case
33 when s <= 6000 then set result = '低工資標準';
34 when s <= 10000 then set result = '中工資標準';
35 when s <= 15000 then set result = '中上工資標準';
36 else set result = '高工資標準';
37 end case;
38 select result;
39end //
40
41call s_case(1);4.3 loop循環
loop為死循環，需要手動退出循環，我們可以使用
leave來退出循環可以把leave看成Java中的break；與之對應的，就有
iterate（繼續循環）也可以看成Java的continue語法：
1[別名:] LOOP
2 循環語句
3END LOOP [別名]注意：別名和別名控制的是同一個標籤。
示例1： 循環打印1~10（leave控制循環的退出）
注意：該loop循環為死循環，我們查的1~10数字是i，在死循環中設置了當大於等於10時停止循環，也就是說先後執行了10次該循環內的內容，結果查詢了10次，生成了10個結果（1~10）。
1delimiter //
2create procedure s_loop()
3begin
4 # 聲明計數器
5 declare i int default 1;
6 # 開始循環
7 num:
8 loop
9 # 查詢計數器記錄的值
10 select i;
11 # 判斷大於等於停止計數
12 if i >= 10 then
13 leave num;
14 end if;
15 # 計數器自增1
16 set i = i + 1;
17 # 結束循環
18 end loop num;
19end //
20
21call s_loop();打印結果：
image-20200610191639524
示例2： 循環打印1~10（iterate和leave控制循環）
注意：這裏我們使用字符串拼接計數器結果，而條件如果用iterate就必須時 i < 10 了！
1delimiter //
2create procedure s_loop1()
3begin
4 # 聲明變量i計數器
5 declare i int default 1;
6 # 聲明字符串容器
7 declare str varchar(256) default '1';
8 # 開始循環
9 num:
10 loop
11 # 計數器自增1
12 set i = i + 1;
13 # 字符串容器拼接計數器結果
14 set str = concat(str, '-', i);
15 # 計數器i如果小於10就繼續執行
16 if i < 10 then
17 iterate num;
18 end if;
19 # 計數器i如果大於10就停止循環
20 leave num;
21 # 停止循環
22 end loop num;
23 # 查詢字符串容器的拼接結果
24 select str;
25end //
26
27call s_loop1();image-20200610193153512
4.4 repeat循環
repeat循環類似Java中的do while循環，直到條件不滿足才會結束循環。
語法：
1[別名:] REPEAT
2 循環語句
3UNTIL 條件
4END REPEAT [別名]示例： 循環打印1~10
1delimiter //
2create procedure s_repeat()
3begin
4 declare i int default 1;
5 declare str varchar(256) default '1';
6 # 開始repeat循環
7 num:
8 repeat
9 set i = i + 1;
10 set str = concat(str, '-', i);
11 # until 結束條件
12 # end repeat 結束num 結束repeat循環
13 until i >= 10 end repeat num;
14 # 查詢字符串拼接結果
15 select str;
16end //
17
18call s_repeat();4.5 while循環
while循環就與Java中的while循環很相似了。
語法：
1[別名] WHILE 條件 DO
2 循環語句
3END WHILE [別名]示例： 循環打印1~10
1delimiter //
2create procedure s_while()
3begin
4 declare i int default 1;
5 declare str varchar(256) default '1';
6 # 開始while循環
7 num:
8 # 指定while循環結束條件
9 while i < 10 do
10 set i = i + 1;
11 set str = concat(str, '+', i);
12 # while循環結束
13 end while num;
14 # 查詢while循環拼接字符串
15 select str;
16end //
17
18call s_while();4.6 流程控制語句（繼續、結束）
至於流程控制的繼續和結束，我們在前面已經使用過了。這裏再列舉一下。
leave：與Java中break;相似
1leave 標籤;iterate：與Java中的continue;相似
1iterate 標籤;五、游標與handler
5.1 游標
游標是可以得到某一個結果集並逐行處理數據。游標的逐行操作，導致了游標很少被使用！
語法：
1DECLARE 游標名 CURSOR FOR 查詢語句
2-- 打開語法
3OPEN 游標名
4-- 取值語法
5FETCH 游標名 INTO var_name [, var_name] ...
6-- 關閉語法
7CLOSE 游標名了解了游標的語法，我們開始使用游標。如下：
示例： 使用游標查詢id、name和salary。
1delimiter //
2create procedure f()
3begin
4 declare val_id int;
5 declare val_name varchar(32);
6 declare val_salary double;
7
8 # 聲明游標
9 declare emp_flag cursor for
10 select id, name, salary from employee;
11
12 # 打開
13 open emp_flag;
14
15 # 取值
16 fetch emp_flag into val_id, val_name, val_salary;
17
18 # 關閉
19 close emp_flag;
20
21 select val_id, val_name, val_salary;
22end //
23
24call f();執行結果：
image-20200610203622749
因為游標逐行操作的特點，導致我們只能使用游標來查詢一行記錄。怎麼改善代碼才可以實現查詢所有記錄呢？聰明的小夥伴想到了使用循環。對，我們試試使用一下循環。
1delimiter //
2create procedure f()
3begin
4 declare val_id int;
5 declare val_name varchar(32);
6 declare val_salary double;
7
8 # 聲明游標
9 declare emp_flag cursor for
10 select id, name, salary from employee;
11
12 # 打開
13 open emp_flag;
14
15 # 使用循環取值
16 c:loop
17 # 取值
18 fetch emp_flag into val_id, val_name, val_salary;
19 end loop;
20
21 # 關閉
22 close emp_flag;
23
24 select val_id, val_name, val_salary;
25end //
26
27call f();image-20200610204034224
我們使用循環之後，發現有一個問題，因為循環是死循環，我們不加結束循環的條件，游標會一直查詢記錄，當查到沒有的記錄的時候，就會拋出異常
1329：未獲取到選擇處理的行數。如果我們想辦法指定結束循環的條件該怎麼做呢？
這時候可以聲明一個boolean類型的標記。如果為true時則查詢結果集，為false時則結束循環。
1delimiter //
2create procedure f()
3begin
4 declare val_id int;
5 declare val_name varchar(32);
6 declare val_salary double;
7
8 # 聲明flag標記
9 declare flag boolean default true;
10
11 # 聲明游標
12 declare emp_flag cursor for
13 select id, name, salary from employee;
14
15 # 打開
16 open emp_flag;
17
18 # 使用循環取值
19 c:loop
20 fetch emp_flag into val_id, val_name, val_salary;
21 # 如果標記為true則查詢結果集
22 if flag then
23 select val_id, val_name, val_salary;
24 # 如果標記為false則證明結果集查詢完畢，停止死循環
25 else
26 leave c;
27 end if;
28 end loop;
29
30 # 關閉
31 close emp_flag;
32
33 select val_id, val_name, val_salary;
34end //
35
36call f();上述代碼你會發現並沒有寫完，它留下了一個很嚴肅的問題。當flag = false時候可以結束循環。但是什麼時候才讓flag為false啊？
於是，MySQL為我們提供了一個
handler句柄。它可以幫我們解決此疑惑。handler句柄語法：
declare continue handler for 異常 set flag = false;handler句柄可以用來捕獲異常，也就是說在這個場景中當捕獲到
1329：未獲取到選擇處理的行數時，就將flag標記的值改為false。這樣使用handler句柄就解決了結束循環的難題。讓我們來試試吧！終極版示例： 解決了多行查詢以及結束循環問題。
1delimiter //
2create procedure f()
3begin
4 declare val_id int;
5 declare val_name varchar(32);
6 declare val_salary double;
7
8 # 聲明flag標記
9 declare flag boolean default true;
10
11 # 聲明游標
12 declare emp_flag cursor for
13 select id, name, salary from employee;
14
15 # 使用handler句柄來解決結束循環問題
16 declare continue handler for 1329 set flag = false;
17
18 # 打開
19 open emp_flag;
20
21 # 使用循環取值
22 c:loop
23 fetch emp_flag into val_id, val_name, val_salary;
24 # 如果標記為true則查詢結果集
25 if flag then
26 select val_id, val_name, val_salary;
27 # 如果標記為false則證明結果集查詢完畢，停止死循環
28 else
29 leave c;
30 end if;
31 end loop;
32
33 # 關閉
34 close emp_flag;
35
36 select val_id, val_name, val_salary;
37end //
38
39call f();執行結果：
image-20200610210925964
在執行結果中，可以看出查詢結果以多次查詢的形式，分佈显示到了每一個查詢結果窗口中。
注意： 在語法中，變量聲明、游標聲明、handler聲明是必須按照先後順序書寫的，否則創建存儲過程出錯。
5.2 handler句柄
語法：
1DECLARE handler操作 HANDLER
2 FOR 情況列表...(比如：異常錯誤情況)
3 操作語句注意：異常情況可以寫異常錯誤碼、異常別名或SQLSTATE碼。
handler操作：
- CONTINUE： 繼續
- EXIT： 退出
- UNDO： 撤銷
異常情況列表：
- mysql_error_code
- SQLSTATE [VALUE] sqlstate_value
- condition_name
- SQLWARNING
- NOT FOUND
- SQLEXCEPTION
注意： MySQL中各種異常情況代碼、錯誤碼、別名和SQLSTATEM碼可參考官方文檔：
https://dev.mysql.com/doc/refman/5.6/en/server-error-reference.html
寫法示例：
1 DECLARE exit HANDLER FOR SQLSTATE '3D000' set flag = false;
2 DECLARE continue HANDLER FOR 1050 set flag = false;
3 DECLARE continue HANDLER FOR not found set flag = false;六、循環創建表
需求： 創建下個月的每天對應的表，創建的表格式為：
comp_2020_06_01、comp_2020_06_02、...描述： 我們需要用某個表記錄很多數據，比如記錄某某用戶的搜索、購買行為（注意，此處是假設用數據庫保存），當每天記錄較多時，如果把所有數據都記錄到一張表中太龐大，需要分表，我們的要求是，每天一張表，存當天的統計數據，就要求提前生產這些表——每月月底創建下一個月每天的表！
預編譯：
PREPARE 數據庫對象名 FROM 參數名執行：
EXECUTE 數據庫對象名 [USING @var_name [, @var_name] ...]通過數據庫對象創建或刪除表：
{DEALLOCATE | DROP} PREPARE 數據庫對象名關於時間處理的語句：
1-- EXTRACT(unit FROM date) 截取時間的指定位置值
2-- DATE_ADD(date,INTERVAL expr unit) 日期運算
3-- LAST_DAY(date) 獲取日期的最後一天
4-- YEAR(date) 返回日期中的年
5-- MONTH(date) 返回日期的月
6-- DAYOFMONTH(date) 返回日代碼：
1-- 思路：循環構建表名 comp_2020_06_01 到 comp_2020_06_30；並執行create語句。
2delimiter //
3create procedure sp_create_table()
4begin
5 # 聲明需要拼接表名的下一個月的年、月、日
6 declare next_year int;
7 declare next_month int;
8 declare next_month_day int;
9
10 # 聲明下一個月的月和日的字符串
11 declare next_month_str char(2);
12 declare next_month_day_str char(2);
13
14 # 聲明需要處理每天的表名
15 declare table_name_str char(10);
16
17 # 聲明需要拼接的1
18 declare t_index int default 1;
19 # declare create_table_sql varchar(200);
20
21 # 獲取下個月的年份
22 set next_year = year(date_add(now(),INTERVAL 1 month));
23 # 獲取下個月是幾月
24 set next_month = month(date_add(now(),INTERVAL 1 month));
25 # 下個月最後一天是幾號
26 set next_month_day = dayofmonth(LAST_DAY(date_add(now(),INTERVAL 1 month)));
27
28 # 如果下一個月月份小於10，就在月份的前面拼接一個0
29 if next_month < 10
30 then set next_month_str = concat('0',next_month);
31 else
32 # 如果月份大於10，不做任何操作
33 set next_month_str = concat('',next_month);
34 end if;
35
36 # 循環操作(下個月的日大於等於1循環開始循環)
37 while t_index <= next_month_day do
38
39 # 如果t_index小於10就在前面拼接0
40 if (t_index < 10)
41 then set next_month_day_str = concat('0',t_index);
42 else
43 # 如果t_index大於10不做任何操作
44 set next_month_day_str = concat('',t_index);
45 end if;
46
47 # 拼接標命字符串
48 set table_name_str = concat(next_year,'_',next_month_str,'_',next_month_day_str);
49 # 拼接create sql語句
50 set @create_table_sql = concat(
51 'create table comp_',
52 table_name_str,
53 '(`grade` INT(11) NULL,`losal` INT(11) NULL,`hisal` INT(11) NULL) COLLATE=\'utf8_general_ci\' ENGINE=InnoDB');
54 # 預編譯
55 # 注意：FROM後面不能使用局部變量！
56 prepare create_table_stmt FROM @create_table_sql;
57 # 執行
58 execute create_table_stmt;
59 # 創建表
60 DEALLOCATE prepare create_table_stmt;
61
62 # t_index自增1
63 set t_index = t_index + 1;
64
65 end while;
66end//
67
68# 調用函數
69call sp_create_table()七、其他
7.1 characteristic
在MySQL存儲過程中，如果沒有显示的定義characteristic，它會隱式的定義一系列特性的默認值來創建存儲過程。
-
LANGUAGE SQL
-
存儲過程語言，默認是sql，說明存儲過程中使用的是sql語言編寫的，暫時只支持sql，後續可能會支持其他語言
-
NOT DETERMINISTIC
-
是否確定性的輸入就是確定性的輸出，默認是NOT DETERMINISTIC，只對於同樣的輸入，輸出也是一樣的，當前這個值還沒有使用
-
CONTAINS SQL
-
提供子程序使用數據的內在信息，這些特徵值目前提供給服務器，並沒有根據這些特徵值來約束過程實際使用數據的情況。有以下選擇：
- CONTAINS SQL表示子程序不包含讀或者寫數據的語句
- NO SQL 表示子程序不包含sql
- READS SQL DATA 表示子程序包含讀數據的語句，但是不包含寫數據的語句
- MODIFIES SQL DATA 表示子程序包含寫數據的語句。
-
SQL SECURITY DEFINER
-
MySQL存儲過程是通過指定SQL SECURITY子句指定執行存儲過程的實際用戶。所以次值用來指定存儲過程是使用創建者的許可來執行，還是執行者的許可來執行，默認值是DEFINER
- DEFINER 創建者的身份來調用，對於當前用戶來說：如果執行存儲過程的權限，且創建者有訪問表的權限，當前用戶可以成功執行過程的調用的
- INVOKER 調用者的身份來執行，對於當前用戶來說：如果執行存儲過程的權限，以當前身份去訪問表，如果當前身份沒有訪問表的權限，即便是有執行過程的權限，仍然是無法成功執行過程的調用的。
-
COMMENT ”
-
存儲過程的註釋性信息寫在COMMENT裏面，這裏只能是單行文本，多行文本會被移除到回車換行等
7.2 死循環處理
如有死循環處理，可以通過下面的命令查看並殺死（結束）
1show processlist;
2kill id;7.3 select語句中書寫case
1select
2 case
3 when 條件判斷 then 結果
4 when 條件判斷 then 結果
5 else 結果
6 end 別名,
7 *
8from 表名;7.4 複製表和數據
1CREATE TABLE dept SELECT * FROM procedure_demo.dept;
2CREATE TABLE emp SELECT * FROM procedure_demo.emp;
3CREATE TABLE salgrade SELECT * FROM procedure_demo.salgrade;7.5 臨時表
1create temporary table 表名(
2 字段名 類型 [約束],
3 name varchar(20)
4)Engine=InnoDB default charset utf8;
5
6-- 需求：按照部門名稱查詢員工，通過select查看員工的編號、姓名、薪資。（注意，此處僅僅演示游標用法）
7delimiter $$
8create procedure sp_create_table02(in dept_name varchar(32))
9begin
10 declare emp_no int;
11 declare emp_name varchar(32);
12 declare emp_sal decimal(7,2);
13 declare exit_flag int default 0;
14
15 declare emp_cursor cursor for
16 select e.empno,e.ename,e.sal
17 from emp e inner join dept d on e.deptno = d.deptno where d.dname = dept_name;
18
19 declare continue handler for not found set exit_flag = 1;
20
21 -- 創建臨時表收集數據
22 CREATE temporary TABLE `temp_table_emp` (
23 `empno` INT(11) NOT NULL COMMENT '員工編號',
24 `ename` VARCHAR(32) NULL COMMENT '員工姓名' COLLATE 'utf8_general_ci',
25 `sal` DECIMAL(7,2) NOT NULL DEFAULT '0.00' COMMENT '薪資',
26 PRIMARY KEY (`empno`) USING BTREE
27 )
28 COLLATE='utf8_general_ci'
29 ENGINE=InnoDB;
30
31 open emp_cursor;
32
33 c_loop:loop
34 fetch emp_cursor into emp_no,emp_name,emp_sal;
35
36
37 if exit_flag != 1 then
38 insert into temp_table_emp values(emp_no,emp_name,emp_sal);
39 else
40 leave c_loop;
41 end if;
42
43 end loop c_loop;
44
45 select * from temp_table_emp;
46
47 select @sex_res; -- 僅僅是看一下會不會執行到
48 close emp_cursor;
49
50end$$
51
52call sp_create_table02('RESEARCH');本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能
※台北網頁設計公司這麼多該如何選擇?
※智慧手機時代的來臨，RWD網頁設計為架站首選
※評比南投搬家公司費用收費行情懶人包大公開
※回頭車貨運收費標準
-
新基建下，智慧交通發展新規劃：智慧隧道監控可視化系統
前言 隨着當代經濟的發展，交通環境日益緊張，加上山區地區的交通運輸的需求，隧道的交通建設開發方興未艾。
隧道交通的規劃越來越完備，而對於隧道內監控管理維護卻顯得有些不足。而
工業4.0的崛起，逐步進入了智能化的新時代，伴隨着
工業互聯網的新興力量，工控可視化系統應運而生，不僅能起到日常的監控管理維護，在發現事故或險情時能第一時間採取
應急預案；還能通過實時數據的採集反饋，遠程操控設備運行以及預測設備的優良性能，從而達到更立體更全面的工控系統的運行。
HT for Web
不止自主研發了強大的基於 HTML5 的 2D、3D 渲染引擎，為可視化提供了豐富的展示效果。介於 2D 組態和 3D 組態上，Hightopo（以下簡稱 HT ）的 HT for Web 產品上的有着豐富的組態化可供選擇，本文將介紹如何運用 HT 豐富的 2/3D 組態搭建出一個隧道監控可視化系統的解決方案。 監控隧道內的車道堵塞情況、隧道內的車禍現場，在隧道中显示當前車禍位置並在隧道口給予提示等功能都是非常有必要的。這個隧道監控可視化系統的主要內容包括：照明、風機、車道指示燈、交通信號燈、情報板、消防、火災報警、車行橫洞、風向儀、微波車檢、隧道緊急逃生出口的控制以及事故模擬等等。
界面簡介及效果預覽預覽鏈接：http://www.hightopo.com/demo/tunnel2/index.html
上圖中的各種設備都可以雙擊，此時 camera 的位置會從當前位置移動到雙擊的設備的正前方；隧道入口的展示牌會自動輪播，出現事故時會展示牌中的內容會由“限速80，請開車燈”變為“超車道兩車追尾，請減速慢行”；兩隧道中間的逃生通道上方的指示牌是可以點擊的，點擊切換為藍綠色激活狀態，兩旁的逃生通道門也會打開，再單擊指示牌變為灰色，門關閉；還有一個事故現場模擬，雙擊兩旁變壓器中其中一個，在隧道內會出現一個“事故現場圖標”，單擊此圖標，出現彈出框显示事故等等等等。
代碼實現
一、場景搭建 整個隧道都是基於 3D 場景上繪製的，先來看看怎麼搭建 3D 場景：// 數據容器 dm = new ht.DataModel(); // 3d 場景 g3d = new ht.graph3d.Graph3dView(dm); // 將場景添加到 body 中 g3d.addToDOM();上面代碼中的 addToDOM 函數，是一個將組件添加到 body 體中的函數的封裝，定義如下：
addToDOM = function(){ var self = this, // 獲取組件的底層 div view = self.getView(), style = view.style; // 將組件底層div添加進body中 document.body.appendChild(view); // ht 默認將所有的組件的position都設置為absolute絕對定位 style.left = '0'; style.right = '0'; style.top = '0'; style.bottom = '0'; // 窗口大小改變事件，調用刷新函數 window.addEventListener('resize', function () { self.iv(); }, false); }
二、JSON反序列化 整個場景是由名為 隧道1.json 的文件導出而成的，我只需要用代碼將 json 文件中的內容轉換為我需要的部分即可：// xhrLoad 函數是一個異步加載文件的函數 ht.Default.xhrLoad('./scenes/隧道1.json', function(text) { // 將 json 文件中的文本轉為我們需要的 json 格式的內容 var json = ht.Default.parse(text); // 反序列化數據容器，解析用於生成對應的Data對象並添加到數據容器 這裏相當於把 json 文件中生成的 ht.Node 節點反序列化到數據容器中，這樣數據容器中就有這個節點了 dm.deserialize(json); });由於 xhrLoad 函數是一個異步加載函數，所以如果 dm 數據容器反序列化未完成就直接調用了其中的節點，那麼會造成數據獲取不到的結果，所以一般來說我是將一些邏輯代碼寫在這個函數內部，或者給邏輯代碼設置 timeout 錯開時間差。
首先，由於數據都是存儲在 dm 數據容器中的（通過 dm.add(node) 添加的），所以我們要獲取數據除了可以通過 id、tag 等獨立的方式，還可以通過遍曆數據容器來獲取多個元素。由於這個場景比較複雜，模型的面也比較多，鑒於設備配置，我將能 Batch 批量的元素都進行了批量。
批量是 HT 實現下的一種特有的機制，批量能提高性能的原理在於，當圖元一個個獨立繪製模型時性能較差，而當一批圖元聚合成一個大模型進行一次性的繪製時， 則會極大提高 WebGL 刷新性能，執行代碼如下
dm.each(function(data) { // 對“電話”進行批量 if (data.s('front.image') === 'assets/sos電話.png'){ data.s('batch', 'sosBatch'); } // 逃生通道批量（透明度也會影響性能） else if (data.s('all.color') === 'rgba(222,222,222,0.18)') { data.s('batch', 'emergencyBatch'); } else if (data.s('shape3d') === 'models/隧道/攝像頭.json' || data.s('shape3d') === 'models/隧道/橫洞.json' || data.s('shape3d') === 'models/隧道/捲簾門.json') { // 個別攝像頭染色了 不做批量 if(!data.s('shape3d.blend')) // 基礎批量什麼也不做 data.s('batch', 'basicBatch'); } else if (data.s('shape3d') === 'models/大型變壓器/變壓器.json') { data.s('batch', 'tileBatch'); data.setToolTip('單擊漫遊，雙擊車禍地點出現圖標'); } else if (data.getDisplayName() === '地面') { // 設置隧道“地面”不可選中 data.s('3d.selectable', false); } else if (data.s('shape3d') === 'models/隧道/排風.json') { // 排風扇的模型比較複雜，所以做批量 data.s('batch', 'fanBatch'); } else if (data.getDisplayName() === 'arrow') { // 隧道兩旁的箭頭路標 if (data.getTag() === 'arrowLeft') data.s('shape3d.image', 'displays/abc.png'); else data.s('shape3d.image', 'displays/abc2.png'); data.s({ 'shape3d': 'billboard', // 緩存，設置了 cache 的代價是需要設置 invalidateShape3dCachedImage 'shape3d.image.cache': true, // 設置這個值，圖片上的鋸齒就不會太明顯了（若圖片類型為 json，則設置 shape3d.dynamic.transparent) 'shape3d.transparent': true }); g3d.invalidateShape3dCachedImage(data); } // 隧道入口處的情報板 else if (data.getTag() === 'board' || data.getTag() === 'board1') { // 業務屬性，用來控制文本的位置[x,y,width,height] data.a('textRect', [0, 2, 244, 46]); // 業務屬性，設置文本內容 data.a('limitText', '限速80，請開車燈'); var min = -245; var name = 'board' + data.getId(); window[name] = setInterval(function() { // 設置情報板中的文字向左滾動，並且當文字全部显示時重複閃爍三次 circleFunc(data, window[name], min); }, 100); } //給逃生通道上方的指示板 動態設置顏色 var infos = ['人行橫洞1', '人行橫洞2', '人行橫洞3', '人行橫洞4', '車行橫洞1', '車行橫洞2', '車行橫洞3']; infos.forEach(function(info) { if(data.getDisplayName() === info) { data.a('emergencyColor', 'rgb(138, 138, 138)'); } }); infos = ['車道指示器', '車道指示器1', '車道指示器2', '車道指示器3']; infos.forEach(function(info) { if (data.getDisplayName() === info) { // 考慮到性能問題 將六面體變換為 billboard 類型元素 createBillboard(data, 'assets/車道信號-過.png', 'assets/車道信號-過.png', info); } }); });上面有一處設置了 tooltip 文字提示信息，在 3d 中，要显示這個文字提示信息，就需要設置 g3d.enableToolTip() 函數，默認 3d 組件是關閉這個功能的。
三、邏輯代碼
情報板滾動條 我就直接按照上面代碼中提到的方法進行解釋，首先是 circleFunc 情報板文字循環移動的函數，在這個函數中我們用到了業務屬性 limitText 設置情報板中的文字屬性以及 textRect 設置情報板中文字的移動位置屬性：// 設置情報板中的文字向左滾動，並且當文字全部显示時重複閃爍三次 function circleFunc(data, timer, min) { // 獲取當前業務屬性 limitText 的內容 var text = data.a('limitText'); // 設置業務屬性 textRect 文本框的坐標和大小 data.a('textRect', [data.a('textRect')[0]-5, 2, 244, 46]); if (parseInt(data.a('textRect')) <= parseInt(min)) { data.a('textRect', [255, 2, 244, 46]); } else if (data.a('textRect')[0] === 0) { clearInterval(timer); var index = 0; // 設置多個 timer 是因為能夠進入這個函數中的不止一個 data，如果在同一時間多個 data 設置同一個 timer，那肯定只會對最後一個節點進行動畫。後面還有很多這種陷阱，要注意 var testName = 'testTimer' + data.getId(); window[testName] = setInterval(function() { index++; // 如果情報板中文本內容為空 if(data.a('limitText') === '') { setTimeout(function() { // 設置為傳入的 text 值 data.a('limitText', text); }, 100); } else { setTimeout(function() { // 若情報板中的文本內容不為空，則設置為空 data.a('limitText', ''); }, 100); } // 重複三次 if(index === 11) { clearInterval(window[testName]); data.a('limitText', text); } }, 100); setTimeout(function() { timer = setInterval(function() { // 回調函數 circleFunc(data, timer, min); }, 100); }, 1500); } }由於 WebGL 對瀏覽器的要求不低，為了能盡量多的適應各大瀏覽器，我們將所有的“道路指示器” ht.Node 類型的六面體全部換成 billboard 類型的節點，性能能提升不少。
http://www.hightopo.com 設置 billboard 的方法很簡單，獲取當前的六面體節點，然後給這些節點設置：
node.s({ 'shape3d': 'billboard', 'shape3d.image': imageUrl, 'shape3d.image.cache': true }); // 還記得用 shape3d.image.cache 的代價么？ g3d.invalidateShape3dCachedImage(node);當然，因為 billboard 不能雙面显示不同的圖片，只是一個“面”，所以我們還得在這個節點的位置創建另一個節點，在這個節點的“背面”显示圖片，並且跟這個節點的配置一模一樣，不過位置要稍稍偏移一點。
Camera 緩慢偏移 其他動畫部分比較簡單，我就不在這裏多說了，這裡有一個雙擊節點能將視線從當前 camera 位置移動到雙擊節點正前方的位置的動畫我提一下。我封裝了兩個函數 setEye 和 setCenter，分別用來設置 camera 的位置和目標位置的：// 設置“目標”位置 function setCenter(center, finish) { // 獲取當前“目標”位置，為一個數組，而 getCenter 數組會在視線移動的過程中不斷變化，所以我們先拷貝一份 var c = g3d.getCenter().slice(0), // 當前x軸位置和目標位置的差值 dx = center[0] - c[0], dy = center[1] - c[1], dz = center[2] - c[2]; // 啟動 500 毫秒的動畫過度 ht.Default.startAnim({ duration: 500, action: function(v, t) { // 將“目標”位置緩慢從當前位置移動到設置的位置處 g3d.setCenter([ c[0] + dx * v, c[1] + dy * v, c[2] + dz * v ]); } }); }; // 設置“眼睛”位置 function setEye(eye, finish) { // 獲取當前“眼睛”位置，為一個數組，而 getEye 數組會在視線移動的過程中不斷變化，所以我們先拷貝一份 var e = g3d.getEye().slice(0), dx = eye[0] - e[0], dy = eye[1] - e[1], dz = eye[2] - e[2]; // 啟動 500 毫秒的動畫過度 ht.Default.startAnim({ duration: 500, // 將 Camera 位置緩慢地從當前位置移動到設置的位置 action: function(v, t) { g3d.setEye([ e[0] + dx * v, e[1] + dy * v, e[2] + dz * v ]); } }); };後期我們要設置的時候就直接調用這兩個函數，並設置參數為我們目標的位置即可。比如我這個場景中的各個模型，由於不同視角對應的各個模型的旋轉角度也不同，我只能找幾個比較有代表性的 0°，90°，180°以及360° 這四種比較典型的角度了。所以繪製 3D 場景的時候，我也盡量設置節點的旋轉角度為這四个中的一種（而且對於我們這個場景來說，基本上只在 y 軸上旋轉了）：
// 獲取事件對象的三維坐標 var p3 = e.data.p3(), // 獲取事件對象的三維尺寸 s3 = e.data.s3(), // 獲取事件對象的三維旋轉值 r3 = e.data.r3(); // 設置“目標”位置為當前事件對象的三維坐標值 setCenter(p3); // 如果節點的 y 軸旋轉值 不為 0 if (r3[1] !== 0) { // 浮點負數得做轉換才能進行比值 if (parseFloat(r3[1].toFixed(5)) === parseFloat(-3.14159)) { // 設置camera 的目標位置 setEye([p3[0], p3[1]+s3[1], p3[2] * Math.abs(r3[1]*2.3/6)]); } else if (parseFloat(r3[1].toFixed(4)) === parseFloat(-1.5708)) { setEye([p3[0] * Math.abs(r3[1]/1.8), p3[1]+s3[1], p3[2]]); } else { setEye([p3[0] *r3[1], p3[1]+s3[1], p3[2]]); } } else { setEye([p3[0], p3[1]+s3[1]*2, p3[2]+1000]); }
事故模擬現場 最後來說說模擬的事故現場吧，這段還是比較接近實際項目的。操作流程如下：雙擊“變壓器”–>隧道中間某個部分會出現一個“事故現場”圖標–>單擊圖標，彈出對話框，显示當前事故信息–>點擊確定，則事故現場之前的燈都显示為紅色×，並且隧道入口的情報板上的文字显示為“超車道兩車追尾，請減速慢行”–>再雙擊一次“變壓器”，場景恢復事故之前的狀態。 在 HT 中，可通過 Graph3dView#addInteractorListener（簡寫為 mi）來監聽交互過程：g3d.addInteractorListener(function(e) { if(e.kind === 'doubleClickData') { // 有“事故”圖標節點存在 if (e.data.getTag() === 'jam') return; // 如果雙擊對象是變壓器 if (e.data.s('shape3d') === 'models/大型變壓器/變壓器.json') { index++; // 通過唯一標識 tag 標籤獲取“事故”圖標節點對象 var jam = dm.getDataByTag('jam'); if(index === 1){ var jam = dm.getDataByTag('jam'); jam.s({ // 設置節點在 3d 上可見 '3d.visible': true, // 設置節點為 billboard 類型 'shape3d': 'billboard', // 設置 billboard 的显示圖片 'shape3d.image': 'assets/車禍.png', // 設置 billboard 圖片是否緩存 'shape3d.image.cache': true, // 是否始終面向鏡頭 'shape3d.autorotate': true, // 默認保持圖片原本大小，設置為數組模式則可以設置圖片显示在界面上的大小 'shape3d.fixSizeOnScreen': [30, 30], }); // cache 的代價是節點需要設置這個函數 g3d.invalidateShape3dCachedImage(jam); } else { jam.s({ // 第二次雙擊變壓器就將所有一切恢復“事故”之前的狀態 '3d.visible': false }); dm.each(function(data) { var p3 = data.p3(); if ((p3[2] < jam.p3()[2]) && data.getDisplayName() === '車道指示器1') { data.s('shape3d.image', 'assets/車道信號-過.png'); } if(data.getTag() === 'board1') { data.a('limitText', '限速80，請開車燈'); } }); index = 0; } } } });既然“事故”節點圖標出現了，接着點擊圖標出現“事故信息彈出框”，監聽事件同樣是在 mi（addInteractorListener）中，但是這次監聽的是單擊事件，我們知道，監聽雙擊事件時會觸發一次單擊事件，為了避免這種情況，我在單擊事件裏面做了演示：
// 點擊圖元 else if (e.kind === 'clickData'){ timer = setTimeout(function() { clearTimeout(timer); // 如果是“事故”圖標節點 if (e.data.getTag() === 'jam') { // 創建一個對話框 createDialog(e.data); } }, 200); }在上面的雙擊事件中我沒有 clearTimeout，怕順序問題給大家造成困擾，要記得加一下。 彈出框如下： 這個彈出框是由兩個 ht.widget.FormPane 表單構成的，左邊的表單隻有一行，行高為 140，右邊的表單是由 5 行構成的，點擊確定，則“事故”圖標節點之前的道路指示燈都換成紅色×的圖標：
// 彈出框右邊的表單 function createForm4(node, dialog) { // 表單組件 var form = new ht.widget.FormPane(); // 設置表單組件的寬 form.setWidth(200); // 設置表單組件的高 form.setHeight(200); // 獲取表單組件的底層 div var view = form.getView(); // 將表單組件添加到 body 中 document.body.appendChild(view); var infos = [ '編輯框內容為：2輛', '編輯框內容為：客車-客車', '編輯框內容為：無起火', '編輯框內容為：超車道' ]; infos.forEach(function(info) { // 向表單中添加行 form.addRow([ info // 第二個參數為行寬度，小於1的值為相對值 ], [0.1]); }); form.addRow([ { // 添加一行的“確認”按鈕 button: { label: '確認', // 按鈕點擊事件觸發 onClicked: function() { // 隱藏對話框 dialog.hide(); dm.each(function(data) { var p3 = data.p3(); // 改變“車道指示器”的显示圖片為紅色×，這裏我是根據“事故”圖標節點的坐標來判斷“車道显示器”是在前還是在後的 if ((p3[2] < node.p3()[2]) && data.getDisplayName() === '車道指示器1') { data.s('shape3d.image', 'assets/車道信號-禁止.png'); } // 將隧道口的情報板上的文字替換 if(data.getTag() === 'board1') { data.a('limitText', '超車道兩車追尾，請減速慢行'); } }); } } } ], [0.1]); return form; }
總結 伴隨着新基建的建設興起，是以新發展理念為引領，以技術創新為驅動，以信息網絡為基礎，面向高質量發展需要，提供数字轉型、智能升級、融合創新等服務的基礎設施體系的完備，國家正邁入新時代的建設，也迎來了新時代的挑戰與機遇。隧道交通的監控可以歸納為工控管理與智慧交通建設的產物，同樣具有極為重要的意義。在眾多行業上所積累的經驗，HT 已經實現了許多不同領域建設的案例，例如 路口監管可視化系統，有興趣的話也可以了解一下！ 2019 我們也更新了數百個工業互聯網 2D/3D 可視化案例集，在這裏你能發現許多新奇的實例，也能發掘出不一樣的工業互聯網： https://mp.weixin.qq.com/s/ZbhB6LO2kBRPrRIfHlKGQA 同時，你也可以查看更多案例及效果： https://www.hightopo.com/demos/index.html 本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理【其他文章推薦】
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線
※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整
※南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!
※教你寫出一流的銷售文案?
※超省錢租車方案
-
掌握SpringBoot-2.3的容器探針：實戰篇
歡迎訪問我的GitHub
https://github.com/zq2599/blog_demos
- 內容：原創文章分類匯總，及配套源碼，涉及Java、Docker、K8S、DevOPS等
經過多篇知識積累終於來到實戰章節，親愛的讀者們，請將裝備就位，一起動手體驗SpringBoot官方帶給我們的最新技術；
關於《SpringBoot-2.3容器化技術》系列
- 《SpringBoot-2.3容器化技術》系列，旨在和大家一起學習實踐2.3版本帶來的最新容器化技術，讓咱們的Java應用更加適應容器化環境，在雲計算時代依舊緊跟主流，保持競爭力；
- 全系列文章分為主題和輔助兩部分，主題部分如下：
- 《體驗SpringBoot(2.3)應用製作Docker鏡像(官方方案)》；
- 《詳解SpringBoot(2.3)應用製作Docker鏡像(官方方案)》；
- 《掌握SpringBoot-2.3的容器探針：基礎篇》；
- 《掌握SpringBoot-2.3的容器探針：深入篇》；
- 《掌握SpringBoot-2.3的容器探針：實戰篇》；
- 輔助部分是一些參考資料和備忘總結，如下：
- 《SpringBoot-2.3鏡像方案為什麼要做多個layer》；
- 《設置非root賬號不用sudo直接執行docker命令》；
- 《開發階段，將SpringBoot應用快速部署到K8S》；
SpringBoot-2.3容器探針知識點小結
經過前面的知識積累，我們知道了SpringBoot-2.3新增的探針規範以及適用場景，這裏做個簡短的回顧：
- kubernetes要求業務容器提供一個名為livenessProbe的地址，kubernetes會定時訪問該地址，如果該地址的返回碼不在200到400之間，kubernetes認為該容器不健康，會殺死該容器重建新的容器，這個地址就是存活探針；
- kubernetes要求業務容器提供一個名為readinessProbe的地址，kubernetes會定時訪問該地址，如果該地址的返回碼不在200到400之間，kubernetes認為該容器無法對外提供服務，不會把請求調度到該容器，這個地址就是就緒探針；
- SpringBoot的2.3.0.RELEASE發布了兩個新的actuator地址，/actuator/health/liveness和/actuator/health/readiness，前者用作存活探針，後者用作就緒探針，這兩個地址的返回值來自兩個新增的actuator：Liveness State和Readiness State；
- SpringBoot應用根據特殊環境變量是否存在來判定自己是否運行在容器環境，如果是，/actuator/health/liveness和/actuator/health/readiness這兩個地址就有返回碼，具體的值是和應用的狀態有對應關係的，例如應用啟動過程中，/actuator/health/readiness返回503，啟動成功后返回200；
- 業務應用可以通過Spring系統事件機制來讀取Liveness State和Readiness State，也可以訂閱這兩個actuator的變更事件；
- 業務應用可以通過Spring系統事件機制來修改Liveness State和Readiness State，此時/actuator/health/liveness和/actuator/health/readiness的返回值都會發生變更，從而影響kubernetes對此容器的行為（參照第一點和第二點），例如livenessProbe返回碼變成503，導致kubernetes認為容器不健康，從而殺死容器；
小結完畢，接下來開始實打實的編碼和操作實戰，驗證上述理論；
實戰環境信息
本次實戰有兩個環境：開發和運行環境，其中開發環境信息如下：
- 操作系統：Ubuntu 20.04 LTS 桌面版
- CPU ：2.30GHz × 4，內存：32G，硬盤：1T NVMe
- JDK：1.8.0_231
- MAVEN：3.6.3
- SpringBoot：2.3.0.RELEASE
- Docker：19.03.10
- 開發工具：IDEA 2020.1.1 (Ultimate Edition)
運行環境信息如下：
- 操作系統：CentOS Linux release 7.8.2003
- Kubernetes：1.15
事實證明，用Ubuntu桌面版作為開發環境是可行的，體驗十分順暢，IDEA、SubLime、SSH、Chrome、微信都能正常使用，下圖是我的Ubuntu開發環境：
實戰內容簡介
本次實戰包括以下內容：
- 開發SpringBoot應用，部署在kubernetes；
- 檢查應用狀態和kubernetes的pod狀態的關聯變化；
- 修改Readiness State，看kubernetes是否還會把請求調度到pod；
- 修改Liveness State，看kubernetes會不是殺死pod；
源碼下載
- 本次實戰用到了一個普通的SpringBoot工程，源碼可在GitHub下載到，地址和鏈接信息如下錶所示(https://github.com/zq2599/blog_demos)：
名稱 鏈接 備註 項目主頁 https://github.com/zq2599/blog_demos 該項目在GitHub上的主頁 git倉庫地址(https) https://github.com/zq2599/blog_demos.git 該項目源碼的倉庫地址，https協議 git倉庫地址(ssh) git@github.com:zq2599/blog_demos.git 該項目源碼的倉庫地址，ssh協議 - 這個git項目中有多個文件夾，本章的應用在probedemo文件夾下，如下圖紅框所示：
開發SpringBoot應用
- 請在IDEA上安裝lombok插件：
- 在IDEA上新建名為probedemo的SpringBoot工程，版本選擇2.3.0：
- 該工程的pom.xml內容如下，注意要有spring-boot-starter-actuator和lombok依賴，另外插件spring-boot-maven-plugin也要增加layers節點：
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.0.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.bolingcavalry</groupId> <artifactId>probedemo</artifactId> <version>0.0.1-SNAPSHOT</version> <name>probedemo</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <version>2.3.0.RELEASE</version> <!--該配置會在jar中增加layer描述文件，以及提取layer的工具--> <configuration> <layers> <enabled>true</enabled> </layers> </configuration> </plugin> </plugins> </build> </project>- 應用啟動類ProbedemoApplication是個最普通的啟動類：
package com.bolingcavalry.probedemo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class ProbedemoApplication { public static void main(String[] args) { SpringApplication.run(ProbedemoApplication.class, args); } }- 增加一個監聽類，可以監聽存活和就緒狀態的變化：
package com.bolingcavalry.probedemo.listener; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.availability.AvailabilityChangeEvent; import org.springframework.boot.availability.AvailabilityState; import org.springframework.context.event.EventListener; import org.springframework.stereotype.Component; /** * description: 監聽系統事件的類 <br> * date: 2020/6/4 下午12:57 <br> * author: willzhao <br> * email: zq2599@gmail.com <br> * version: 1.0 <br> */ @Component @Slf4j public class AvailabilityListener { /** * 監聽系統消息， * AvailabilityChangeEvent類型的消息都從會觸發此方法被回調 * @param event */ @EventListener public void onStateChange(AvailabilityChangeEvent<? extends AvailabilityState> event) { log.info(event.getState().getClass().getSimpleName() + " : " + event.getState()); } }- 增加名為StateReader的Controller的Controller，用於獲取存活和就緒狀態：
package com.bolingcavalry.probedemo.controller; import org.springframework.boot.availability.ApplicationAvailability; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import java.util.Date; @RestController @RequestMapping("/statereader") public class StateReader { @Resource ApplicationAvailability applicationAvailability; @RequestMapping(value="/get") public String state() { return "livenessState : " + applicationAvailability.getLivenessState() + "<br>readinessState : " + applicationAvailability.getReadinessState() + "<br>" + new Date(); } }- 增加名為StateWritter的Controller，用於設置存活和就緒狀態：
package com.bolingcavalry.probedemo.controller; import org.springframework.boot.availability.AvailabilityChangeEvent; import org.springframework.boot.availability.LivenessState; import org.springframework.boot.availability.ReadinessState; import org.springframework.context.ApplicationEventPublisher; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import java.util.Date; /** * description: 修改狀態的controller <br> * date: 2020/6/4 下午1:21 <br> * author: willzhao <br> * email: zq2599@gmail.com <br> * version: 1.0 <br> */ @RestController @RequestMapping("/staterwriter") public class StateWritter { @Resource ApplicationEventPublisher applicationEventPublisher; /** * 將存活狀態改為BROKEN（會導致kubernetes殺死pod） * @return */ @RequestMapping(value="/broken") public String broken(){ AvailabilityChangeEvent.publish(applicationEventPublisher, StateWritter.this, LivenessState.BROKEN); return "success broken, " + new Date(); } /** * 將存活狀態改為CORRECT * @return */ @RequestMapping(value="/correct") public String correct(){ AvailabilityChangeEvent.publish(applicationEventPublisher, StateWritter.this, LivenessState.CORRECT); return "success correct, " + new Date(); } /** * 將就緒狀態改為REFUSING_TRAFFIC（導致kubernetes不再把外部請求轉發到此pod） * @return */ @RequestMapping(value="/refuse") public String refuse(){ AvailabilityChangeEvent.publish(applicationEventPublisher, StateWritter.this, ReadinessState.REFUSING_TRAFFIC); return "success refuse, " + new Date(); } /** * 將就緒狀態改為ACCEPTING_TRAFFIC（導致kubernetes會把外部請求轉發到此pod） * @return */ @RequestMapping(value="/accept") public String accept(){ AvailabilityChangeEvent.publish(applicationEventPublisher, StateWritter.this, ReadinessState.ACCEPTING_TRAFFIC); return "success accept, " + new Date(); } }- 增加名為Hello的controller，此接口能返回當前pod的IP地址，在後面測試時會用到：
package com.bolingcavalry.probedemo.controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import java.net.Inet4Address; import java.net.InetAddress; import java.net.NetworkInterface; import java.net.SocketException; import java.util.ArrayList; import java.util.Date; import java.util.Enumeration; import java.util.List; /** * description: hello demo <br> * date: 2020/6/4 下午4:38 <br> * author: willzhao <br> * email: zq2599@gmail.com <br> * version: 1.0 <br> */ @RestController public class Hello { /** * 返回的是當前服務器IP地址，在k8s環境就是pod地址 * @return * @throws SocketException */ @RequestMapping(value="/hello") public String hello() throws SocketException { List<Inet4Address> addresses = getLocalIp4AddressFromNetworkInterface(); if(null==addresses || addresses.isEmpty()) { return "empty ip address, " + new Date(); } return addresses.get(0).toString() + ", " + new Date(); } public static List<Inet4Address> getLocalIp4AddressFromNetworkInterface() throws SocketException { List<Inet4Address> addresses = new ArrayList<>(1); Enumeration e = NetworkInterface.getNetworkInterfaces(); if (e == null) { return addresses; } while (e.hasMoreElements()) { NetworkInterface n = (NetworkInterface) e.nextElement(); if (!isValidInterface(n)) { continue; } Enumeration ee = n.getInetAddresses(); while (ee.hasMoreElements()) { InetAddress i = (InetAddress) ee.nextElement(); if (isValidAddress(i)) { addresses.add((Inet4Address) i); } } } return addresses; } /** * 過濾迴環網卡、點對點網卡、非活動網卡、虛擬網卡並要求網卡名字是eth或ens開頭 * @param ni 網卡 * @return 如果滿足要求則true，否則false */ private static boolean isValidInterface(NetworkInterface ni) throws SocketException { return !ni.isLoopback() && !ni.isPointToPoint() && ni.isUp() && !ni.isVirtual() && (ni.getName().startsWith("eth") || ni.getName().startsWith("ens")); } /** * 判斷是否是IPv4，並且內網地址並過濾迴環地址. */ private static boolean isValidAddress(InetAddress address) { return address instanceof Inet4Address && address.isSiteLocalAddress() && !address.isLoopbackAddress(); } }以上就是該SpringBoot工程的所有代碼了，請確保可以編譯運行；
製作Docker鏡像
- 在pom.xml所在目錄創建文件Dockerfile，內容如下：
# 指定基礎鏡像，這是分階段構建的前期階段 FROM openjdk:8u212-jdk-stretch as builder # 執行工作目錄 WORKDIR application # 配置參數 ARG JAR_FILE=target/*.jar # 將編譯構建得到的jar文件複製到鏡像空間中 COPY ${JAR_FILE} application.jar # 通過工具spring-boot-jarmode-layertools從application.jar中提取拆分后的構建結果 RUN java -Djarmode=layertools -jar application.jar extract # 正式構建鏡像 FROM openjdk:8u212-jdk-stretch WORKDIR application # 前一階段從jar中提取除了多個文件，這裏分別執行COPY命令複製到鏡像空間中，每次COPY都是一個layer COPY --from=builder application/dependencies/ ./ COPY --from=builder application/spring-boot-loader/ ./ COPY --from=builder application/snapshot-dependencies/ ./ COPY --from=builder application/application/ ./ ENTRYPOINT ["java", "org.springframework.boot.loader.JarLauncher"]- 先編譯構建工程，執行以下命令：
mvn clean package -U -DskipTests- 編譯成功后，通過Dockerfile文件創建鏡像：
sudo docker build -t bolingcavalry/probedemo:0.0.1 .- 鏡像創建成功：
SpringBoot的鏡像準備完畢，接下來要讓kubernetes環境用上這個鏡像；
將鏡像加載到kubernetes環境
此時的鏡像保存在開發環境的電腦上，可以有以下三種方式加載到kubernetes環境：
- push到私有倉庫，kubernetes上使用時也從私有倉庫獲取；
- push到hub.docker.com，kubernetes上使用時也從hub.docker.com獲取，目前我已經將此鏡像push到hub.docker.com，您在kubernetes直接使用即可，就像nginx、tomcat這些官方鏡像一樣下載；
- 在開發環境執行docker save bolingcavalry/probedemo:0.0.1 > probedemo.tar，可將此鏡像另存為本地文件，再scp到kubernetes服務器，再在kubernetes服務器執行docker load < /root/temp/202006/04/probedemo.tar就能加載到kubernetes服務器的本地docker緩存中；
以上三種方法的優缺點整理如下：
- 首推第一種，但是需要您搭建私有倉庫；
- 由於springboot-2.3官方對鏡像構建作了優化，第二種方法也就執行第一次的時候上傳和下載很耗時，之後修改java代碼重新構建時，不論上傳還是下載都很快（只上傳下載某個layer）；
- 在開發階段，使用第三種方法最為便捷，但如果kubernetes環境有多台機器，就不合適了，因為鏡像是存在指定機器的本地緩存的；
我的kubernetes環境只有一台電腦，因此用的是方法三，參考命令如下(建議安裝sshpass，就不用每次輸入帳號密碼了)：
# 將鏡像保存為tar文件 sudo docker save bolingcavalry/probedemo:0.0.1 > probedemo.tar # scp到kubernetes服務器 sshpass -p 888888 scp ./probedemo.tar root@192.168.50.135:/root/temp/202006/04/ # 遠程執行ssh命令，加載docker鏡像 sshpass -p 888888 ssh root@192.168.50.135 "docker load < /root/temp/202006/04/probedemo.tar"kubernetes部署deployment和service
- 在kubernetes創建名為probedemo.yaml的文件，內容如下，注意pod副本數是2，另外請關注livenessProbe和readinessProbe的參數配置：
apiVersion: v1 kind: Service metadata: name: probedemo spec: type: NodePort ports: - port: 8080 nodePort: 30080 selector: name: probedemo --- apiVersion: extensions/v1beta1 kind: Deployment metadata: name: probedemo spec: replicas: 2 template: metadata: labels: name: probedemo spec: containers: - name: probedemo image: bolingcavalry/probedemo:0.0.1 tty: true livenessProbe: httpGet: path: /actuator/health/liveness port: 8080 initialDelaySeconds: 5 failureThreshold: 10 timeoutSeconds: 10 periodSeconds: 5 readinessProbe: httpGet: path: /actuator/health/readiness port: 8080 initialDelaySeconds: 5 timeoutSeconds: 10 periodSeconds: 5 ports: - containerPort: 8080 resources: requests: memory: "512Mi" cpu: "100m" limits: memory: "1Gi" cpu: "500m"- 執行命令kubectl apply -f probedemo..yaml，即可創建deployment和service：
- 這裏要重點關注的是livenessProbe的initialDelaySeconds和failureThreshold參數，initialDelaySeconds等於5，表示pod創建5秒后檢查存活探針，如果10秒內應用沒有完成啟動，存活探針不返回200，就會重試10次(failureThreshold等於10)，如果重試10次后存活探針依舊無法返回200，該pod就會被kubernetes殺死重建，要是每次啟動都耗時這麼長，pod就會不停的被殺死重建；
- 執行命令kubectl apply -f probedemo.yaml，創建deployment和service，如下圖，可見在第十秒的時候pod創建成功，但是此時還未就緒：
- 繼續查看狀態，創建一分鐘后兩個pod終於就緒：
- 用kubectl describe命令查看pod狀態，事件通知显示存活和就緒探針都有失敗情況，不過因為有重試，因此後來狀態會變為成功：
至此，從編碼到部署都完成了，接下來驗證SpringBoot-2.3.0.RELEASE的探針技術；
驗證SpringBoot-2.3.0.RELEASE的探針技術
- 監聽類AvailabilityListener的作用是監聽狀態變化，看看pod日誌，看AvailabilityListener的代碼是否有效，如下圖紅框，在應用啟動階段AvailabilityListener被成功回調，打印了存活和就緒狀態：
-
kubernetes所在機器的IP地址是192.168.50.135，因此SpringBoot服務的訪問地址是http://192.168.50.135:30080/xxx
-
訪問地址http://192.168.50.135:30080/actuator/health/liveness，返回碼如下圖紅框，可見存活探針已開啟：
- 就緒探針也正常：
- 打開兩個瀏覽器，都訪問：http://192.168.50.135:30080/hello，多次Ctrl+F5強刷，如下圖，很快就能得到不同結果，證明響應來自不同的Pod：
- 訪問：http://192.168.50.135:30080/statereader/get，可以得到存活和就緒的狀態，可見StateReader的代碼已經生效，可以通過ApplicationAvailability接口取得狀態：
- 修改就緒狀態，訪問：http://192.168.50.135:30080/statewriter/refuse，如下圖紅框，可見收到請求的pod，其就緒狀態已經出現了異常，證明StateWritter.java中修改就緒狀態后，可以讓kubernetes感知到這個pod的異常：
- 用瀏覽器反覆強刷hello接口，返回的Pod地址也只有一個，證明只有一個Pod在響應請求：
- 嘗試恢復服務，注意請求要在服務器後台發送，而且IP地址要用剛才被設置為refuse的pod地址：
curl http://10.233.90.195:8080/statewriter/accept- 如下圖，狀態已經恢復：
- 最後再來試試將存活狀態從CORRECT改成BROKEN，瀏覽器訪問：http://192.168.50.135:30080/statewriter/broken
- 如下圖紅框，重啟次數變成1，表示pod被殺死了一次，並且由於重啟導致當前還未就緒，證明在SpringBoot中修改了存活探針的狀態，是會觸發kubernetes殺死pod的：
- 等待pod重啟、就緒探針正常后，一切恢復如初：
- 強刷瀏覽器，如下圖紅框，兩個Pod都能正常響應：
官方忠告
- 至此，《掌握SpringBoot-2.3的容器探針》系列就全部完成了，從理論到實踐，咱們一起學習了SpringBoot官方帶給我們的容器化技術，最後以一段官方忠告來結尾，大家一起將此忠告牢記在心：
- 我對以上內容的理解：選擇外部系統的服務作為探針的時候要謹慎（外部系統可能是數據庫，也可能是其他web服務），如果外部系統出現問題，會導致kubernetes殺死pod(存活探針問題)，或者導致kubernetes不再調度請求到pod(就緒探針問題)；（再請感謝大家容忍我的英語水平）
歡迎關注我的公眾號：程序員欣宸
https://github.com/zq2599/blog_demos
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!
※網頁設計公司推薦不同的風格，搶佔消費者視覺第一線
※Google地圖已可更新顯示潭子電動車充電站設置地點!!
※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益
※別再煩惱如何寫文案,掌握八大原則!
※網頁設計最專業,超強功能平台可客製化
- 內容：原創文章分類匯總，及配套源碼，涉及Java、Docker、K8S、DevOPS等
-
10萬以下產品力最強的兩款SUV！詳解風神AX5和遠景SUV！
未來肯定不能以價格取勝。那麼要考慮的就是要從質量與技術可靠為主了。而且有了AX7在前面擋着，未來AX5隻要在宣傳上做得出色，未來還是可以期待的。而遠景SUV換裝了全新的家族式造型設計，與吉利汽車其他車型有了很好的延續性。
目前SUV市場非常紅火，但對於國內的消費者來說；他們很多時候對SUV的購車預算大多數會考慮在10萬以下的車型，而這個區間最火熱的要屬最火熱的遠景SUV了。遠景SUV作為一款上市多年的車型，憑藉著良好的口碑與超高的性價比在三四線城市當中一直都受到追捧。其他品牌看它這麼紅火，肯定心有不甘；醞釀着推出競品與其競爭。在這個背景下，東風風神AX5應該是與它最接近的一款車型了。總結：AX5作為市場的新丁，未來要遇到的挑戰很多；首先它目前的市場肯可度比較一般，而且相對性價比較高的遠景SUV來說，價格相對高一些；未來肯定不能以價格取勝。那麼要考慮的就是要從質量與技術可靠為主了；而且有了AX7在前面擋着，未來AX5隻要在宣傳上做得出色，未來還是可以期待的。
而遠景SUV換裝了全新的家族式造型設計，與吉利汽車其他車型有了很好的延續性。但它的車尾卻與前臉不太協調，但改款之後提價的策略也被不少消費者詬病；這是吉利急需要改變的不好影響。當然目前吉利汽車一系列熱門車型會把整個市場口碑營造上去，但遠景SUV卻不能以此為傲。雖不說前有前敵，但肯定後邊會有不少追兵。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，台北網頁設計公司幫您達到更多曝光效益
※教你寫出一流的銷售文案?