讓你的襯衫變得"好色"起來吧!

讓你的襯衫變得”好色”起來吧!

       襯衫可以說是春夏的必備單品,不但實用,而且能與任何下裝完美搭配。今年春夏流行的襯衫不再止於傳統的白色和純色,條紋、印花、拼色、波點,顏色和款式絢麗得如同春天一樣。

  * 條紋襯衫 *

  條紋襯衫可以說是時尚界的”常青樹”,相比純色襯衫,條紋襯衫更多了一些新意。細密的條紋,能給人一種靜謐溫柔的感覺。

  條紋襯衫相對於其他襯衫,中性的屬性更強,女生穿上條紋襯衫,可以增添不少男孩般的幹練和帥氣。

  襯衫最簡單的搭配就是穿上牛仔褲,輕鬆收穫復古范兒和潮流感。

 

 

 

  而搭配白色或者杏色、米色的下裝,溫柔知性的氣息則撲面而來。

 

 

  當極簡的條紋遇上宮廷袖、蕾絲、木耳邊、精緻的印花等極富甜美風的元素,則成就了條紋襯衫的浪漫氣息。

 

 

  * 印花襯衫 *

  在各大品牌的秀場上,印花襯衫絕對是一個不可忽視的主角。

 

 

  花朵圖案的印花襯衫簡直和生機盎然的春天”配一臉”,在春光明媚的日子里穿起來,讓整個人都有着春天般的活力與明艷。

 

  幾何、抽象、波普圖案的印花則更能彰顯個性,穿上這樣的襯衫,搭配簡單的褲裝,就有了一種濃濃的復古情懷。

 

 

  * 波點襯衫 *

  波點圖案的復古味道十足,穿上這樣的襯衫,搭配裙裝、褲裝,都有一種變身畫報中復古女郎的感覺。深V的領口,或者將下擺系起來,不但大大提升時髦指數,你想要的”法式風情”也能很輕易得到。

 

 

  * 拼色襯衫 *

  在眾多襯衫款式里,拼色襯衫是最另類的存在,混搭、碰撞等時尚風格都只需一件襯衫就可以輕鬆完成。

  拼色襯衫可以穿出乖乖的小女生味道。

 

 

  也可以輕鬆獲得藝術家般的自由和趣味感。

 

 

  而拼色襯衫帶來的嫵媚或大氣,都是基本款無法企及的。

 

本站聲明:網站內容來源於江西熱線http://www.online.jx.cn,如有侵權請聯繫我們,我們將及時處理

【其他文章推薦】

※【推薦】婚攝外拍包車,可以租用外景車拍婚紗

台東必買名產首選都在"購夠台東"

※南部專業嘉義到府坐月子,台南到府坐月子,高雄到府坐月子收費服務資訊懶人包

※棉花糖女孩穿搭g cup內衣,f 罩杯內衣零著感完美包覆

婚禮影片不NG,婚禮錄影mv精彩重現讓賓客感動熱議

小琉球民宿套裝行程帶你走遍最夯的行程,浮潛找海龜、知名打卡景點、人氣麻花捲,享受渡假樂趣

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳

國家文物局:中法達成共識 中國專家將參与巴黎聖母院修復工作

  記者6日從國家文物局獲悉,中法雙方6日在京簽署合作文件,就巴黎聖母院修復開展合作,中國專家將參與巴黎聖母院修復工作。

  根據這份文件,中法雙方將在2020年確定巴黎聖母院保護修複合作的主題、模式及中方專家人選,儘早選派中國專家與法國團隊共同參與現場修復工作。

  文件還明確中法雙方將就陝西秦始皇陵兵馬俑保護開展技術與科學交流及培訓項目。

  “以文明交流超越文明隔閡,以文明互鑒超越文明衝突,以文明共存超越文明優越。”國家文物局局長劉玉珠表示,今年4月巴黎聖母院發生火災後,中法文化遺產主管部門間多次函件來往,討論合作設想。巴黎聖母院是法國乃至歐洲的文明象徵之一,其火災後修復工作受到法國國內的高度重視和國際社會的高度關注。秦始皇陵兵馬俑是享有國際盛譽的中國文化遺產,其保護研究也一直廣受國際關注。選取巴黎聖母院和秦始皇陵兵馬俑這兩個兩國各自最具標誌性的文化遺產開展保護修復和研究,將極大拓展中法文化遺產合作的深度,在世界範圍內產生積極示範效應。(記者施雨岑)

本站聲明:網站內容來源再生能源資訊網http://toptour.cn/,如有侵權請聯繫我們,我們將及時處理

【其他文章推薦】

※廣受好評的【機場接送推薦

租車接送服務需要另外加價嗎?

台東人氣名產台東人氣伴手禮,熱門獨家商品,現貨供應中

※坐月子經驗談-新竹到府坐月子媽媽心得分享與交流

※給婚攝的迎娶婚禮錄影必拍清單,沒拍到您一定會後悔!

※旅遊不求人,帶你掌握小琉球民宿海景攻略

※各類招牌、海報、大圖輸出,急件製作施工!

世界旅遊交易會“丹寨”成網紅

  11月4日, 2019倫敦世界旅遊交易會(WTM London)正式在英國開幕,丹寨萬達小鎮代表中國貴州參加了本次會議,並獲邀在中國展區啟動儀式上開展推介。憑藉秀麗的山水風景和多彩的民族文化,丹寨萬達小鎮在本次大會上甫一亮相就成為大會的一個焦點。

  倫敦世界旅遊交易會是全球最重要的旅遊行業展會之一,至今已有40年歷史。

  作為本次大會中國國家展區推介活動的重要環節之一,丹寨萬達小鎮代表中國貴州和丹寨向全球旅遊從業者推介了丹寨縣各項旅遊資源、非遺傳統文化和輪值鎮長項目。在丹寨現場搭建的展區裡,與會者還可以現場體驗來自中國的古法造紙、蠟染等丹寨非遺項目。

  藉助中國貴州於近日登上《孤獨星球》2020全球十大最佳旅行地區榜的契機,丹寨萬達小鎮在現場的推介活動吸引了大量國際與會人士的關注。

  中國駐英大使劉曉明出席了當天的中國展區啟動儀式併發言。劉曉明說,旅遊業為改善人們生活提供了強大的動力,旅遊業可以有效的促進經濟增長,增加就業。通過發展旅遊業來改善貧困在全球減貧的進程中扮演了重要角色。以中國為例,新中國成立70年來,已經有超過7億人口脫離貧困,在中國展區大家就可以看到一些通過旅遊減貧的典型案例。

  劉曉明在演講結束之後參觀了中國區展位,丹寨萬達小鎮代表向他介紹了貴州登上《孤獨星球》2020全球十大最佳旅行地區榜的情況,劉曉明還與丹寨萬達小鎮第78任輪值鎮長梅根·伊芙斯(Megan Eaves)進行了交流。

  《孤獨星球》還派代表於當天專程來到丹寨發布會,向中國貴州及丹寨頒發了《孤獨星球》上榜紀念證書。

  《孤獨星球》是一本針對全球背包客撰寫的旅行系列叢書,在200個國家和地區銷售,年銷售量達700萬冊,約佔全球英文旅行指南銷售量的四分之一。到2010年,《孤獨星球》累計銷售突破1億冊,是全球背包客和自助遊者海外行必備指南,被國際遊客稱作“旅行聖經”。10月22日,《孤獨星球》在倫敦發布2020年世界最佳旅行目的地,貴州成為中國境內唯一躋身10大世界最佳旅行地區榜單的地區,丹寨萬達小鎮被當做貴州省主要旅遊目的地重點推薦。

  2019倫敦世界旅遊交易會官員拉傑·多赫爾(Raj Dohel)也專程趕到丹寨推介會現場祝賀並致辭。他說,丹寨萬達小鎮項目是一個非常具有創新性的應對貧困的辦法,這個項目取得的數據已經非常有力的證明了它的效果,丹寨應該為自己取得的成績感到驕傲。

  在活動現場,曾擔任過丹寨萬達小鎮第78任輪值鎮長的梅根·伊芙斯向全球參會者和媒體推介了丹寨非物質文化遺產、丹寨著名景點,並在WTM推介會現場宣布丹寨萬達小鎮在全球進行輪值鎮長招募。

  此舉受到現場人士的追捧,許多外國參會者當場就來到“雲上丹寨“展位填寫並投遞輪值鎮長申請表,他們希望可以通過輪值鎮長項目幫助更多丹寨民眾。據統計,在WTM首日,丹寨就已經收到近20份來自海外的申請信。

