台灣電動巴士廠商車王電與華德動能宣布，兩家公司將就電動公車展開智慧車聯網技術的研發工作，推出商務行動辦公室，最快在今年第四季就可量產。台灣、中國大陸與東南亞國家都是市場目標。
車王電董事長蔡裕慶表示，電動車結合車聯網的模式，未來將席捲全球，因此車王電與華德動能合作，整合端、網、雲系統，所涉及的技術包括：車載通訊、行動影音娛樂、先進駕駛安全輔助（ADAS）與行車管理等系統，推出專為電動巴士所設計的完整車聯網系統平台。
蔡裕慶表示，電動巴士加車聯網的全新營運模式，初期將會以台灣本土市場為主要目標，未來也會嘗試進入中國大陸、印度、香港、新加坡、越南等更多市場。他也指出，車王電與華德動能的合作主要在平台整合，進入各地市場之際，還會根據各市場的需求打造不同車體。
藉著智慧化車聯網平台方案，蔡裕慶估計每輛車輛的售價將可提高一至二成。他認為，車用電子市場潛力龐大，車聯網與綠能都是未來發展的主要潮流。
本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
注意：
先備份數據，在備份的數據表的基礎上進行分表，不直接操作原始表!
將源數據表備份一份，依次將對應年份的數據歸檔，每成功歸檔一次，就將備份數據表中對應數據刪除（目的減少查詢數據量），最後根據備份表最小 ID，刪除源數據表 小於 ID 的所有數據。
該步驟可以直接通過 SQL 執行，也可通過腳本執行。
腳本執行
刪除源數據表數據操作，建議通過手動執行 SQL完成，其他操作通過腳本執行
以積分日誌表 tb_user_points_log 為例
備份 tb_user_points_log 得到 tb_user_points_copy
將數據表 tb_user_points_copy 2016 年的數據歸檔存入 2016 年數據表 tb_user_points_log_2016
CREATE TABLE tb_user_points_log_2016 LIKE tb_user_points_log_copy;
INSERT INTO tb_user_points_log_2016 SELECT * FROM tb_user_points_log_copy WHERE add_time < 1483200000;
對比數量
SELECT COUNT(id) FROM tb_user_points_log_2016;
SELECT COUNT(id) FROM tb_user_points_log_copy WHERE add_time < 1483200000;
一致則刪除 tb_user_points_copy 的 2016 年數據
DELETE FROM tb_user_points_log_copy WHERE add_time < 1483200000;
將數據表 tb_user_points_copy 2017 年的數據歸檔存入 2017 年數據表 tb_user_points_log_2017
CREATE TABLE tb_user_points_log_2017 LIKE tb_user_points_log_copy;
INSERT INTO tb_user_points_log_2017 SELECT * FROM tb_user_points_log_copy WHERE add_time < 1514736000;
對比數量
SELECT COUNT(id) FROM tb_user_points_log_2017;
SELECT COUNT(id) FROM tb_user_points_log_copy WHERE add_time < 1514736000;
一致則刪除 tb_user_points_copy 的 2017 年數據
DELETE FROM tb_user_points_log_copy WHERE add_time < 1514736000;
將數據表 tb_user_points_copy 2018 年的數據歸檔存入 2018 年數據表 tb_user_points_log_2018
CREATE TABLE tb_user_points_log_2018 LIKE tb_user_points_log_copy;
INSERT INTO tb_user_points_log_2018 SELECT * FROM tb_user_points_log_copy WHERE add_time < 1546272000;
對比數量
SELECT COUNT(id) FROM tb_user_points_log_2018;
SELECT COUNT(id) FROM tb_user_points_log_copy WHERE add_time < 1546272000;
一致則刪除 tb_user_points_copy 的 2018 年數據
DELETE FROM tb_user_points_copy WHERE add_time < 1546272000;
現在是 11 月，將 5 月之前的數據歸檔
CREATE TABLE tb_user_points_log_2019 LIKE tb_user_points_log_copy;
INSERT INTO tb_user_points_log_2019 SELECT * FROM tb_user_points_log_copy WHERE add_time < 1556640000;
對比數量
SELECT COUNT(id) FROM tb_user_points_log_2019;
SELECT COUNT(id) FROM tb_user_points_log_copy WHERE add_time < 1556640000;
一致則刪除 tb_user_points_copy 的 2019 年 5 月之前的數據
DELETE FROM tb_user_points_log_copy WHERE add_time < 1556640000;
根據最小 tb_user_points_copy 的最小 ID，刪除原始表 小於 ID 的所有數據
DELETE FROM tb_user_points_log WHERE id < (SELECT id FROM tb_user_points_log_copy ORDER BY id asc LIMIT 1);
刪除臨時表
DELETE FROM tb_user_points_log_copy;
數據表分表完成！
增量歸檔
每日凌晨，執行腳本將最近半年之前的數據歸檔
<?php
/**
* Description: 將6個月前數據歸檔
*/
namespace wladmin\cmd;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\Db;
class DataArchiving extends Command
{
protected function configure()
{
$this->setName('DataArchiving')->setDescription('將6個月前數據歸檔');
}
/**
* 將6個月前數據歸檔
* php think DataArchiving
* @param Input $input
* @param Output $output
*
* @return int|void|null
*/
protected function execute(Input $input, Output $output)
{
try {
$this->archiveData('tb_user_points_log', 'id', 'add_time');
$this->archiveData('tb_order_recharge', 'or_id', 'create_time');
$this->archiveData('tb_order_recharge_do', 'ord_id', 'create_time');
echo '歸檔完成';
} catch (\Exception $e) {
mylog($e->getMessage(),'歸檔發生錯誤:'.PHP_EOL);
}
}
/**
* 歸檔數據表
* @param string $sourceTable 源數據表名
* @param string $primaryKey 主鍵名
* @param string $timeKey 時間鍵名
*
* @author Dong.cx 2019-11-18 18:05
* @version V4.0.1
*/
private function archiveData($sourceTable, $primaryKey, $timeKey)
{
try {
date_default_timezone_set('PRC');
// 1.複製源數據表
$copyTable = $sourceTable . '_copy';
$isExist = $this->tableExist($copyTable, $sourceTable);
if (!$isExist) {
echo "開始複製源數據表{$copyTable}" . PHP_EOL;
$archivingTimeLine = time();
$sql = "INSERT IGNORE INTO {$copyTable} SELECT * FROM {$sourceTable} WHERE {$timeKey} < {$archivingTimeLine}";
Db::execute($sql);
echo "複製源數據表{$copyTable}完成" . PHP_EOL;
}
echo "{$copyTable} 開始歸檔" . PHP_EOL;
// 歸檔
$this->archive(2016, $sourceTable, $primaryKey, $timeKey);
$this->archive(2017, $sourceTable, $primaryKey, $timeKey);
$this->archive(2018, $sourceTable, $primaryKey, $timeKey);
$this->archive(2019, $sourceTable, $primaryKey, $timeKey);
echo "{$copyTable} 歸檔完成";
} catch (\Exception $e) {
echo '歸檔發生錯誤:' . $e->getMessage() .PHP_EOL;
}
}
/**
* 歸檔操作
* @param int $year 年份
* @param string $sourceTable 源數據表名
* @param string $primaryKey 主鍵名
* @param string $timeKey 時間鍵名
*
* @return bool
* @throws \Exception
* @author Dong.cx 2019-11-18 18:12
* @version V4.0.1
*/
private function archive($year, $sourceTable, $primaryKey, $timeKey)
{
try {
$copyTable = $sourceTable . '_copy';
echo "{$copyTable} 開始歸檔{$year}年數據--->" . PHP_EOL;
if ($year == date('Y')) {
// 注意現在是 11月份,可以簡單這樣寫,如果是小於6月,則要相應修改
$archivingTimeLine = strtotime('-6 month', strtotime('today'));
} else {
$archivingTimeLine = mktime(0,0,0,1,1,$year+1);
}
$sql = "SELECT COUNT({$primaryKey}) as num FROM {$copyTable} WHERE {$timeKey} < {$archivingTimeLine}";
$res = Db::query($sql);
if (!$res || !$res[0]['num']) {
echo "{$copyTable} {$year}年數據歸檔完成,未查詢到需要歸檔的數據" . PHP_EOL;
return true;
}
// 需歸檔數量
$targetNum = $res[0]['num'];
// 歸檔表名
$tableArchivingName = $sourceTable . '_' . $year;
$this->tableExist($tableArchivingName, $sourceTable);
// 分批歸檔
$this->archivingBatch($tableArchivingName, $copyTable, $primaryKey,$timeKey, $archivingTimeLine, $year, $targetNum);
return true;
} catch (\Exception $e) {
throw $e;
}
}
/**
* 分批歸檔
* @param string $tableArchivingName 歸檔表名稱
* @param string $copyTable 複製表名
* @param string $primaryKey 主鍵名
* @param string $timeKey 時間鍵
* @param int $archivingTimeLine 歸檔時間線
* @param string $year 歸檔年
* @param int $targetNum 需歸檔的數據量
*
* @throws \Exception
* @author Dong.cx 2019-11-19 13:10
* @version V4.0.1
*/
private function archivingBatch($tableArchivingName, $copyTable, $primaryKey,$timeKey, $archivingTimeLine, $year, $targetNum)
{
// 歸檔表起始ID
$res = Db::query("SELECT {$primaryKey} FROM {$tableArchivingName} ORDER BY {$primaryKey} DESC LIMIT 1");
$startID = $res ? $res[0][$primaryKey] : 0;
$totalDelNum = 0;
$batchNum = 10000;
$taskNum = ceil($targetNum/$batchNum);
$minID = Db::query("SELECT {$primaryKey} FROM {$copyTable} ORDER BY {$primaryKey} ASC LIMIT 1");
if (!$minID) throw new \Exception('$minID為空!');
$minID = $minID[0][$primaryKey];
$maxID = Db::query("SELECT {$primaryKey} FROM {$copyTable} WHERE {$timeKey} < {$archivingTimeLine} ORDER BY {$primaryKey} DESC LIMIT 1");
if (!$maxID) throw new \Exception('$max 為空!');
$maxID = $maxID ? $maxID[0][$primaryKey] : 0;
for ($i = 1; $i <= $taskNum; $i++) {
if ($i == $taskNum) {
// 歸檔
$sql = "INSERT IGNORE INTO {$tableArchivingName} SELECT * FROM {$copyTable} WHERE {$primaryKey} <= {$maxID} AND {$timeKey} < {$archivingTimeLine}";
Db::execute($sql);
// 刪除
$sql = "DELETE FROM {$copyTable} WHERE {$primaryKey} <= {$maxID} AND {$timeKey} < {$archivingTimeLine}";
$totalDelNum += Db::execute($sql);
} else {
$end = $minID + $i * $batchNum;
// 歸檔
$sql = "INSERT IGNORE INTO {$tableArchivingName} SELECT * FROM {$copyTable} WHERE {$primaryKey} <= {$end} AND {$timeKey} < {$archivingTimeLine}";
Db::execute($sql);
// 刪除
$sql = "DELETE FROM {$copyTable} WHERE {$primaryKey} <= {$end} AND {$timeKey} < {$archivingTimeLine}";
$totalDelNum += Db::execute($sql);
}
}
// 成功歸檔數據量
$num = Db::query("SELECT COUNT({$primaryKey}) as num FROM {$tableArchivingName} WHERE {$primaryKey} > {$startID}")[0]['num'];
if ($targetNum != $num) throw new \Exception("歸檔數據不一致,過期數據量{$targetNum},歸檔量{$num},刪除量{$totalDelNum}");
if ($num != $totalDelNum) throw new \Exception("刪除數據不一致,歸檔量{$num},刪除量{$totalDelNum}");
echo "{$copyTable} {$year}年數據歸檔完成,過期數據量{$targetNum},歸檔量{$num},刪除量{$totalDelNum}" . PHP_EOL;
// 刪除源數據表數據
//echo "開始刪除源數據表 {$sourceTable}已歸檔數據" . PHP_EOL；
//$num = Db::execute("DELETE FROM {$sourceTable} WHERE {$primaryKey} < (SELECT id FROM {$copyTable} ORDER BY {$primaryKey} asc LIMIT 1)");
//echo "源數據表 {$sourceTable}已歸檔數據刪除完成,刪除數據量{$num}" . PHP_EOL；
//echo "開始刪除臨時表 {$copyTable}" . PHP_EOL；
// 刪除臨時表
//Db::execute("DELETE FROM {$copyTable}");
//echo "臨時表{$copyTable}刪除完成" . PHP_EOL;
}
最後由於是要刪除源數據表，屬於敏感操作，(腳本最後註釋部分) 建議再複查一次數據歸檔正確性，確認無誤后，手動執行 SQL操作。
DELETE FROM {$sourceTable} WHERE {$primaryKey} < (SELECT {$primaryKey} FROM {$copyTable} ORDER BY {$primaryKey} asc LIMIT 1;
DELETE FROM {$copyTable};
<?php
/**
* Description: 將6個月前數據歸檔
*/
namespace wladmin\cmd;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\Db;
class DataArchiving extends Command
{
protected function configure()
{
$this->setName('DataArchiving')->setDescription('將6個月前數據歸檔');
}
/**
* 將6個月前數據歸檔
* php think DataArchiving
* @param Input $input
* @param Output $output
*
* @return int|void|null
*/
protected function execute(Input $input, Output $output)
{
try {
$this->archiveDataEveryDay('tb_user_points_log', 'id', 'add_time');
$this->archiveDataEveryDay('tb_order_recharge', 'or_id', 'create_time');
$this->archiveDataEveryDay('tb_order_recharge_do', 'ord_id', 'create_time');
echo '歸檔完成';
} catch (\Exception $e) {
mylog($e->getMessage(),'歸檔發生錯誤:'.PHP_EOL);
}
}
/**
* 歸檔數據
* @param string $sourceTable 源數據表名
* @param string $primaryKey 源數據表主鍵名
* @param string $timeKey 時間控制鍵名
*
* @return bool
* @throws \Exception
* @author Dong.cx 2019-11-15 18:36
* @version V4.0.1
*/
private function archiveDataEveryDay($sourceTable, $primaryKey, $timeKey)
{
try {
//mylog("{$sourceTable} 開始歸檔".PHP_EOL);
// 歸檔時間線
$archivingTimeLine = strtotime('-6 month', strtotime('today'));
// 歸檔表的年份
$year = date('Y', $archivingTimeLine);
// 歸檔表名
$tableArchivingName = $sourceTable . '_' . $year;
// 需要歸檔的數據量
$sql = "SELECT COUNT({$primaryKey}) as num FROM {$sourceTable} WHERE {$timeKey} < {$archivingTimeLine}";
$res = Db::query($sql);
// 沒有需要歸檔的,直接返回
if (!$res) {
mylog("{$sourceTable} 歸檔完成,未查詢到需要歸檔的數據");
return true;
}
$count = $res[0]['num'];
// 檢測數據表是否存在,不存在則創建
$this->tableExist($tableArchivingName, $sourceTable);
$sql = "INSERT IGNORE INTO {$tableArchivingName} SELECT * FROM {$sourceTable} WHERE {$timeKey} < {$archivingTimeLine}";
// 1.開始歸檔
// 歸檔表起始ID
$res = Db::query("SELECT {$primaryKey} FROM {$tableArchivingName} ORDER BY {$primaryKey} DESC LIMIT 1");
$startID = $res ? $res[0][$primaryKey] : 0;
Db::execute($sql);
// 成功歸檔數據量
$num = Db::query("SELECT COUNT({$primaryKey}) as num FROM {$tableArchivingName} WHERE {$primaryKey} > {$startID}")[0]['num'];
if ($count != $num) throw new \Exception("歸檔數據不一致,過期數據量{$count},歸檔量{$num}");
$lastID = Db::query("SELECT {$primaryKey} FROM {$tableArchivingName} ORDER BY {$primaryKey} DESC LIMIT 1")[0][$primaryKey];
// 2.刪除源數據
$sql = "DELETE FROM {$sourceTable} WHERE {$primaryKey} <= {$lastID} AND {$timeKey} < {$archivingTimeLine}";
$delNum = Db::execute($sql);
if ($delNum != $count) throw new \Exception("刪除數據不一致,過期數據量{$count},刪除量{$delNum}");
//mylog("{$sourceTable} 歸檔完成,過期數據量{$count},歸檔量{$count},刪除量{$delNum}" . PHP_EOL);
return true;
} catch (\Exception $e) {
Db::rollback();
throw $e;
}
}
/**
* 檢測數據表是否存在,不存在則創建
* @param $table
* @param $likeTable
*/
private function tableExist($table, $likeTable)
{
$sql = "SHOW TABLES LIKE '{$table}'";
$isExist = Db::query($sql);
if (!$isExist) {
Db::execute("CREATE TABLE {$table} LIKE {$likeTable}");
}
}
}
在數據訪問層中根據需要查詢時間 動態修改數據表名即可
這裏使用的是 thinkphp Query 類中的 setTable() 和 getTable()
if (isset($params['history']) && !empty($params['history'])) {
$this->model()->setTable($this->model()->getTable().'_'.$params['history']);
}
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
摘錄自2020年3月22日聯合報報導
中歐國家克羅埃西亞今天（22日）上午遭遇規模5.3地震襲擊，鄰國斯洛維尼亞隨後表示，境內唯一一座位在克斯科（Krsko）的克斯科核電廠（NEK）並未受到影響。
克斯科核電廠是斯洛維尼亞（Slovenia）和克羅埃西亞共有。斯洛維尼亞核子安全局長塞奇（Igor Sirc）在地震後表示：「這座核電廠持續以全產能運作。」但當局已展開正常預防程序，對核電廠的系統與設備進行檢查
克羅埃西亞首都薩格勒布（Zagreb）北方發生規模5.3強震，引發人們奔逃上街，並造成建築物損害、車輛遭崩塌的瓦礫掩埋，還發生多起火警。
核能
災害
能源議題
土地水文
國際新聞
克羅埃西亞
斯洛維尼亞
地震
核電廠
本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
據海外媒體報導稱福特計畫推出一款全新新能源車型，其很有可能會命名為Model E。
福特公司把這款Model E定位於一款緊湊車型，這款車會推出混動、插電式混動以及純電動版本，主要取代的是純電動版福克斯以及混動版和插電式混動版C-MAX。
另外，福特公司將會投資16億美元的資金，在墨西哥San Luis Potosi建設全新的工廠，並且這款Model E也將會在這座工廠生產。這款車將在2018年正式亮相，在2019年投放市場。
本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
Spring Security是一個功能強大且高度可定製的身份驗證和訪問控制框架，它是用於保護基於Spring的應用程序的實際標準。
Spring Security是一個框架，致力於為Java應用程序提供身份驗證和授權。與所有Spring項目一樣，Spring Security的真正強大之處在於可以輕鬆擴展以滿足自定義要求。
更多信息可以查看官網：https://spring.io/projects/spring-security
新建一個SpringBoot的web項目spring-boot-security。
pom文件中不引入Spring Security，然後新建一個controller：
@RestController
public class AppController {
@GetMapping("/hello")
public String hello() {
return "Hello,spring security!";
}
}然後打開瀏覽器訪問：http://localhost:8080/hello，成功后返回：
Hello,spring security!pom文件中引入Spring Security的starter：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>打開瀏覽器再次訪問http://localhost:8080/hello，會被重定向到登錄頁http://localhost:8080/login，截圖如下：
要登錄系統，我們需要知道用戶名和密碼，Spring Security默認的用戶名是user，項目啟動的時候會生成默認密碼（在啟動日誌中可以看到），輸入用戶名和密碼后就可以訪問/hello接口了。
當然也可以自定義用戶名密碼，在配置文件添加如下內容即可：
spring.security.user.name=java_suisui
spring.security.user.password=123456上面說過Spring Security的功能有“認證”和“授權”，下面通過一個簡單的例子實現下自定義的認證和授權。
假設系統中有兩個角色：
按照下面步驟操作即可。
對於用戶名、密碼、登錄頁面、訪問權限等都可以在 WebSecurityConfigurerAdapter 的實現類中配置。
WebSecurityConfig代碼如下：
/**
* 配置類
* @Author java_suisui
*
*/
@EnableWebSecurity
@Configuration
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
@Override
protected void configure(AuthenticationManagerBuilder auth) throws Exception {
//配置內存中的 用戶名、密碼和角色
auth.inMemoryAuthentication().passwordEncoder(new MyPasswordEncoder()).withUser("user").password("123456").roles("USER");
auth.inMemoryAuthentication().passwordEncoder(new MyPasswordEncoder()).withUser("admin").password("123456").roles("ADMIN");
}
@Override
protected void configure(HttpSecurity http) throws Exception {
http.authorizeRequests()
.antMatchers("/login").permitAll()
.antMatchers("/user").hasRole("USER") //訪問 /user這個接口，需要有USER角色
.antMatchers("/admin").hasRole("ADMIN")
.anyRequest().authenticated() //剩餘的其他接口，登錄之後就能訪問
.and()
.formLogin().defaultSuccessUrl("/hello");
}
}內存用戶驗證時，Spring Boot 2.0以上版本引用的security 依賴是 spring security 5.X版本，此版本需要提供一個PasswordEncorder的實例。
MyPasswordEncoder代碼如下：
public class MyPasswordEncoder implements PasswordEncoder {
@Override
public String encode(CharSequence rawPassword) {
return rawPassword.toString();
}
@Override
public boolean matches(CharSequence rawPassword, String encodedPassword) {
return encodedPassword.equals(rawPassword);
}
}瀏覽器打開http://localhost:8080/login，
如果使用user登錄后訪問/admin，會報403錯誤，具體錯誤信息如下：
Whitelabel Error Page
This application has no explicit mapping for /error, so you are seeing this as a fallback.
Tue Nov 19 16:26:28 CST 2019
There was an unexpected error (type=Forbidden, status=403).
Forbidden結果和我們預期的一致，說明簡單的自定義認證和授權功能已經實現了。
完整源碼地址：
推薦閱讀
Java碎碎念，一個堅持原創的公眾號，為您提供一系列系統架構、微服務、Java、SpringBoot、SpringCloud等高質量技術文章。
如果覺得文章不錯，希望可以隨手轉發或者”在看“哦，非常感謝哈！
關注下方公眾號后回復「1024」，有驚喜哦！
本文由博客一文多發平台 發布！
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
1 apiVersion: v1 #必選，版本號，例如v1,版本號必須可以用 kubectl api-versions 查詢到 2 kind: Pod #必選，Pod 3 metadata: #必選，元數據 4 name: string #必選，Pod名稱，需符合RFC 1035規範 5 namespace: string #必選，Pod所屬的命名空間，默認為"default" 6 labels: #自定義標籤 7 - name: string #自定義標籤名字 8 annotations: #自定義註釋列表 9 - name: string 10 spec: #必選，Pod中容器的詳細定義 11 containers: #必選，Pod中容器列表 12 - name: string #必選，容器名稱，需符合RFC 1035規範 13 image: string #必選，容器的鏡像名稱 14 imagePullPolicy: [ Always|Never|IfNotPresent ] #獲取鏡像的策略，Alawys表示每次都嘗試下載鏡像，IfnotPresent表示優先使用本地鏡像,否則下載鏡像，Nerver表示僅使用本地鏡像 15 command: [string] #容器的啟動命令列表，如不指定，使用打包時使用的啟動命令 16 args: [string] #容器的啟動命令參數列表 17 workingDir: string #容器的工作目錄 18 volumeMounts: #掛載到容器內部的存儲卷配置 19 - name: string #引用pod定義的共享存儲卷的名稱，需用volumes[]部分定義的的卷名 20 mountPath: string #存儲卷在容器內mount的絕對路徑，應少於512字符 21 readOnly: boolean #是否為只讀模式，默認為讀寫模式 22 ports: #需要暴露的端口庫號列表 23 - name: string #端口的名稱 24 containerPort: int #容器需要監聽的端口號 25 hostPort: int #容器所在主機需要監聽的端口號，默認與Container相同 26 protocol: string #端口協議，支持TCP和UDP，默認TCP 27 env: #容器運行前需設置的環境變量列表 28 - name: string #環境變量名稱 29 value: string #環境變量的值 30 resources: #資源限制和請求的設置 31 limits: #資源限制的設置 32 cpu: string #CPU的限制，單位為core數，將用於docker run --cpu-shares參數 33 memory: string #內存限制，單位可以為Mib/Gib，將用於docker run --memory參數 34 requests: #資源請求的設置 35 cpu: string #CPU請求，容器啟動的初始可用數量 36 memory: string #內存請求,容器啟動的初始可用數量 37 livenessProbe: #對Pod內各容器健康檢查的設置，當探測無響應幾次后將自動重啟該容器，檢查方法有exec、httpGet和tcpSocket，對一個容器只需設置其中一種方法即可 38 exec: #對Pod容器內檢查方式設置為exec方式 39 command: [string] #exec方式需要制定的命令或腳本 40 httpGet: #對Pod內個容器健康檢查方法設置為HttpGet，需要制定Path、port 41 path: string 42 port: number 43 host: string 44 scheme: string 45 HttpHeaders: 46 - name: string 47 value: string 48 tcpSocket: #對Pod內個容器健康檢查方式設置為tcpSocket方式 49 port: number 50 initialDelaySeconds: 0 #容器啟動完成后首次探測的時間，單位為秒 51 timeoutSeconds: 0 #對容器健康檢查探測等待響應的超時時間，單位秒，默認1秒 52 periodSeconds: 0 #對容器監控檢查的定期探測時間設置，單位秒，默認10秒一次 53 successThreshold: 0 54 failureThreshold: 0 55 securityContext: 56 privileged: false 57 restartPolicy: [Always | Never | OnFailure] #Pod的重啟策略，Always表示一旦不管以何種方式終止運行，kubelet都將重啟，OnFailure表示只有Pod以非0退出碼退出才重啟，Nerver表示不再重啟該Pod 58 nodeSelector: obeject #設置NodeSelector表示將該Pod調度到包含這個label的node上，以key：value的格式指定 59 imagePullSecrets: #Pull鏡像時使用的secret名稱，以key：secretkey格式指定 60 - name: string 61 hostNetwork: false #是否使用主機網絡模式，默認為false，如果設置為true，表示使用宿主機網絡 62 volumes: #在該pod上定義共享存儲卷列表 63 - name: string #共享存儲卷名稱 （volumes類型有很多種） 64 emptyDir: {} #類型為emtyDir的存儲卷，與Pod同生命周期的一個臨時目錄。為空值 65 hostPath: string #類型為hostPath的存儲卷，表示掛載Pod所在宿主機的目錄 66 path: string #Pod所在宿主機的目錄，將被用於同期中mount的目錄 67 secret: #類型為secret的存儲卷，掛載集群與定義的secre對象到容器內部 68 scretname: string 69 items: 70 - key: string 71 path: string 72 configMap: #類型為configMap的存儲卷，掛載預定義的configMap對象到容器內部 73 name: string 74 items: 75 - key: string 76 path: string
Pod可以由1個或多個容器組合而成，通常對於緊耦合的兩個應用，應該組合成一個整體對外提供服務，則應該將這兩個打包為一個pod。
屬於一個Pod的多個容器應用之間相互訪問只需要通過localhost即可通信，這一組容器被綁定在一個環境中。
1 [root@k8smaster01 study]# vi frontend-localredis-pod.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: redis-php 6 label: 7 name: redis-php 8 spec: 9 containers: 10 - name: frontend 11 image: kubeguide/guestbook-php-frontend:localredis 12 ports: 13 - containersPort: 80 14 - name: redis-php 15 image: kubeguide/redis-master 16 ports: 17 - containersPort: 6379 18 19 [root@k8smaster01 study]# kubectl create -f frontend-localredis-pod.yaml 20
1 [root@k8smaster01 study]# kubectl get pods #READY為2/2，表示此Pod中運行了yaml定義的兩個容器 2 NAME READY STATUS RESTARTS AGE 3 redis-php 2/2 Running 0 7m45s 4 [root@k8smaster01 study]# kubectl describe pod redis-php #查看詳細信息 5
靜態pod是由kubelet進行管理的僅存在於特定Node的Pod上，他們不能通過API Server進行管理，無法與ReplicationController、Deployment或者DaemonSet進行關聯，並且kubelet無法對他們進行健康檢查。靜態Pod總是由kubelet進行創建，並且總是在kubelet所在的Node上運行。
創建靜態Pod有兩種方式：配置文件或者HTTP方式。
1 [root@k8snode01 ~]# mkdir -p /etc/kubelet.d 2 [root@k8snode01 ~]# vi /etc/kubelet.d/static-web.yaml 3 apiVersion: v1 4 kind: Pod 5 metadata: 6 name: static-web 7 label: 8 name: static-web 9 spec: 10 containers: 11 - name: static-web 12 image: nginx 13 ports: 14 - name: web 15 containersPort: 80 16 17 [root@k8snode01 ~]# vi /etc/systemd/system/kubelet.service 18 …… 19 --config=/etc/kubelet.d/ \· #加入此參數 20 …… 21 [root@k8snode01 ~]# systemctl daemon-reload 22 [root@k8snode01 ~]# systemctl restart kubelet.service #重啟kubelet 23 [root@k8snode01 ~]# docker ps #查看創建的pod
提示：由於靜態pod不能通過API Server進行管理，因此在Master節點執行刪除操作後會變為Pending狀態，且無法刪除。刪除該pod只能在其運行的node上，將定義POD的yaml刪除。
通過設置kubelet的啟動參數–mainfest-url，會定期從該URL下載Pod的定義文件，並以.yaml或.json文件的格式進行解析，從而創建Pod。
在同一個Pod中的多個容器能夠共享Pod級別的存儲就Volume。Volume可以被定義為各種類型，多個容器各自進行掛載操作，將一個Volume掛載為容器內部需要的目錄。
示例1：
Pod級別設置Volume “app-logs”，同時Pod包含兩個容器，Tomcat向該Volume寫日誌，busybox讀取日誌文件。
1 [root@k8smaster01 study]# vi pod-volume-applogs.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: volume-pod 6 spec: 7 containers: 8 - name: tomcat 9 image: tomcat 10 ports: 11 - containerPort: 8080 12 volumeMounts: 13 - name: app-logs 14 mountPath: /usr/local/tomcat/logs 15 - name: logreader 16 image: busybox 17 command: ["sh","-c","tail -f /logs/catalina*.log"] 18 volumeMounts: 19 - name: app-logs 20 mountPath: /logs 21 volumes: 22 - name: app-logs 23 emptyDir: {}
解釋：
Volume名：app-logs；
emptyDir：為Pod分配到Node的時候創建。無需指定宿主機的目錄文件，為Kubernetes自動分配的目錄。
1 [root@k8smaster01 study]# kubectl create -f pod-volume-applogs.yaml #創建 2 [root@k8smaster01 study]# kubectl get pods #查看 3 [root@k8smaster01 study]# kubectl logs volume-pod -c busybox #讀取log
1 [root@k8smaster01 study]# kubectl exec -it volume-pod -c tomcat -- ls /usr/local/tomcat/logs 2 catalina.2019-06-29.log localhost_access_log.2019-06-29.txt 3 host-manager.2019-06-29.log manager.2019-06-29.log 4 localhost.2019-06-29.log 5 [root@k8smaster01 study]# kubectl exec -it volume-pod -c tomcat -- tail /usr/local/tomcat/logs/catalina.2019-06-29.log
提示：通過tomcat容器可查看日誌，對比busybox通過共享Volume查看的日誌是否一致。
應用部署的一個最佳實踐是將應用所需的配置信息與程序進行分離，使程序更加靈活。將相應的應用打包為鏡像，可以通過環境變量或者外掛volume的方式在創建容器的時候進行配置注入，從而實現更好的復用。
Kubernetes提供一種統一的應用配置管理方案：ConfigMap。
ConfigMap供容器使用的主要場景：
ConfigMap以一個或多個key:value的形式定義。value可以是string也可以是一個文件內容，可以通過yaml配置文件或者通過kubectl create configmap 的方式創建configMap。
1 [root@k8smaster01 study]# vi cm-appvars.yaml 2 apiVersion: v1 3 kind: ConfigMap 4 metadata: 5 name: cm-appvars 6 data: 7 apploglevel: info 8 appdatadir: /var/data 9 10 [root@k8smaster01 study]# kubectl create -f cm-appvars.yaml 11 configmap/cm-appvars created 12 [root@k8smaster01 study]# kubectl get configmaps 13 NAME DATA AGE 14 cm-appvars 2 8s 15 [root@k8smaster01 study]# kubectl describe configmaps cm-appvars
1 [root@k8smaster01 study]# kubectl get configmaps cm-appvars -o yaml
語法1
1 # kubectl create configmap NAME --from-file=[key=]source --from-file=[key=]source
解釋：通過–from-file參數從文件中創建，可以指定key名稱，也可以制定多個key。
語法2
1 # kubectl create configmap NAME --from-file=config-files-dir
解釋：通過–from-file參數從目錄中創建，該目錄下的每個配置文件名都被設置為key，文件的內容被設置為value。
語法3
1 # kubectl create configmap NAME --from-literal=key1=value1 --from-literal=key2=value2
解釋：通過–from-literal參數從文本中創建，直接將指定的key#=value#創建為ConfigMap的內容。
容器應用使用ConfigMap有兩種方式：
1 [root@k8smaster01 study]# vi cm-test-pod.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: cm-test-pod 6 spec: 7 containers: 8 - name: cm-test 9 image: busybox 10 command: ["/bin/sh","-c","env|grep APP"] #容器里執行查看環境變量的命令 11 env: 12 - name: APPLOGLEVEL #定義容器環境變量名稱 13 valueFrom: 14 configMapKeyRef: #環境變量的值來自ConfigMap 15 name: cm-appvars #指定來自cm-appvars的ConfigMap 16 key: apploglevel #key為apploglevel 17 - name: APPDATADIR 18 valueFrom: 19 configMapKeyRef: 20 name: cm-appvars 21 key: appdatadir 22 23 [root@k8smaster01 study]# kubectl create -f cm-test-pod.yaml 24 [root@k8smaster01 study]# kubectl get pods 25 NAME READY STATUS RESTARTS AGE 26 cm-test-pod 0/1 Completed 2 24s
【掛載形式-待補充】
pod擁有唯一的名字、IP地址，並且處於某個Namespace中。pod的容器內獲取pod的信息科通過Downward API實現。具體有以下兩種方式：
舉例1：通過Downward API將Pod的IP、名稱和所在的Namespace注入容器的環境變量。
1 [root@k8smaster01 study]# vi dapi-test-pod.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: dapi-test-pod 6 spec: 7 containers: 8 - name: test-container 9 image: busybox 10 command: [ "/bin/sh", "-c", "env" ] 11 env: 12 - name: MY_POD_NAME 13 valueFrom: 14 fieldRef: 15 fieldPath: metadata.name 16 - name: MY_POD_NAMESPACE 17 valueFrom: 18 fieldRef: 19 fieldPath: metadata.namespace 20 - name: MY_POD_IP 21 valueFrom: 22 fieldRef: 23 fieldPath: status.podIP 24 restartPolicy: Never
提示：Downward API提供如下變量：
metadata.name：Pod的名稱，當Pod通過RC生成時，其名稱是RC隨機產生的唯一名稱；
status.podIP：Pod的IP地址，POd的IP屬於狀態數據，而非元數據；
metadata.namespace：Pod所在的namespace。
1 [root@k8smaster01 study]# kubectl create -f dapi-test-pod.yaml 2 [root@k8smaster01 study]# kubectl logs dapi-test-pod | grep MY_POD 3 MY_POD_NAMESPACE=default 4 MY_POD_IP=172.30.240.4 5 MY_POD_NAME=dapi-test-pod 6
舉例2：通過Downward API將Container的自願請求和限制信息注入容器的環境變量。
1 [root@k8smaster01 study]# vi dapi-test-pod-container-vars.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: dapi-test-pod-container-vars 6 spec: 7 containers: 8 - name: test-container 9 image: busybox 10 imagePullPolicy: Never 11 command: [ "/bin/sh", "-c" ] 12 args: 13 - while true; do 14 echo -en '\n'; 15 printenv MY_CPU_REQUEST MY_CPU_LIMIT; 16 printenv MY_MEM_REQUEST MY_MEM_LIMIT; 17 sleep 3600; 18 done; 19 resources: 20 requests: 21 memory: "32Mi" 22 cpu: "125m" 23 limits: 24 memory: "64Mi" 25 cpu: "250m" 26 env: 27 - name: MY_CPU_REQUEST 28 valueFrom: 29 resourceFieldRef: 30 containerName: test-container 31 resource: requests.cpu 32 - name: MY_CPU_LIMIT 33 valueFrom: 34 resourceFieldRef: 35 containerName: test-container 36 resource: limits.cpu 37 - name: MY_MEM_REQUEST 38 valueFrom: 39 resourceFieldRef: 40 containerName: test-container 41 resource: requests.memory 42 - name: MY_MEM_LIMIT 43 valueFrom: 44 resourceFieldRef: 45 containerName: test-container 46 resource: limits.memory 47 restartPolicy: Never
提示：Downward API提供如下變量：
requests.cpu：容器的CPU請求值；
limits.cpu：容器的CPU限制值；
requests.memory：容器的內存請求值；
limits.memory：容器的內存限制值。
1 [root@k8smaster01 study]# kubectl create -f dapi-test-pod-container-vars.yaml 2 [root@k8smaster01 study]# kubectl logs dapi-test-pod-container-vars 3 1 4 1 5 33554432 6 67108864
舉例3：通過Downward API將Pod的Label、Annotation列表通過Volume掛載為容器內的一個文件。
1 [root@k8smaster01 study]# vi dapi-test-pod-volume.yaml 2 apiVersion: v1 3 kind: Pod 4 metadata: 5 name: dapi-test-pod-volume 6 labels: 7 zone: us-est-coast 8 cluster: test-cluster1 9 rack: rack-22 10 annotations: 11 build: two 12 builder: john-doe 13 spec: 14 containers: 15 - name: test-container 16 image: busybox 17 imagePullPolicy: Never 18 command: [ "/bin/sh", "-c" ] 19 args: 20 - while true; do 21 if [[ -e /etc/labels ]]; then 22 echo -en '\n\n'; cat /etc/labels; fi; 23 if [[ -e /etc/annotations ]]; then 24 echo -en '\n\n'; cat /etc/annotations; fi; 25 sleep 3600; 26 done; 27 volumeMounts: 28 - name: podinfo 29 mountPath: /etc 30 readOnly: false 31 volumes: 32 - name: podinfo 33 downwardAPI: 34 items: 35 - path: "labels" 36 fieldRef: 37 fieldPath: metadata.labels 38 - path: "annotations" 39 fieldRef: 40 fieldPath: metadata.annotations
注意：Volume中的ddownwardAPI的items語法，將會以path的名稱生成文件。如上所示，會在容器內生產/etc/labels和/etc/annotations兩個文件，分別包含metadata.labels和metadata.annotations的全部Label。
1 [root@k8smaster01 study]# kubectl create -f dapi-test-pod-volume.yaml 2 [root@k8smaster01 study]# kubectl logs dapi-test-pod-volume 3
提示：DownwardAPI意義：
在某些集群中，集群中的每個節點需要將自身的標識（ID）及進程綁定的IP地址等信息事先寫入配置文件中，進程啟動時讀取此類信息，然後發布到某個類似註冊服務中心。此時可通過DowanwardAPI，將一個預啟動腳本或Init Container，通過環境變量或文件方式獲取Pod自身的信息，然後寫入主程序配置文件中，最後啟動主程序。本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
學習Netty也有一段時間了，Netty作為一個高性能的異步框架，很多RPC框架也運用到了Netty中的知識，在rpc框架中豐富的數據協議及編解碼可以讓使用者更加青睞；
Netty支持豐富的編解碼框架，其本身內部提供的編解碼也可以應對各種業務場景；
今天主要就是學習下Netty中提供的編、解碼類，之前只是簡單的使用了下Netty提供的解碼類，今天更加深入的研究下Netty中編、解碼的源碼及部分使用。
編碼（Encoder）
編碼就是將我們發送的數據編碼成字節數組方便在網絡中進行傳輸，類似Java中的序列化，將對象序列化成字節傳輸解碼（Decoder）
解碼和編碼相反，將傳輸過來的字節數組轉化為各種對象來進行展示等，類似Java中的反序列化
如：
// 將字節數組轉化為字符串
new String(byte bytes[], Charset charset)ByteToMessageDecoder: 解碼超類，將字節轉換成消息
解碼解碼一般用於將獲取到的消息解碼成系統可識別且自己需要的數據結構；因此ByteToMessageDecoder需要繼承ChannelInboundHandlerAdapter入站適配器來獲取到入站的數據，在handler使用之前通過channelRead獲取入站數據進行一波解碼；通過channelRead獲取入站數據，將數據緩存至cumulation數據緩衝區，最後在傳給decode進行解碼，在read完成之後清空緩存的數據
1. 獲取入站數據
/**
* 通過重寫channelRead方法來獲取入站數據
*/
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
// 檢測是否是byteBuf對象格式數據
if (msg instanceof ByteBuf) {
// 實例化字節解碼成功輸出集合 即List<Object> out
CodecOutputList out = CodecOutputList.newInstance();
try {
// 獲取到的請求的數據
ByteBuf data = (ByteBuf) msg;
// 如果緩衝數據區為空則代表是首次觸發read方法
first = cumulation == null;
if (first) {
// 如果是第一次read則當前msg數據為緩衝數據
cumulation = data;
} else {
// 如果不是則觸發累加，將緩衝區的舊數據和新獲取到的數據通過 expandCumulation 方法累加在一起存入緩衝區cumulation
// cumulator 累加類，將緩衝池中數據和新數據進行組合在一起
// private Cumulator cumulator = MERGE_CUMULATOR;
cumulation = cumulator.cumulate(ctx.alloc(), cumulation, data);
}
// 將緩衝區數據cumulation進行解碼
callDecode(ctx, cumulation, out);
} catch (DecoderException e) {
throw e;
} catch (Throwable t) {
throw new DecoderException(t);
} finally {
// 在解碼完畢后釋放引用和清空全局字節緩衝區
if (cumulation != null && !cumulation.isReadable()) {
numReads = 0;
cumulation.release();
cumulation = null;
// discardAfterReads為netty中設置的讀取多少次后開始丟棄字節 默認值16
// 可通過setDiscardAfterReads(int n)來設置值不設置默認16次
} else if (++ numReads >= discardAfterReads) {
// We did enough reads already try to discard some bytes so we not risk to see a OOME.
// 在我們讀取了足夠的數據可以嘗試丟棄一些字節已保證不出現內存溢出的異常
//
// See https://github.com/netty/netty/issues/4275
// 讀取次數重置為0
numReads = 0;
// 重置讀寫指針或丟棄部分已讀取的字節
discardSomeReadBytes();
}
// out為解碼成功的傳遞給下一個handler
int size = out.size();
decodeWasNull = !out.insertSinceRecycled();
// 結束當前read傳遞到下個ChannelHandler
fireChannelRead(ctx, out, size);
// 回收響應集合 將insertSinceRecycled設置為false；
// insertSinceRecycled用於channelReadComplete判斷使用
out.recycle();
}
} else {
// 不是的話直接fire傳遞給下一個handler
ctx.fireChannelRead(msg);
}
}
public static final Cumulator MERGE_CUMULATOR = new Cumulator() {
/**
* alloc ChannelHandlerContext分配的字節緩衝區
* cumulation 當前ByteToMessageDecoder類全局的字節緩衝區
* in 入站的字節緩衝區
**/
@Override
public ByteBuf cumulate(ByteBufAllocator alloc, ByteBuf cumulation, ByteBuf in) {
final ByteBuf buffer;
// 如果全局ByteBuf寫入的字節+當前入站的字節數據大於全局緩衝區最大的容量或者全局緩衝區的引用數大於1個或全局緩衝區只讀
if (cumulation.writerIndex() > cumulation.maxCapacity() - in.readableBytes()
|| cumulation.refCnt() > 1 || cumulation.isReadOnly()) {
// Expand cumulation (by replace it) when either there is not more room in the buffer
// or if the refCnt is greater then 1 which may happen when the user use slice().retain() or
// duplicate().retain() or if its read-only.
//
// See:
// - https://github.com/netty/netty/issues/2327
// - https://github.com/netty/netty/issues/1764
// 進行擴展全局字節緩衝區（容量大小 = 新數據追加到舊數據末尾組成新的全局字節緩衝區）
buffer = expandCumulation(alloc, cumulation, in.readableBytes());
} else {
buffer = cumulation;
}
// 將新數據寫入緩衝區
buffer.writeBytes(in);
// 釋放當前的字節緩衝區的引用
in.release();
return buffer;
}
};
/**
* alloc 字節緩衝區操作類
* cumulation 全局累加字節緩衝區
* readable 讀取到的字節數長度
*/
// 字節緩衝區擴容方法
static ByteBuf expandCumulation(ByteBufAllocator alloc, ByteBuf cumulation, int readable) {
// 舊數據
ByteBuf oldCumulation = cumulation;
// 通過ByteBufAllocator將緩衝區擴大到oldCumulation + readable大小
cumulation = alloc.buffer(oldCumulation.readableBytes() + readable);
// 將舊數據重新寫入到新的字節緩衝區
cumulation.writeBytes(oldCumulation);
// 舊字節緩衝區引用-1
oldCumulation.release();
return cumulation;
}@Override
public boolean release() {
return release0(1);
}
@Override
public boolean release(int decrement) {
return release0(checkPositive(decrement, "decrement"));
}
/**
* decrement 減量
*/
private boolean release0(int decrement) {
for (;;) {
int refCnt = this.refCnt;
// 當前引用小於減量
if (refCnt < decrement) {
throw new IllegalReferenceCountException(refCnt, -decrement);
}
// 這裏就利用里線程併發中的知識CAS，線程安全的設置refCnt的值
if (refCntUpdater.compareAndSet(this, refCnt, refCnt - decrement)) {
// 如果減量和引用量相等
if (refCnt == decrement) {
// 全部釋放
deallocate();
return true;
}
return false;
}
}
}4. 將全局字節緩衝區進行解碼
/**
* ctx ChannelHandler的上下文，用於傳輸數據與下一個handler來交互
* in 入站數據
* out 解析之後的出站集合 （此出站不是返回給客戶端的而是傳遞給下個handler的）
*/
protected void callDecode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
try {
// 如果入站數據還有沒解析的
while (in.isReadable()) {
// 解析成功的出站集合長度
int outSize = out.size();
// 如果大於0則說明解析成功的數據還沒被消費完，直接fire掉給通道中的後續handler繼續 消費
if (outSize > 0) {
fireChannelRead(ctx, out, outSize);
out.clear();
// Check if this handler was removed before continuing with decoding.
// 在這個handler刪除之前檢查是否還在繼續解碼
// If it was removed, it is not safe to continue to operate on the buffer.
// 如果移除了，它繼續操作緩衝區是不安全的
//
// See:
// - https://github.com/netty/netty/issues/4635
if (ctx.isRemoved()) {
break;
}
outSize = 0;
}
// 入站數據字節長度
int oldInputLength = in.readableBytes();
// 開始解碼數據
decodeRemovalReentryProtection(ctx, in, out);
// Check if this handler was removed before continuing the loop.
//
// If it was removed, it is not safe to continue to operate on the buffer.
//
// See https://github.com/netty/netty/issues/1664
if (ctx.isRemoved()) {
break;
}
// 解析完畢跳出循環
if (outSize == out.size()) {
if (oldInputLength == in.readableBytes()) {
break;
} else {
continue;
}
}
if (oldInputLength == in.readableBytes()) {
throw new DecoderException(
StringUtil.simpleClassName(getClass()) +
".decode() did not read anything but decoded a message.");
}
if (isSingleDecode()) {
break;
}
}
} catch (DecoderException e) {
throw e;
} catch (Throwable cause) {
throw new DecoderException(cause);
}
}
final void decodeRemovalReentryProtection(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
// 設置解碼狀態為正在解碼 STATE_INIT = 0; STATE_CALLING_CHILD_DECODE = 1; STATE_HANDLER_REMOVED_PENDING = 2; 分別為初始化； 解碼； 解碼完畢移除
decodeState = STATE_CALLING_CHILD_DECODE;
try {
// 具體的解碼邏輯（netty提供的解碼器或自定義解碼器中重寫的decode方法）
decode(ctx, in, out);
} finally {
// 此時decodeState為正在解碼中 值為1，返回false
boolean removePending = decodeState == STATE_HANDLER_REMOVED_PENDING;
// 在設置為初始化等待解碼
decodeState = STATE_INIT;
// 解碼完成移除當前ChannelHandler標記為不處理
// 可以看看handlerRemoved源碼。如果緩衝區還有數據直接傳遞給下一個handler
if (removePending) {
handlerRemoved(ctx);
}
}
}@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
// 讀取次數重置
numReads = 0;
// 重置讀寫index
discardSomeReadBytes();
// 在channelRead meth中定義賦值 decodeWasNull = !out.insertSinceRecycled();
// out指的是解碼集合List<Object> out; 咱們可以點進
if (decodeWasNull) {
decodeWasNull = false;
if (!ctx.channel().config().isAutoRead()) {
ctx.read();
}
}
// fire掉readComplete傳遞到下一個handler的readComplete
ctx.fireChannelReadComplete();
}
/**
* 然後我們可以搜索下insertSinceRecucled在什麼地方被賦值了
* Returns {@code true} if any elements where added or set. This will be reset once {@link #recycle()} was called.
*/
boolean insertSinceRecycled() {
return insertSinceRecycled;
}
// 搜索下insert的調用我們可以看到是CodecOutputList類即為channelRead中的out集合，眾所周知在 decode完之後，解碼數據就會被調用add方法，此時insertSinceRecycled被設置為true
private void insert(int index, Object element) {
array[index] = element;
insertSinceRecycled = true;
}
/**
* 清空回收數組內部的所有元素和存儲空間
* Recycle the array which will clear it and null out all entries in the internal storage.
*/
// 搜索recycle的調用我么可以知道在channelRead的finally邏輯中 調用了out.recycle();此時 insertSinceRecycled被設置為false
void recycle() {
for (int i = 0 ; i < size; i ++) {
array[i] = null;
}
clear();
insertSinceRecycled = false;
handle.recycle(this);
}
至此ByteToMessageDecoder解碼類應該差不多比較清晰了！！！
MessageToByteEncoder: 編碼超類，將消息轉成字節進行編碼發出
何謂編碼，就是將發送數據轉化為客戶端和服務端約束好的數據結構和格式進行傳輸，我們可以在編碼過程中將消息體body的長度和一些頭部信息有序的設置到ByteBuf字節緩衝區中；方便解碼方靈活的運用來判斷（是否完整的包等）和處理業務；解碼是繼承入站數據，反之編碼應該繼承出站的數據；接下來我們看看編碼類是怎麼進行編碼的；既然是繼承出站類，我們直接看看write方法是怎麼樣的
/**
* 通過write方法獲取到出站的數據即要發送出去的數據
* ctx channelHandler上下文
* msg 發送的數據 Object可以通過繼承類指定的泛型來指定
* promise channelPromise異步監聽，類似ChannelFuture，只不過promise可以設置監聽的結果，future只能通過獲取監聽的成功失敗結果；可以去了解下promise和future的區別
*/
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
ByteBuf buf = null;
try {
// 檢測發送數據的類型 通過TypeParameterMatcher類型匹配器
if (acceptOutboundMessage(msg)) {
@SuppressWarnings("unchecked")
I cast = (I) msg;
// 分配字節緩衝區 preferDirect默認為true
buf = allocateBuffer(ctx, cast, preferDirect);
try {
// 進行編碼
encode(ctx, cast, buf);
} finally {
// 完成編碼后釋放對象的引用
ReferenceCountUtil.release(cast);
}
// 如果緩衝區有數據則通過ctx發送出去，promise可以監聽數據傳輸並設置是否完成
if (buf.isReadable()) {
ctx.write(buf, promise);
} else {
// 如果沒有數據則釋放字節緩衝區的引用併發送一個empty的空包
buf.release();
ctx.write(Unpooled.EMPTY_BUFFER, promise);
}
buf = null;
} else {
// 非TypeParameterMatcher類型匹配器匹配的類型直接發送出去
ctx.write(msg, promise);
}
} catch (EncoderException e) {
throw e;
} catch (Throwable e) {
throw new EncoderException(e);
} finally {
if (buf != null) {
buf.release();
}
}
}
// 初始化設置preferDirect為true
protected MessageToByteEncoder() {
this(true);
}
protected MessageToByteEncoder(boolean preferDirect) {
matcher = TypeParameterMatcher.find(this, MessageToByteEncoder.class, "I");
this.preferDirect = preferDirect;
}編碼： 重寫encode方法，根據實際業務來進行數據編碼
// 此處就是我們需要重寫的編碼方法了，我們和根據約束好的或者自己定義好想要的數據格式發送給對方
// 下面是我自己寫的demo的編碼方法；頭部設置好body的長度，服務端可以根據長度來判斷是否是完整的包，僅僅自學寫的簡單的demo非正常線上運營項目的邏輯
public class MyClientEncode extends MessageToByteEncoder<String> {
@Override
protected void encode(ChannelHandlerContext ctx, String msg, ByteBuf out) throws Exception {
if (null != msg) {
byte[] request = msg.getBytes(Charset.forName("UTF-8"));
out.writeInt(request.length);
out.writeBytes(request);
}
}
}編碼類相對要簡單很多，因為只需要將發送的數據序列化，按照一定的格式進行發送數據！！！
項目實戰
項目主要簡單的實現下自定義編解碼器的運用及LengthFieldBasedFrameDecoder的使用
│ hetangyuese-netty-06.iml
│ pom.xml
│
├─src
│ ├─main
│ │ ├─java
│ │ │ └─com
│ │ │ └─hetangyuese
│ │ │ └─netty
│ │ │ ├─client
│ │ │ │ MyClient06.java
│ │ │ │ MyClientChannelInitializer.java
│ │ │ │ MyClientDecoder.java
│ │ │ │ MyClientEncode.java
│ │ │ │ MyClientHandler.java
│ │ │ │ MyMessage.java
│ │ │ │
│ │ │ └─server
│ │ │ MyChannelInitializer.java
│ │ │ MyServer06.java
│ │ │ MyServerDecoder.java
│ │ │ MyServerDecoderLength.java
│ │ │ MyServerEncoder.java
│ │ │ MyServerHandler.java
│ │ │
│ │ └─resources
│ └─test
│ └─java
Serverhandler: 只是簡單的將解碼的內容輸出
public class MyServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("客戶端連接成功 time: " + new Date().toLocaleString());
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
System.out.println("客戶端斷開連接 time: " + new Date().toLocaleString());
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
String body = (String) msg;
System.out.println("content:" + body);
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
// 出現異常關閉通道
cause.printStackTrace();
ctx.close();
}
}解碼器
public class MyServerDecoder extends ByteToMessageDecoder {
// 此處我頭部只塞了長度字段佔4個字節，別問為啥我知道，這是要客戶端和服務端約束好的
private static int min_head_length = 4;
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
// 解碼的字節長度
int size = in.readableBytes();
if(size < min_head_length) {
System.out.println("解析的數據長度小於頭部長度字段的長度");
return ;
}
// 讀取的時候指針已經移位到長度字段的尾端
int length = in.readInt();
if (size < length) {
System.out.println("解析的數據長度與長度不符合");
return ;
}
// 上面已經讀取到了長度字段，後面的長度就是body
ByteBuf decoderArr = in.readBytes(length);
byte[] request = new byte[decoderArr.readableBytes()];
// 將數據寫入空數組
decoderArr.readBytes(request);
String body = new String(request, Charset.forName("UTF-8"));
out.add(body);
}
}將解碼器加入到channelHandler中：記得加到業務handler的前面否則無效
public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline()
// .addLast(new MyServerDecoderLength(10240, 0, 4, 0, 0))
// .addLast(new LengthFieldBasedFrameDecoder(10240, 0, 4, 0, 0))
.addLast(new MyServerDecoder())
.addLast(new MyServerHandler())
;
}
}ClientHandler
public class MyClientHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("與服務端連接成功");
for (int i = 0; i<10; i++) {
ctx.writeAndFlush("hhhhh" + i);
}
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
System.out.println("與服務端斷開連接");
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println("收到服務端消息:" +msg+ " time: " + new Date().toLocaleString());
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}編碼器
public class MyClientEncode extends MessageToByteEncoder<String> {
@Override
protected void encode(ChannelHandlerContext ctx, String msg, ByteBuf out) throws Exception {
if (null != msg) {
byte[] request = msg.getBytes(Charset.forName("UTF-8"));
out.writeInt(request.length);
out.writeBytes(request);
}
}
}將編碼器加到ClientHandler的前面
public class MyClientChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline()
.addLast(new MyClientDecoder())
.addLast(new MyClientEncode())
.addLast(new MyClientHandler())
;
}
}MyServer06 is start ...................
客戶端連接成功 time: 2019-11-19 16:35:47
content:hhhhh0
content:hhhhh1
content:hhhhh2
content:hhhhh3
content:hhhhh4
content:hhhhh5
content:hhhhh6
content:hhhhh7
content:hhhhh8
content:hhhhh9將自定義編碼器換成LengthFieldBasedFrameDecoder(10240, 0, 4, 0, 0)
public class MyChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline()
// .addLast(new MyServerDecoderLength(10240, 0, 4, 0, 0))
.addLast(new LengthFieldBasedFrameDecoder(10240, 0, 4, 0, 0))
// .addLast(new MyServerDecoder())
.addLast(new MyServerHandler())
;
}
}
// 怕忘記的各個參數的含義在這在說明一次，自己不斷的修改每個值觀察結果就可以更加深刻的理解
/**
* maxFrameLength：消息體的最大長度，好像默認最大值為1024*1024
* lengthFieldOffset 長度字段所在字節數組的下標 （我這是第一個write的所以下標是0）
* lengthFieldLength 長度字段的字節長度（int類型佔4個字節）
* lengthAdjustment 長度字段補償的數值 （lengthAdjustment = 數據包長度 - lengthFieldOffset - lengthFieldLength - 長度域的值），解析需要減去對應的數值
* initialBytesToStrip 是否去掉長度字段（0不去除，對應長度域字節長度）
*/
public LengthFieldBasedFrameDecoder(
int maxFrameLength,
int lengthFieldOffset, int lengthFieldLength,
int lengthAdjustment, int initialBytesToStrip)MyServer06 is start ...................
客戶端連接成功 time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh0, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh1, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh2, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh3, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh4, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh5, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh6, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh7, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh8, time: 2019-11-19 17:53:42
收到客戶端發來的消息: hhhhh9, time: 2019-11-19 17:53:42如果我們在客戶端的長度域中做手腳 LengthFieldBasedFrameDecoder(10240, 0, 4, 0, 0)
舊： out.writeInt(request.length);
新： out.writeInt(request.length + 1);// 看結果就不正常，0後面多了一個0；但是不知道為啥只解碼了一次？？？ 求解答
MyServer06 is start ...................
客戶端連接成功 time: 2019-11-19 17:56:55
收到客戶端發來的消息: hhhhh0 , time: 2019-11-19 17:56:55
// 正確修改為 LengthFieldBasedFrameDecoder(10240, 0, 4, -1, 0)
// 結果：
MyServer06 is start ...................
客戶端連接成功 time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh0, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh1, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh2, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh3, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh4, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh5, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh6, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh7, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh8, time: 2019-11-19 18:02:18
收到客戶端發來的消息: hhhhh9, time: 2019-11-19 18:02:18捨棄長度域 ：LengthFieldBasedFrameDecoder(10240, 0, 4, 0, 4)
// 結果
MyServer06 is start ...................
客戶端連接成功 time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh0, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh1, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh2, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh3, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh4, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh5, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh6, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh7, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh8, time: 2019-11-19 18:03:44
收到客戶端發來的消息:hhhhh9, time: 2019-11-19 18:03:44 * <pre>
* lengthFieldOffset = 0
* lengthFieldLength = 2
* <b>lengthAdjustment</b> = <b>-2</b> (= the length of the Length field)
* initialBytesToStrip = 0
*
* BEFORE DECODE (14 bytes) AFTER DECODE (14 bytes)
* +--------+----------------+ +--------+----------------+
* | Length | Actual Content |----->| Length | Actual Content |
* | 0x000E | "HELLO, WORLD" | | 0x000E | "HELLO, WORLD" |
* +--------+----------------+ +--------+----------------+
* </pre>長度域中0x000E為16進制，轉換成10進制是14，說明消息體長度為14；根據公式：14-0-2-14 = -2* <pre>
* lengthFieldOffset = 0
* lengthFieldLength = 3
* <b>lengthAdjustment</b> = <b>2</b> (= the length of Header 1)
* initialBytesToStrip = 0
*
* BEFORE DECODE (17 bytes) AFTER DECODE (17 bytes)
* +----------+----------+----------------+ +----------+----------+----------------+
* | Length | Header 1 | Actual Content |----->| Length | Header 1 | Actual Content |
* | 0x00000C | 0xCAFE | "HELLO, WORLD" | | 0x00000C | 0xCAFE | "HELLO, WORLD" |
* +----------+----------+----------------+ +----------+----------+----------------+
* </pre>從上的例子可以知道；lengthAdjustment(2) = 17- 12（00000C）-lengthFieldOffset(0) - lengthFieldLength(3);…….等等
本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
美國蒙大拿州密蘇拉（Missoula）聯邦地區法官克里斯坦森（Dana Christensen）與環保人士及美國原住民站在同一陣線，駁回美國魚類暨野生動物管理局（US Fish and Wildlife Service）將灰熊從瀕危物種名單除名的決定。
環保人士主張，根據瀕臨滅絕物種保護法，對這些灰熊與蒙大拿州和下48州（Lower 48）的其他灰熊族群採取差別待遇，是生物學上靠不住且非法行為，法官也同意這類說法。
環保人士說，儘管灰熊數量有所回升，倘若沒有受到聯邦持續保護，牠們的復育情況就會受到影響。此外，氣候變遷導致灰熊食物供給出現變化和人為死亡率高，也對灰熊生存構成威脅。
本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!
 |