本站聲明:網站內容來源再生能源資訊網http://toptour.cn/,如有侵權請聯繫我們,我們將及時處理

【其他文章推薦】

※想知道大胸女孩都會買什麼款式的內衣呢?d cup內衣,e cup內衣挑選完美致勝推薦

※濃郁的奶香牛軋糖-最好吃的伴手禮,送禮要送進心崁裡!

※專為各大企業長短期商務包車接送的服務

※來台東旅遊不可錯過的,台東必買名產 「池上米、地瓜酥、洛神花」都在"購夠台東"網路商城皆買的到哦!

※2020推薦婚禮錄影台北精選18家專業團隊

※票選台中最佳親子活動.情侶約會必住的一中街住宿,旅遊行程推薦!

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳

機器學習筆記(1) 感知機算法 之 實戰篇

我們在上篇筆記中介紹了感知機的,討論了感知機的由來、工作原理、求解策略、收斂性。這篇筆記中,我們親自動手寫代碼,使用感知機算法解決實際問題。

先從一個最簡單的問題開始,用感知機算法解決OR邏輯的分類。

import numpy as np
import matplotlib.pyplot as plt

x = [0,0,1,1]
y = [0,1,0,1]

plt.scatter(x[0],y[0], color="red",label="negative")
plt.scatter(x[1:],y[1:], color="green",label="positive")

plt.legend(loc="best")
plt.show()

下面我們來定義一個函數,用來判定一個樣本點是否被正確分類了。由於此例中樣本點是二維的,因此權重向量也相應的為二維,可以定義為\(w = (w_1, w_2)\),在Python中可以使用列表來表達,例如w = [0, 0],而樣本到超平面的距離自然就是w[0] * x[0] + w[1] * x[1] +b。下面給出完整的函數。

def decide(data,label,w,b):
    result = w[0] * data[0] + w[1] * data[1] - b
    print("result = ",result)
    if np.sign(result) * label <= 0:
        w[0] += 1 * (label - result) * data[0]
        w[1] += 1 * (label - result) * data[1]
        b += 1 * (label - result)*(-1)
    return w,b

寫完核心函數后,我們還需要寫一個調度函數,這個函數提供遍歷每一個樣本點的功能。

def run(data, label):
    w,b = [0,0],0
    for epoch in range(10):
        for item in zip(data, label):
            dataset,labelset = item[0],item[1]
            w,b = decide(dataset, labelset, w, b)
            print("dataset = ",dataset, ",", "w = ",w,",","b = ",b)
    print(w,b)
data = [(0,0),(0,1),(1,0),(1,1)]
label = [0,1,1,1]
run(data,label)
result =  0
dataset =  (0, 0) , w =  [0, 0] , b =  0
result =  0
dataset =  (0, 1) , w =  [0, 1] , b =  -1
result =  1
dataset =  (1, 0) , w =  [0, 1] , b =  -1
result =  2
dataset =  (1, 1) , w =  [0, 1] , b =  -1
result =  1
dataset =  (0, 0) , w =  [0, 1] , b =  0
result =  1
dataset =  (0, 1) , w =  [0, 1] , b =  0
result =  0
dataset =  (1, 0) , w =  [1, 1] , b =  -1
result =  3
dataset =  (1, 1) , w =  [1, 1] , b =  -1
result =  1
dataset =  (0, 0) , w =  [1, 1] , b =  0
result =  1
dataset =  (0, 1) , w =  [1, 1] , b =  0
result =  1
後面的迭代這裏省略不貼,參數穩定下來,算法已經收斂

下面看一個來自UCI的數據集:PIMA糖尿病數據集,例子來自《機器學習算法視角》第三章

import os
import pylab as pl
import numpy as np
import pandas as pd
os.chdir(r"DataSets\pima-indians-diabetes-database")
pima = np.loadtxt("pima.txt", delimiter=",", skiprows=1)
pima.shape
(768, 9)
indices0 = np.where(pima[:,8]==0)
indices1 = np.where(pima[:,8]==1)
pl.ion()
pl.plot(pima[indices0,0],pima[indices0,1],"go")
pl.plot(pima[indices1,0],pima[indices1,1],"rx")
pl.show()

數據預處理

1.將年齡離散化

pima[np.where(pima[:,7]<=30),7] = 1
pima[np.where((pima[:,7]>30) & (pima[:,7]<=40)),7] = 2
pima[np.where((pima[:,7]>40) & (pima[:,7]<=50)),7] = 3
pima[np.where((pima[:,7]>50) & (pima[:,7]<=60)),7] = 4
pima[np.where(pima[:,7]>60),7] = 5

2.將女性的懷孕次數大於8次的統一用8次代替

pima[np.where(pima[:,0]>8),0] = 8

3.將數據標準化處理

pima[:,:8] = pima[:,:8]-pima[:,:8].mean(axis=0)
pima[:,:8] = pima[:,:8]/pima[:,:8].var(axis=0)

4.切分訓練集和測試集

trainin = pima[::2,:8]
testin = pima[1::2,:8]
traintgt = pima[::2,8:9]
testtgt = pima[1::2,8:9]

定義模型

class Perceptron:
    def __init__(self, inputs, targets):
        # 設置網絡規模
        # 記錄輸入向量的維度,神經元的維度要和它相等
        if np.ndim(inputs) > 1:
            self.nIn = np.shape(inputs)[1]
        else:
            self.nIn = 1
        
        # 記錄目標向量的維度,神經元的個數要和它相等
        if np.ndim(targets) > 1:
            self.nOut = np.shape(targets)[1]
        else:
            self.nOut = 1
        
        # 記錄輸入向量的樣本個數
        self.nData = np.shape(inputs)[0]
        
        # 初始化網絡,這裏加1是為了包含偏置項
        self.weights = np.random.rand(self.nIn + 1, self.nOut) * 0.1 - 0.05
        
    def train(self, inputs, targets, eta, epoch):
        """訓練環節"""
        # 和前面處理偏置項同步地,這裏對輸入樣本加一項-1,與W0相匹配
        inputs = np.concatenate((inputs, -np.ones((self.nData,1))),axis=1)
        
        for n in range(epoch):
            self.activations = self.forward(inputs)
            self.weights -= eta * np.dot(np.transpose(inputs), self.activations - targets)
        return self.weights
    
    def forward(self, inputs):
        """神經網路前向傳播環節"""
        # 計算
        activations = np.dot(inputs, self.weights)
        # 判斷是否激活
        return np.where(activations>0, 1, 0)
    
    def confusion_matrix(self, inputs, targets):
        # 計算混淆矩陣
        inputs = np.concatenate((inputs, -np.ones((self.nData,1))),axis=1)
        outputs = np.dot(inputs, self.weights)
        nClasses = np.shape(targets)[1]
        
        if nClasses == 1:
            nClasses = 2
            outputs = np.where(outputs<0, 1, 0)
        else:
            outputs = np.argmax(outputs, 1)
            targets = np.argmax(targets, 1)
            
        cm = np.zeros((nClasses, nClasses))
        for i in range(nClasses):
            for j in range(nClasses):
                cm[i,j] = np.sum(np.where(outputs==i, 1,0) * np.where(targets==j, 1, 0))
        print(cm)
        print(np.trace(cm)/np.sum(cm))
print("Output after preprocessing of data")
p = Perceptron(trainin,traintgt)
p.train(trainin,traintgt,0.15,10000)
p.confusion_matrix(testin,testtgt)
Output after preprocessing of data
[[ 69.  86.]
 [182.  47.]]
0.3020833333333333

這個案例使用感知機訓練得到的結果比較糟糕,這裏只是作為展示算法的例子。

最後看一個使用感知機算法識別MNIST手寫数字的例子。代碼借鑒了Kaggle上的kernel。

step 1:首先導入所需的包,並且設置好數據所在路徑

import numpy as np
import pandas as pd
import matplotlib.pyplot as plt
train = pd.read_csv(r"DataSets\Digit_Recognizer\train.csv", engine="python")
test = pd.read_csv(r"DataSets\Digit_Recognizer\test.csv", engine="python")
print("Training set has {0[0]} rows and {0[1]} columns".format(train.shape))
print("Test set has {0[0]} rows and {0[1]} columns".format(test.shape))
Training set has 42000 rows and 785 columns
Test set has 28000 rows and 784 columns

step 2:數據預處理

  1. 創建label,它的size為 (42000, 1)

  2. 創建training set,size為(42000, 784)

  3. 創建weights,size為(10,784),這可能有點不好理解。我們知道,權重向量是描述神經元的,784是維度,表示一個輸入樣本有784維,相應的與它對接的神經元也要有784維。同時,要記住一個神經元只能輸出一個output,而在数字識別問題中,我們期待的是輸入一個樣本數據,能返回10個数字,然後依概率判斷這個樣本是哪個数字的可能性最大。所以,我們需要10個神經元,這就是(10,784)的來歷。

trainlabels = train.label
trainlabels.shape
(42000,)
traindata = np.asmatrix(train.loc[:,"pixel0":])
traindata.shape
(42000, 784)
weights = np.zeros((10,784))
weights.shape
(10, 784)

這裏可以先看一個樣本,找找感覺。注意原數據是壓縮成了784維的數組,我們需要將它變回28*28的圖片

# 從矩陣中隨便取一行
samplerow = traindata[123:124]
# 重新變成28*28
samplerow = np.reshape(samplerow, (28,28))
plt.imshow(samplerow, cmap="hot")

step 3:訓練

這裏我們對訓練數據集循環若干次,然後重點關注錯誤率曲線

# 先創建一個列表,用來記錄每一輪訓練的錯誤率
errors = []
epoch = 20

for epoch in range(epoch):
    err = 0
    # 對每一個樣本(亦矩陣中的每一行)
    for i, data in enumerate(traindata):
        # 創建一個列表,用來記錄每個神經元輸出的值
        output = []
        # 對每個神經元都做點乘操作,並記錄下輸出值
        for w in weights:
            output.append(np.dot(data, w))
        # 這裏簡單的取輸出值最大者為最有可能的
        guess = np.argmax(output)
        # 實際的值為標籤列表中對應項
        actual = trainlabels[i]
        
        # 如果估計值和實際值不同,則分類錯誤,需要更新權重向量
        if guess != actual:
            weights[guess] = weights[guess] - data
            weights[actual] = weights[actual] + data
            err += 1
    # 計算迭代完42000個樣本之後,錯誤率 = 錯誤次數/樣本個數
    errors.append(err/42000)
x = list(range(20))
plt.plot(x, errors)
[<matplotlib.lines.Line2D at 0x5955c50>]

從圖可以看出,達到15次迭代時,錯誤率已經有上升的趨勢了,開始過擬合了。

感知機是一個非常簡單的算法,以致於很難在真正的場景中使用感知機算法。這裏舉的3個例子,都旨在於動手寫代碼實現這個算法,找找感覺。稍有經驗的讀者想必會好奇:為什麼沒有使用Scikit-Learn這個包,這部分其實是筆者另有計劃,打算結合算法寫Scikit-Learn的源碼解讀筆記。當然,限於個人水平,不一定能解析到精髓,但勉力而為吧。下篇會寫Multi-Layer-Perceptron算法的原理,在那裡我們很容易看到,縱使是簡單的感知機,只要加一個隱層,就能大幅提升其分類能力。另外,也會抽空寫一篇感知機Sklearn源碼解讀的文章。有任何問題,歡迎大家留言討論。

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理
【其他文章推薦】

※信用卡的機場接送服務好嗎?

台北桃園機場接送,網友超推,CP值超高,安全,寬敞又舒適

※想知道台東名產人氣商品是什麼?想知道更多台東知名伴手禮有哪些?

※評選台東伴手禮推薦商品「釋迦 」是台東必買伴手禮之一

※離島好好玩!小琉球必吃美食、必玩景點、最優惠的小琉球民宿套裝行程詳細攻略!

※濃郁的奶香牛軋糖-最好吃的伴手禮,送禮要送進心崁裡!

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳

Chrome Extension 小試牛刀

 

自從有了Chrome以後,就喜歡上了這個瀏覽器,從此IE 886了。

以前作爬蟲,做登錄,做數據採集,做數據處理等各種功能,後來H5出來后,出現了,除了Session/Cookie 出了Local Storage,暫時還沒有更好的辦法獲取Local Storage。由於處理的數據比較少,所以決定研究一下Chrome Extension。

 

百度了一下Chrome Extension,可以通過Chrome Extension 官網進行學習,簡單上手。網址:

要解決的問題:

公司OA使用了很多年了,其中的流程備案記錄很少關注查看,今天公司通知最近要檢查,確認大家是否都看了,否則會進行處罰。今天要解決的問題就是自動把所有的未查看過的抄送記錄,都確認為已閱讀。

解決方案:

本來可以通過SQL語句,修改數據庫的是否閱讀狀態。這是最近單的方式,但是和Chrome Extension 就沒有關係了。

所以還是通過模擬的方式,通過點擊一個按鈕自動瀏覽本頁的所有標記為未讀的記錄。

操作記錄:

進入流程抄送記錄,點擊【自動瀏覽】開始操作。

 

 

 

 

點擊自動瀏覽后,會自動在該Chrome頁面上打開多個瀏覽器頁簽显示所有未讀的記錄

軟件開發中問題匯總:

怎麼使用Jquery

自動使用Juquery原來,對原生的js是越來越陌生了,寫Js第一件事就是下載一個Jquery用上。

 

 

 

 

在 manifest.json中配置對應的jquery路徑,然後在contentscript.js和background.js中就可以使用Jquery了。