因應龐大需求，電動車龍頭廠商特斯拉（Tesla）表示將積極擴產，目標在2018年達成年產量50萬輛車。
特斯拉2015年的產量約為5萬輛，但Model 3甫一推出就獲得40萬輛的超大筆訂單。為滿足這些預購車主的需求，特斯拉表示將積極擴產五倍，將原先2020年年產量50萬輛的目標提前到2018年實現，從中可望取得可觀的美國政府補助。而2016年，特斯拉預計將交車8~9萬輛。
特斯拉執行長Elon Musk於5月4日發表公司經營狀況時表示已將自己的辦公桌「移至生產線尾端，整個團隊都全力以赴」，彰顯急速擴張的決心。但他也坦言這個目標極具挑戰，若能成功，全球電動車市場將產生結構性的變化。
特斯拉財報：首季虧損
特斯拉在4日所發表的財報顯示，該公司今年第一季營收較去年同期大幅增加22%，為11.5億美元。但由於公司正在高速擴張，使營業費用比去年同期增加四成，至5億美元；加上Model X交車進度略有落後，使首季出現虧損，淨損為2.83億美元，高於去年第一季的淨損1.54億美元。扣除非常態性項目後，相當於每股虧損0.57美元。
未見起色的財報直接衝擊特斯拉股情。4日當天，特斯拉股價一度下滑4.2%，為222.56美元。不過，當Musk再宣布目標於2018年擴產至50萬輛後，股價再度回彈，最高漲至每股239.72美元。
特斯拉能否如期實現年產能50萬輛的目標，仍待觀察。近期有兩位高階副總即將離職，且特斯拉營運燒錢速度快於盈利回收，也是一隱憂。但特斯拉表示目前仍不需要依靠融資。
本站聲明:網站內容來源於EnergyTrend https://www.energytrend.com.tw/ev/,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】
※帶您來了解什麼是 USB CONNECTOR ?
※自行創業 缺乏曝光? 下一步”網站設計“幫您第一時間規劃公司的門面形象
※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站，提高曝光率!!
※綠能、環保無空污,成為電動車最新代名詞，目前市場使用率逐漸普及化
※廣告預算用在刀口上，網站設計公司幫您達到更多曝光效益
※試算大陸海運運費!