Chrome Extension的圖標怎麼設置呢?

看到上面manifest.json中的icons屬性了嗎?設置上對應的圖標即可。注意大小。

點擊Chrome Extension圖標,展示的頁面

這是一個特別特別簡單的html頁面,只有一個按鈕,最後加了一個index.js的js文件,一定要引用到最後。Js文件主要是對該彈出頁進行操作。

這個插件只有一個動作,就是點擊上面的【自動瀏覽】按鈕。

 

 

 

點擊【自動瀏覽】按鈕的邏輯

點擊按鈕后,按鈕顏色編成藍色,如果有其他按鈕,則其他按鈕字體顏色為黑色,另外:點擊按鈕后,與當前網頁進行通訊,返回頁面上所有沒有瀏覽記錄的ID,並用【;】分割。

 

處理網頁數據的頁面邏輯

通過jquery查詢當前頁面中所有的未讀記錄,遍歷並把所有的id用【;】分割。

一定要有return true.

 

 

 

寫在最後:

剛開始結束的時候,經歷了各種坎坷,

 

 

由於是Chrome Extension與頁面的數據進行通訊,各種搞不定,現在基本可以通過這個模式化的界面與各種服務、http頁面等進行互操作了。

通過這次Chrome Extension的開發,不僅重新熟悉了各種js,而且最重要的是,以後簡單的爬蟲,再也不用打開vs,吭哧坑成的編程啦。

 

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

【其他文章推薦】

※全國票選五大台東必買台東伴手禮最佳商品哪裡買的到?

※月子中心貴鬆鬆,找對到府月嫂省一半,更讓你事半功倍!!    

※女孩困擾找不到『i cup內衣』?不必擔心專業內衣網購平台嚨底家

※機場接送服務包括:大陸機場接送以及桃園機場接送服務。

※最美的渡假聖地!享受無敵海景小琉球民宿推薦,旅遊達人,教你怎麼玩~

※嚴選台中火車站周邊熱鬧景點-台中一中住宿優惠!

※各類招牌、海報、大圖輸出,急件製作施工!

Flutter之環境配置與項目搭建,React-Native windows環境搭建記錄,React Naive之macOs環境配置記錄(iOS Android)

Flutter之環境配置與項目搭建

一,介紹

1.1,

       是一種 易於學習、 易於擴展、並且可以部署到 任何地方 的 應用 編程 語言。並且同時借鑒了Java和JavaScript。Dart在靜態語法方面和Java非常相似,如類型定義、函數聲明、泛型等,而在動態特性方面又和JavaScript很像,如函數式特性、異步支持等。

1.2,

        是 Google推出並開源的移動應用開發框架,主打跨平台、高保真、高性能。開發者可以通過 Dart語言開發 App,一套代碼同時運行在 iOS 和 Android平台。 Flutter提供了豐富的組件、接口,開發者可以很快地為 Flutter添加 native擴展。同時 Flutter還使用 Native引擎渲染視圖。

二,開發環境配置

 2.1,安裝Flutter

第一步:配置鏡像

由於在國內訪問Flutter有時可能會受到限制,Flutter官方為中國開發者搭建了臨時鏡像,大家可以將如下環境變量加入到用戶環境變量中:

1 export PUB_HOSTED_URL=https://pub.flutter-io.cn
2 export FLUTTER_STORAGE_BASE_URL=https://storage.flutter-io.cn

如下圖所示:

第二步:獲取Flutter SDK

去flutter官網下載其最新可用的安裝包,下載地址: ,打開后如圖所示:

    1. 將安裝包zip解壓到你想安裝Flutter SDK的路徑(如:D:\flutter;注意,不要將flutter安裝到需要一些高權限的路徑如C:\Program Files\)。

    2. 在Flutter安裝目錄的flutter文件下找到flutter_console.bat,雙擊運行並啟動flutter命令行,接下來,你就可以在Flutter命令行運行flutter命令了。

第三步:配置環境變量

如果不配置環境變量,在全局環境中是無法使用flutter命令的,轉到 “控制面板>用戶帳戶>用戶帳戶>更改我的環境變量”,在Path下添加D:\flutter\bin條目,保存即可。

第四步:運行 flutter doctor命令

在Flutter命令行運行如下命令來查看是否還需要安裝其它依賴,如果需要,安裝它們:

1 flutter doctor

該命令檢查你的環境並在命令行窗口中显示報告。Dart SDK已經在打包在Flutter SDK里了,沒有必要單獨安裝Dart。安裝完成后再運行flutter doctor命令來驗證是否安裝成功。

 2.2,windows與mac本配置(模擬器)

windows下sdk與jdk配置,可參考

mac本下sdk與jdk配置,可參考

 2.3,編輯器配置

常用編輯器是VS Code,故此這兒主要介紹VS Code的配置,VS Code支持Flutter運行和調試。

安裝flutter插件

    1. 啟動 VS Code。
    2. 調用 View>Command Palette…。
    3. 輸入 ‘install’, 然後選擇 Extensions: Install Extension action。
    4. 在搜索框輸入 flutter ,在搜索結果列表中選擇 ‘Flutter’, 然後點擊 Install。
    5. 選擇 ‘OK’ 重新啟動 VS Code。
    6. 驗證配置
      • 調用 View>Command Palette…
      • 輸入 ‘doctor’, 然後選擇 ‘Flutter: Run Flutter Doctor’ action。
      • 查看“OUTPUT”窗口中的輸出是否有問題

創建Flutter應用

    1. 啟動 VS Code
    2. 調用 View>Command Palette…
    3. 輸入 ‘flutter’, 然後選擇 ‘Flutter: New Project’ action
    4. 輸入 Project 名稱 (如myapp), 然後按回車鍵
    5. 指定放置項目的位置,然後按藍色的確定按鈕
    6. 等待項目創建繼續,並显示main.dart文件

VS Code格式化dart代碼的快捷方式是shift+alt+f

三,項目搭建

第一步:創建Flutter應用

1 flutter create yingqi_flutter

 第二步:底部tab

 Flutter中的路由管理和原生開發類似,無論是Android還是iOS,導航管理都會維護一個路由棧,路由入棧(push)操作對應打開一個新頁面,路由出棧(pop)操作對應頁面關閉操作,而路由管理主要是指如何來管理路由棧。

1  final result =
2         await Navigator.of(context).push(MaterialPageRoute(builder: (context) {
3       return LoginPage();
4     }));
1  Navigator.pop(context, "refresh");

  1 class AppHomeState extends State<AppHome> {
  2   final appBarTitles = ['首頁', '資訊', '產品', '我的'];
  3  
  4   ... 
  5 
  6   int _tabIndex = 0;
  7 
  8   var tabImages;
  9   var _body;
 10   var pages;
 11 
 12   Image getTabImage(path) {
 13     return Image.asset(path, width: 20.0, height: 20.0);
 14   }
 15 
 16   @override
 17   void initState() {
 18     super.initState();
 19 
 20    ...
 21 
 22     });
 23     pages = <Widget>[HomePage(), NewsPage(), ProductPage(), MyPage()];
 24     if (tabImages == null) {
 25       tabImages = [
 26         [
 27           getTabImage('images/ic_nav_news_normal.png'),
 28           getTabImage('images/ic_nav_news_actived.png')
 29         ],
 30         [
 31           getTabImage('images/ic_nav_tweet_normal.png'),
 32           getTabImage('images/ic_nav_tweet_actived.png')
 33         ],
 34         [
 35           getTabImage('images/ic_nav_discover_normal.png'),
 36           getTabImage('images/ic_nav_discover_actived.png')
 37         ],
 38         [
 39           getTabImage('images/ic_nav_my_normal.png'),
 40           getTabImage('images/ic_nav_my_pressed.png')
 41         ]
 42       ];
 43     }
 44   }
 45 
 46   TextStyle getTabTextStyle(int curIndex) {
 47     if (curIndex == _tabIndex) {
 48       return tabTextStyleSelected;
 49     }
 50     return tabTextStyleNormal;
 51   }
 52 
 53   Image getTabIcon(int curIndex) {
 54     if (curIndex == _tabIndex) {
 55       return tabImages[curIndex][1];
 56     }
 57     return tabImages[curIndex][0];
 58   }
 59 
 60   Text getTabTitle(int curIndex) {
 61     return Text(appBarTitles[curIndex], style: getTabTextStyle(curIndex));
 62   }
 63 
 64   @override
 65   Widget build(BuildContext context) {
 66     _body = IndexedStack(
 67       children: pages,
 68       index: _tabIndex,
 69     );
 70     return MaterialApp( 74       home: Scaffold( 80         body: _body,
 81         bottomNavigationBar: CupertinoTabBar(
 82           items: <BottomNavigationBarItem>[
 83             BottomNavigationBarItem(
 84                 icon: getTabIcon(0),
 85                 title: getTabTitle(0)),
 86             BottomNavigationBarItem(
 87                 icon: getTabIcon(1),
 88                 title: getTabTitle(1)),
 89             BottomNavigationBarItem(
 90                 icon: getTabIcon(2),
 91                 title: getTabTitle(2)),
 92             BottomNavigationBarItem(
 93                 icon: getTabIcon(3),
 94                 title: getTabTitle(3)),
 95           ],
 96           currentIndex: _tabIndex,
 97           onTap: (index) {
 98             setState((){
 99               _tabIndex = index;
100             });
101           },
102         ),
103       ),
104     );
105   }
106 }

 第三步:包管理與資源配置

Flutter項目默認的配置文件是pubspec.yaml,包與資源配置,均修改此文件

包配置如下圖所示:

    • dependencies:應用或包依賴的其它包或插件。
    • flutter:flutter相關的配置選項。

http: ^0.12.0就是項目中需要使用外部包配置,使用如下命令即可下載:

1 flutter packages get

資源配置如下圖所示:

 

 需要使用什麼資源,以圖片中的格式在assets下繼續添加即可。

 第四步:數據緩存

1,在pubspec.yaml文件中,添加如下包:

1   shared_preferences: ^0.4.3

2,數據記錄類

1 import 'package:shared_preferences/shared_preferences.dart';
2 import 'dart:async';
3 
4 class DataUtils {
5 
6 ...
7 
8 }

3,用戶登錄信息操作

 1   static const String SP_USER_NAME = "name";
 2   static const String SP_USER_ID = "userId";
 3   static const String SP_IS_LOGIN = "isLogin";
 4 
 5   // 保存用戶登錄信息,data中包含了token等信息
 6   static saveLoginInfo(Map data) async {
 7     if (data != null) {
 8       SharedPreferences sp = await SharedPreferences.getInstance();
 9       String userId = data['UserId'];
10       await sp.setString(SP_USER_ID, userId);
11       String name = data['Name'];
12       await sp.setString(SP_USER_NAME, name);
13       await sp.setBool(SP_IS_LOGIN, true);
14     }
15   }
16 
17   // 清除登錄信息
18   static clearLoginInfo() async {
19     SharedPreferences sp = await SharedPreferences.getInstance();
20     await sp.setString(SP_USER_ID, "");
21     await sp.setString(SP_USER_NAME, "");
22     await sp.setBool(SP_IS_LOGIN, false);
23   }
24 
25  // 獲取用戶登錄信息
26   static Future<LoginInfo> getLoginInfo() async {
27      SharedPreferences sp = await SharedPreferences.getInstance();
28     bool isLogin = sp.getBool(SP_IS_LOGIN);
29     if (isLogin == null || !isLogin) {
30       return null;
31     }
32     LoginInfo loginInfo = LoginInfo();
33     loginInfo.userId = sp.getString(SP_USER_ID);
34     loginInfo.name = sp.getString(SP_USER_NAME);
35     return loginInfo;
36   }

 下一章->

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

【其他文章推薦】

※【推薦】婚攝外拍包車,可以租用外景車拍婚紗

台東必買名產首選都在"購夠台東"

※南部專業嘉義到府坐月子,台南到府坐月子,高雄到府坐月子收費服務資訊懶人包

※棉花糖女孩穿搭g cup內衣,f 罩杯內衣零著感完美包覆

婚禮影片不NG,婚禮錄影mv精彩重現讓賓客感動熱議

小琉球民宿套裝行程帶你走遍最夯的行程,浮潛找海龜、知名打卡景點、人氣麻花捲,享受渡假樂趣

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳

《Java多線程面試題》系列-創建線程的三種方法及其區別

1. 創建線程的三種方法及其區別

1.1 繼承Thread類

首先,定義Thread類的子類並重寫run()方法:

package com.zwwhnly.springbootaction.javabase.thread;

public class MyFirstThread extends Thread {
    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.printf("[MyFirstThread]輸出:%d,當前線程名稱:%s\n",
                    i, getName());
        }
    }
}

然後,創建該子類的實例並調用start()方法啟動線程:

package com.zwwhnly.springbootaction.javabase.thread;

public class ThreadTest {
    public static void main(String[] args) {
        System.out.println("主線程開始執行,當前線程名稱:" +
                Thread.currentThread().getName());

        Thread firstThread = new MyFirstThread();
        firstThread.start();

        System.out.println("主線程執行結束,當前線程名稱:" +
                Thread.currentThread().getName());
    }
}

運行結果如下所示:

主線程開始執行,當前線程名稱:main

主線程執行結束,當前線程名稱:main

[MyFirstThread]輸出:0,當前線程名稱:Thread-0

[MyFirstThread]輸出:1,當前線程名稱:Thread-0

[MyFirstThread]輸出:2,當前線程名稱:Thread-0

[MyFirstThread]輸出:3,當前線程名稱:Thread-0

[MyFirstThread]輸出:4,當前線程名稱:Thread-0

從運行結果可以看出以下2個問題:

  1. 程序中存在2個線程,分別為主線程main和自定義的線程Thread-0。
  2. 調用firstThread.start();,run()方法體中的代碼並沒有立即執行,而是異步執行的。

查看Thread類的源碼,可以發現Thread類實現了接口Runnable:

public class Thread implements Runnable {
    // 省略其它代碼
}

這裡是重點,面試常問!

1.2 實現Runnable接口(推薦)

首先,定義Runnable接口的實現類並實現run()方法:

package com.zwwhnly.springbootaction.javabase.thread;

public class MySecondThread implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.printf("[MySecondThread]輸出:%d,當前線程名稱:%s\n",
                    i, Thread.currentThread().getName());
        }
    }
}

然後,調用Thread類的構造函數創建Thread實例並調用start()方法啟動線程:

package com.zwwhnly.springbootaction.javabase.thread;

public class ThreadTest {
    public static void main(String[] args) {
        Runnable target = new MySecondThread();
        Thread secondThread = new Thread(target);
        secondThread.start();
    }
}

運行結果如下所示:

主線程開始執行,當前線程名稱:main

主線程執行結束,當前線程名稱:main

[MySecondThread]輸出:0,當前線程名稱:Thread-0

[MySecondThread]輸出:1,當前線程名稱:Thread-0

[MySecondThread]輸出:2,當前線程名稱:Thread-0

[MySecondThread]輸出:3,當前線程名稱:Thread-0

[MySecondThread]輸出:4,當前線程名稱:Thread-0

可以看出,使用這種方式和繼承Thread類的運行結果是一樣的。

1.3 實現Callable接口

首先,定義Callable接口的實現類並實現call()方法:

package com.zwwhnly.springbootaction.javabase.thread;

import java.util.Random;
import java.util.concurrent.Callable;

public class MyThirdThread implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        Thread.sleep(6 * 1000);
        return new Random().nextInt();
    }
}

然後,調用FutureTask類的構造函數創建FutureTask實例:

Callable<Integer> callable = new MyThirdThread();
FutureTask<Integer> futureTask = new FutureTask<>(callable);

最後,調用Thread類的構造函數創建Thread實例並調用start()方法啟動線程:

package com.zwwhnly.springbootaction.javabase.thread;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class ThreadTest {
    public static void main(String[] args) {
        System.out.println("主線程開始執行,當前線程名稱:" +
                Thread.currentThread().getName());

        Callable<Integer> callable = new MyThirdThread();
        FutureTask<Integer> futureTask = new FutureTask<>(callable);
        new Thread(futureTask).start();

        try {
            System.out.println("futureTask.isDone() return:" + futureTask.isDone());

            System.out.println(futureTask.get());

            System.out.println("futureTask.isDone() return:" + futureTask.isDone());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        System.out.println("主線程執行結束,當前線程名稱:" +
                Thread.currentThread().getName());
    }
}

運行結果如下所示:

主線程開始執行,當前線程名稱:main

futureTask.isDone() return:false

-1193053528

futureTask.isDone() return:true

主線程執行結束,當前線程名稱:main

可以發現,使用Callable接口這種方式,我們可以通過futureTask.get()獲取到線程的執行結果,而之前的2種方式,都是沒有返回值的。

注意事項:調用futureTask.get()獲取線程的執行結果時,主線程會阻塞直到獲取到結果。

阻塞效果如下圖所示:

1.4 區別

以下是重點,面試常問!

  1. Java中,類僅支持單繼承,如果一個類繼承了Thread類,就無法再繼承其它類,因此,如果一個類既要繼承其它的類,又必須創建為一個線程,就可以使用實現Runable接口的方式。
  2. 使用實現Runable接口的方式創建的線程可以處理同一資源,實現資源的共享。
  3. 使用實現Callable接口的方式創建的線程,可以獲取到線程執行的返回值、是否執行完成等信息。

關於第2點,可以通過如下示例來理解。

假如我們總共有10張票(共享的資源),為了提升售票的效率,開了3個線程來售賣,代碼如下所示:

package com.zwwhnly.springbootaction.javabase.thread;

public class SaleTicketThread implements Runnable {
    private int quantity = 10;

    @Override
    public void run() {
        while (quantity > 0) {
            System.out.println(quantity-- + " is saled by " +
                    Thread.currentThread().getName());
        }
    }
}
public static void main(String[] args) {
    Runnable runnable = new SaleTicketThread();
    Thread saleTicketThread1 = new Thread(runnable);
    Thread saleTicketThread2 = new Thread(runnable);
    Thread saleTicketThread3 = new Thread(runnable);

    saleTicketThread1.start();
    saleTicketThread2.start();
    saleTicketThread3.start();
}

因為3個線程都是異步執行的,因此每次的運行結果可能是不一樣,以下列舉2次不同的運行結果。

第1次運行結果:

10 is saled by Thread-0

8 is saled by Thread-0

7 is saled by Thread-0

5 is saled by Thread-0

9 is saled by Thread-1

3 is saled by Thread-1

2 is saled by Thread-1

1 is saled by Thread-1

4 is saled by Thread-0

6 is saled by Thread-2

第2次運行結果:

10 is saled by Thread-0

9 is saled by Thread-0

8 is saled by Thread-0

7 is saled by Thread-0

6 is saled by Thread-0

5 is saled by Thread-0

3 is saled by Thread-0

2 is saled by Thread-0

4 is saled by Thread-2

1 is saled by Thread-1

如果將上面的SaleTicketThread修改成繼承Thread類的方式,就變成了3個線程各自擁有10張票,即變成了30張票,而不是3個線程共享10張票。

2. Thread類start()和run()的區別

2.1 示例

因為實現Runnable接口的優勢,基本上實現多線程都使用的是該種方式,所以我們將之前定義的MyFirstThread也修改為實現Runnable接口的方式:

package com.zwwhnly.springbootaction.javabase.thread;

public class MyFirstThread implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.printf("[MyFirstThread]輸出:%d,當前線程名稱:%s\n",
                    i, Thread.currentThread().getName());
        }
    }
}

然後仍然沿用之前定義的MyFirstThread、MySecondThread,我們先看下調用start()的效果:

package com.zwwhnly.springbootaction.javabase.thread;

public class ThreadTest {
    public static void main(String[] args) {

        System.out.println("主線程開始執行,當前線程名稱:" +
                Thread.currentThread().getName());

        Thread firstThread = new Thread(new MyFirstThread());

        Runnable target = new MySecondThread();
        Thread secondThread = new Thread(target);

        firstThread.start();
        secondThread.start();

        System.out.println("主線程執行結束,當前線程名稱:" +
                Thread.currentThread().getName());
    }
}

運行結果(注意:多次運行,結果可能不一樣):

主線程開始執行,當前線程名稱:main

[MyFirstThread]輸出:0,當前線程名稱:Thread-0

[MyFirstThread]輸出:1,當前線程名稱:Thread-0

[MySecondThread]輸出:0,當前線程名稱:Thread-1

主線程執行結束,當前線程名稱:main

[MySecondThread]輸出:1,當前線程名稱:Thread-1

[MySecondThread]輸出:2,當前線程名稱:Thread-1

[MySecondThread]輸出:3,當前線程名稱:Thread-1

[MySecondThread]輸出:4,當前線程名稱:Thread-1

[MyFirstThread]輸出:2,當前線程名稱:Thread-0

[MyFirstThread]輸出:3,當前線程名稱:Thread-0

[MyFirstThread]輸出:4,當前線程名稱:Thread-0

可以看出,調用start()方法后,程序中有3個線程,分別為主線程main、Thread-0、Thread-1,而且執行順序不是按順序執行的,存在不確定性。

然後將start()方法修改為run()方法,如下所示:

firstThread.run();
secondThread.run();

此時的運行結果如下所示(多次運行,結果是一樣的):

主線程開始執行,當前線程名稱:main

[MyFirstThread]輸出:0,當前線程名稱:main

[MyFirstThread]輸出:1,當前線程名稱:main

[MyFirstThread]輸出:2,當前線程名稱:main

[MyFirstThread]輸出:3,當前線程名稱:main

[MyFirstThread]輸出:4,當前線程名稱:main

[MySecondThread]輸出:0,當前線程名稱:main

[MySecondThread]輸出:1,當前線程名稱:main

[MySecondThread]輸出:2,當前線程名稱:main

[MySecondThread]輸出:3,當前線程名稱:main

[MySecondThread]輸出:4,當前線程名稱:main

主線程執行結束,當前線程名稱:main

可以看出,調用run()方法后,程序中只有一個主線程,自定義的2個線程並沒有啟動,而且執行順序也是按順序執行的。

1.2 總結

以下是重點,面試常問!

  • run()方法只是一個普通方法,調用之後程序會等待run()方法執行完畢,所以是串行執行,而不是并行執行。
  • start()方法會啟動一個線程,當線程得到CPU資源後會自動執行run()方法體中的內容,實現真正的併發執行。

3. Runnable和Callable的區別

在文章前面的章節中(1.2 實現Runnable接口 和1.3 實現Callable接口),我們了解了如何使用Runnable、Callable接口來創建線程,現在我們分別看下Runable和Callable接口的定義,其中,Runable接口的定義如下所示:

public interface Runnable {
    public abstract void run();
}

Callable接口的定義如下所示:

public interface Callable<V> {
    V call() throws Exception;
}

由此可以看出,Runnable和Callable的區別主要有以下幾點:

  1. Runable的執行方法是run(),Callable的執行方法是call()
  2. call()方法可以拋出異常,run()方法如果有異常只能在內部消化
  3. 實現Runnable接口的線程沒有返回值,實現Callable接口的線程能返回執行結果
  4. 實現Callable接口的線程,可以和FutureTask一起使用,獲取到線程是否完成、線程是否取消、線程執行結果,也可以取消線程的執行。

4. 源碼及參考

源碼地址:,歡迎下載。

如果覺得文章寫的不錯,歡迎關注我的微信公眾號:「申城異鄉人」,所有博客會同步更新。

如果有興趣,也可以添加我的微信:zwwhnly_002,一起交流和探討技術。

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

【其他文章推薦】

※廣受好評的【機場接送推薦

租車接送服務需要另外加價嗎?

台東人氣名產台東人氣伴手禮,熱門獨家商品,現貨供應中

※坐月子經驗談-新竹到府坐月子媽媽心得分享與交流

※給婚攝的迎娶婚禮錄影必拍清單,沒拍到您一定會後悔!

※旅遊不求人,帶你掌握小琉球民宿海景攻略

※各類招牌、海報、大圖輸出,急件製作施工!

java架構之路(MQ專題)kafka集群配置和簡單使用

  前面我們說了RabbitMQ和RocketMQ的安裝和簡單的使用,這次我們說一下Kafka的安裝配置,後面我會用幾個真實案例來說一下MQ的真實使用場景。天冷了,不願意伸手,最近沒怎麼寫博客了,還請見諒。

一、目標

  1.知道什麼是Kafka

  2.懂得kafka的單機和集群安裝配置

  3.了解內部參數的簡單配置

二、Kafka簡介

 

  Kafka是由Apache軟件基金會開發的一個開源流處理平台,由Scala和Java編寫。Kafka是一種高吞吐量的分佈式發布訂閱消息系統,它可以處理消費者在網站中的所有動作流數據。 這種動作(網頁瀏覽,搜索和其他用戶的行動)是在現代網絡上的許多社會功能的一個關鍵因素。 這些數據通常是由於吞吐量的要求而通過處理日誌和日誌聚合來解決。 對於像Hadoop一樣的日誌數據和離線分析系統,但又要求實時處理的限制,這是一個可行的解決方案。Kafka的目的是通過Hadoop的并行加載機制來統一線上和離線的消息處理,也是為了通過集群來提供實時的消息。——百度百科

三、Kafka使用場景

  • 日誌收集:一個公司可以用Kafka可以收集各種服務的log,通過kafka以統一接口服務的方式開放給各種consumer,例如hadoop、Hbase、Solr等。
  • 消息系統:解耦和生產者和消費者、緩存消息等。
  • 用戶活動跟蹤:Kafka經常被用來記錄web用戶或者app用戶的各種活動,如瀏覽網頁、搜索、點擊等活動,這些活動信息被各個服務器發布到kafka的topic中,然後訂閱者通過訂閱這些topic來做實時的監控分析,或者裝載到hadoop、數據倉庫中做離線分析和挖掘。
  • 運營指標:Kafka也經常用來記錄運營監控數據。包括收集各種分佈式應用的數據,生產各種操作的集中反饋,比如報警和報告。

四、相關術語

  • Broker

Kafka集群包含一個或多個服務器,這種服務器被稱為broker

  • Topic

每條發布到Kafka集群的消息都有一個類別,這個類別被稱為Topic。

  • Partition

Partition是物理上的概念,每個Topic包含一個或多個Partition.

  • Producer

負責發布消息到Kafka broker

  • Consumer

消息消費者,向Kafka broker讀取消息的客戶端。

  • Consumer Group

每個Consumer屬於一個特定的Consumer Group(可為每個Consumer指定group name,若不指定group name則屬於默認的group)。

五、單機安裝

  1.安裝jdk,輸入yum install -y java-1.8.0-openjdk* 耐心等待即可,安裝完成以後,輸入$ java -version,檢查是否安裝成功。

  2.由於Kafka是基於Zookeeper環境的,我們安裝一下Zookeeper(不安裝也可以,最好配置一下,便於後期理解,建議安裝3.*版本)。我以前寫過Zookeeper的安裝過程,想看的可以去了解一下

  3.輸入wget https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz 等待下載完成,Kafka現在是0.*,1.*,2.*三個版本,這裏建議使用1.*版本,你也可以下載最新的2.3.1版本,下載方式wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.1/kafka_2.12-2.3.1.tgz,這裏說一下,kafka_2.12-2.3.1.tgz前面的2.12是Scala語言版本,後面的2.3.1才是我們的Kafka的版本。官網地址:

  4.解壓tar -zxvf kafka_2.11-1.1.0.tgz 

  5.進入到config目錄下,vim server.properties,我們在123行可以看到Zookeeper的配置如下(不是localhost的自己改一下)

  6.啟動$ ./bin/kafka-server-start.sh -daemon config/server.properties 

  7.進入Zookeeper下查看節點信息。

  輸入jps看到我們的進程kafka,單機配置成功。

六、集群安裝

  1.重複單機安裝步驟。

  2.修改配置文件,在21行broker.id設置為不同的数字,第一台可以設置0,第二台1,依次類推,在123行 zookeeper.connect寫入Zookeeper集群連接,例如zookeeper.connect=47.105.137.93:2181,114.215.145.41:2181,115.29.151.4:2181。

  3.分別啟動三個Kafka。

  4.測試集群,創建一個主題./bin/kafka-topics.sh –create –zookeeper  47.105.137.93:2181,114.215.145.41:2181,115.29.151.4:2181  –replication-factor 1 –partitions 1 –topic test

  到其它服務器下查看現有主題即可。

七、簡單使用

  1.創建主題 ./bin/kafka-topics.sh –create –zookeeper IP:端口,IP:端口 –replication-factor 副本數 –partitions 分區數 –topic 主題名

   例如:./bin/kafka-topics.sh –create –zookeeper 47.105.137.93:2181,114.215.145.41:2181,115.29.151.4:2181 –replication-factor 1 –partitions 1 –topic xiaocaijishu

  2.查看現有主題 ./bin/kafka-topics.sh –list –zookeeper IP:端口,IP:端口

   例如:./bin/kafka-topics.sh –list –zookeeper 47.105.137.93:2181,114.215.145.41:2181,115.29.151.4:2181

  3.刪除主題 ./bin/kafka-topics.sh –delete –topic xiaocaijishu2 –zookeeper IP:端口,IP:端口

  例如:./bin/kafka-topics.sh –delete –topic xiaocaijishu2 –zookeeper 47.105.137.93:2181,114.215.145.41:2181,115.29.151.4:2181  

   4.發送消息 ./bin/kafka-console-producer.sh –broker-list Kafka服務器IP:9092 –topic 主題名

  例如:./bin/kafka-console-producer.sh –broker-list 47.105.137.93:9092 –topic xiaocaijishu

  5.消費消息./bin/kafka-console-consumer.sh –bootstrap-server Kafka服務器IP:9092 –consumer-property group.id=消費組名稱 –topic 主題名

  例如: ./bin/kafka-console-consumer.sh –bootstrap-server 47.105.137.93:9092 –consumer-property group.id=xiaocaiGroup –topic xiaocaijishu

  6.查看現有消費組 ./bin/kafka-consumer-groups.sh –bootstrap-server Kafka服務器IP:9092 –list

   例如:./bin/kafka-consumer-groups.sh –bootstrap-server 47.105.137.93:9092 –list

 

 

最進弄了一個公眾號,小菜技術,歡迎大家的加入

 

 

 

 

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

【其他文章推薦】

※想知道大胸女孩都會買什麼款式的內衣呢?d cup內衣,e cup內衣挑選完美致勝推薦

※濃郁的奶香牛軋糖-最好吃的伴手禮,送禮要送進心崁裡!

※專為各大企業長短期商務包車接送的服務

※來台東旅遊不可錯過的,台東必買名產 「池上米、地瓜酥、洛神花」都在"購夠台東"網路商城皆買的到哦!

※2020推薦婚禮錄影台北精選18家專業團隊

※票選台中最佳親子活動.情侶約會必住的一中街住宿,旅遊行程推薦!

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳

2020年春晚將應用5G、8K等創新技術

  新華社北京1月14日電(記者余俊傑)中央廣播電視總台14日在京舉行2020年春節聯歡晚會創新應用啟動儀式,將利用5G、8K、4K和VR等新技術為觀眾帶來全新觀看體驗。

  據介紹,基於5G網絡的移動拍攝和景觀等機位的4K信號,都將接入春晚製作系統,為春晚全4K智能直播提供技術支持。同時,總台還將採用5G+8K技術實現多機位拍攝,並製作8K版春晚。

本站聲明:網站內容來源於裝修網http://et.21cn.com/,如有侵權,請聯繫我們

【其他文章推薦】

※想知道台北團體制服哪裡比較便宜嗎?

※專業台北團體服訂制、設計一條龍服務!

※住宿攻略懶人包,精選平價舒適一中街住宿,一中街民宿出遊的休息好去處!

※2020票選台東必買 最佳節慶送禮、年節伴手禮,釋迦禮盒,小農禮盒深受國人的青睞!

※各類招牌、海報、大圖輸出,急件製作施工!

澤東新人李宛妲時尚首亮相

澤東新人李宛妲時尚首亮相

李宛妲Vanda以一組清新少女造型登上雜誌,原生態天然氣質與摩登混血的立體五官彼此加分,與眾不同的靈動生命力令這位15歲的女孩在陽光頗好的初春午後,令人眼前一亮。

李宛妲清新初春LOOK

18日,澤東電影宣告新人李宛妲的加入,她自此成為張震、張榕容的小師妹,同時也是澤東成立26年以來年紀最小的簽約演員。李宛妲帶着電影處女作《恭弘=叶 恭弘問4》正式入行,她在片中擔任女主角,與甄子丹飾演的恭弘=叶 恭弘問有不少對手戲。談及對未來的期待時,李宛妲表示,“我希望能學到很多東西,希望能夠靜一點,也希望自己越來越好。”

李宛妲首登時尚雜誌

被陽光偏愛的原生態少女

拍攝現場,李宛妲以清新初春LOOK顯露出專屬於15歲女孩的陽光與自信,而棒球外套、鴨舌帽、豹紋毛衣的不同搭配更讓人看到這位原生態少女的各種可能性。身處初春午後的李宛妲,與綠植親近互動,笑容明媚、自在隨性,仿若置身於她最熟悉和熱愛的家鄉——西雙版納。李宛妲03年出生於雲南,其父是從事西雙版納熱帶雨林修復和再造工作的德國生態學博士。她從與大自然相處的過程培養出獨特的性格,對現代與原始有不同的理解,也令她敢於大膽嘗試不同的時尚風格。“我小時候最喜歡那種誇張的風格,紅配綠,爆炸捲髮什麼的,現在的話,我覺得我什麼風格都可以嘗試。”

鏡頭前的李宛妲眼神清澈純凈,簡單的穿搭在她的演繹下完美詮釋出最舒服的少女狀態。對於生活與自然的認知,李宛妲皆在“都市定式”之外,她喜歡自己的小麥色皮膚,熱愛騎馬、射箭,且射箭為專業運動員的水平,而對於戶外活動的熱愛絲毫不影響她對家的眷顧。“手機對我而言是用來跟想念的人溝通,我特別喜歡阿米爾·汗的電影,因為他會用電影保護他的家、家人,是一種不一樣的精神。”如此心意,質樸又別樣。

澤東新簽最年輕藝人出任《恭弘=叶 恭弘問4》女主

李宛妲天然與現代感融合一體的特殊氣質,在她10歲時就曾吸引了知名攝影師肖全的鏡頭。肖全為她與姐姐拍了多組攝影作品並舉辦攝影展,而正是其中一組照片吸引到導演王家衛的目光,小女孩眉宇之間的質感讓他好奇Vanda的可能性,於是促成了她加入澤東電影,成為張震、張榕容的小師妹。據了解,正在學習舞蹈的李宛妲,已經被公司安排專門學習語文等不同功課,並有多個工作計劃將在今年爆發。

日前,李宛妲出席《恭弘=叶 恭弘問4》香港電影節記者會,這是她簽入澤東后的首度亮相。她在片中飾演出生於美國的華裔功夫少女若男,是吳樾扮演的太極堂堂主的女兒,與甄子丹飾演的恭弘=叶 恭弘問有不少對手戲,也因她的緣故激起了二人對武術的初心。該片是李宛妲的出道處女作,也是她第一次拍動作戲,處女作便擔女主,李宛妲很感謝前輩的提攜,“八爺、丹哥還有吳樾叔叔都很照顧我,讓我順利地完成表演。在這裏要謝謝他們,也希望不要給他們造成麻煩。”據悉,電影《恭弘=叶 恭弘問4》有望於今年上映,而新人演員李宛妲的大銀幕首秀也將與觀眾見面。

本站聲明:網站內容來源於江西熱線http://www.online.jx.cn,如有侵權請聯繫我們,我們將及時處理

【其他文章推薦】

※信用卡的機場接送服務好嗎?

台北桃園機場接送,網友超推,CP值超高,安全,寬敞又舒適

※想知道台東名產人氣商品是什麼?想知道更多台東知名伴手禮有哪些?

※評選台東伴手禮推薦商品「釋迦 」是台東必買伴手禮之一

※離島好好玩!小琉球必吃美食、必玩景點、最優惠的小琉球民宿套裝行程詳細攻略!

※濃郁的奶香牛軋糖-最好吃的伴手禮,送禮要送進心崁裡!

※找尋專業廣告設計,價格公道大圖輸出,背板品質佳