kafka叢集部署

1.準備工作

名稱	IP地址	Hostname
zk1	192.168.247.101	zookeeper1
zk2	192.168.247.102	zookeeper2
zk3	192.168.247.103	zookeeper3
kafka1	192.168.247.201	kafka1
kafka2	192.168.247.202	kafka2
kafka3	192.168.247.203	kafka3
kafka4	192.168.247.204	kafka4

為了保證整個叢集的正常工作, 需要給叢集中的各個節點設定工作目錄, 我們要保證各個節點工作目錄是相同的

# 在以上各個節點的家目錄建立工作目錄:
$ mkdir ~/kafka

2. 生成證書檔案

2.1 編寫配置檔案

# crypto-config.yaml
OrdererOrgs:
  - Name: Orderer
    Domain: test.com
    Specs:
      - Hostname: orderer0	# 第1個排序節點: orderer0.test.com
      - Hostname: orderer1	# 第2個排序節點: orderer1.test.com
      - Hostname: orderer2  # 第3個排序節點: orderer2.test.com 


PeerOrgs:
  - Name: OrgGo
    Domain: orggo.test.com
    Template:
      Count: 2  # 當前go組織兩個peer節點
    Users:
      Count: 1

  - Name: OrgCpp
    Domain: orgcpp.test.com
    Template:
      Count: 2  # 當前cpp組織兩個peer節點
    Users:
      Count: 1

2.2 生成證書

$ cryptogen generate --config=crypto-config.yaml
$ tree ./ -L 1
./
├── ` 
crypto-config`   -> 證書檔案目錄
└── crypto-config.yaml

3. 生成創始塊和通道檔案

3.1 編寫配置檔案


---
################################################################################
#
#   Section: Organizations
#
#   - This section defines the different organizational identities which will
#   be referenced later in the configuration.
#
################################################################################
Organizations:
    - &OrdererOrg
        Name: OrdererOrg
        ID: OrdererMSP
        MSPDir: crypto-config/ordererOrganizations/test.com/msp

    - &go_org
        Name: OrgGoMSP
        ID: OrgGoMSP
        MSPDir: crypto-config/peerOrganizations/orggo.test.com/msp
        AnchorPeers:
            - Host: peer0.orggo.test.com
              Port: 7051

    - &cpp_org
        Name: OrgCppMSP
        ID: OrgCppMSP
        MSPDir: crypto-config/peerOrganizations/orgcpp.test.com/msp
        AnchorPeers:
            - Host: peer0.orgcpp.test.com
              Port: 7051

################################################################################
#
#   SECTION: Capabilities
#
################################################################################
Capabilities:
    Global: &ChannelCapabilities
        V1_1: true
    Orderer: &OrdererCapabilities
        V1_1: true
    Application: &ApplicationCapabilities
        V1_2: true

################################################################################
#
#   SECTION: Application
#
################################################################################
Application: &ApplicationDefaults
    Organizations:

################################################################################
#
#   SECTION: Orderer
#
################################################################################
Orderer: &OrdererDefaults
    # Available types are "solo" and "kafka"
    OrdererType: kafka
    Addresses:
        # 排序節點伺服器地址
        - orderer0.test.com:7050
        - orderer1.test.com:7050
        - orderer2.test.com:7050

    BatchTimeout: 2s
    BatchSize:
        MaxMessageCount: 10
        AbsoluteMaxBytes: 99 MB
        PreferredMaxBytes: 512 KB
    Kafka:
        Brokers: 
            # kafka伺服器地址
            - 192.168.247.201:9092
            - 192.168.247.202:9092
            - 192.168.247.203:9092
            - 192.168.247.204:9092
    Organizations:

################################################################################
#
#   Profile
#
################################################################################
Profiles:
    OrgsOrdererGenesis:
        Capabilities:
            <<: *ChannelCapabilities
        Orderer:
            <<: *OrdererDefaults
            Organizations:
                - *OrdererOrg
            Capabilities:
                <<: *OrdererCapabilities
        Consortiums:
            SampleConsortium:
                Organizations:
                    - *go_org
                    - *cpp_org
    OrgsChannel:
        Consortium: SampleConsortium
        Application:
            <<: *ApplicationDefaults
            Organizations:
                - *go_org
                - *cpp_org
            Capabilities:
                <<: *ApplicationCapabilities

3.2 生成通道和創始塊檔案

生成創始塊檔案

# 我們先建立一個目錄 channel-artifacts 儲存生成的檔案, 目的是為了和後邊的配置檔案模板的配置項保持一致
$ mkdir channel-artifacts
# 生成通道檔案
$ configtxgen -profile OrgsOrdererGenesis -outputBlock ./channel-artifacts/genesis.block

生成通道檔案

# 生成創始塊檔案
$ configtxgen -profile OrgsChannel -outputCreateChannelTx ./channel-artifacts/channel.tx -channelID testchannel

4. Zookeeper設定

4.1 基本概念

zookeeper 的運作流程
在配置之前, 讓我們先了解一下 Zookeeper 的基本運轉流程:

選舉Leader
- 選舉Leader過程中演算法有很多，但要達到的選舉標準是一致的
- Leader要具有最高的執行ID，類似root許可權。
- 叢集中大多數的機器得到響應並跟隨選出的Leader。
資料同步
Zookeeper的叢集數量

Zookeeper 叢集的數量可以是 3, 5, 7, 它值需要是一個奇數以避免腦裂問題（split-brain）的情況。同時選擇大於1的值是為了避免單點故障，如果叢集的數量超過7個Zookeeper服務將會無法承受。

4.2 zookeeper配置檔案模板

配置檔案模板

下面我們來看一個示例配置檔案, 研究下zookeeper如何配置:

version: '2'
services:
  zookeeper1:
    container_name: zookeeper1
    hostname: zookeeper1
    image: hyperledger/fabric-zookeeper
    restart: always
    environment:
      # ID在集合中必須是唯一的並且應該有一個值，在1和255之間。
      - ZOO_MY_ID=1
      # server.x=hostname:prot1:port2
      - ZOO_SERVERS=server.1=zookeeper1:2888:3888 server.2=zookeeper2:2888:3888 server.3=zookeeper3:2888:3888
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
    extra_hosts:
      - zookeeper1:192.168.24.201
      - zookeeper2:192.168.24.202
      - zookeeper3:192.168.24.203
      - kafka1:192.168.24.204
      - kafka2:192.168.24.205
      - kafka3:192.168.24.206
      - kafka4:192.168.24.207

相關配置項解釋:
1. docker 的restart策略
  - no – 容器退出時不要自動重啟，這個是預設值。
  - on-failure[:max-retries] – 只在容器以非0狀態碼退出時重啟，例如：on-failure:10
  - always – 不管退出狀態碼是什麼始終重啟容器
  - unless-stopped – 不管退出狀態碼是什麼始終重啟容器，不過當daemon啟動時，如果容器之前已經為停止狀態，不要嘗試啟動它。
2. 環境變數
  - ZOO_MY_ID
    
    zookeeper叢集中的當前zookeeper伺服器節點的ID, 在叢集中這個只是唯一的, 範圍: 1-255
  - ZOO_SERVERS
    - 組成zookeeper叢集的伺服器列表
    - 列表中每個伺服器的值都附帶兩個埠號
      
      第一個: 追隨者用來連線 Leader 使用的
      
      第二個: 使用者選舉 Leader
3. zookeeper伺服器中三個重要埠:
  - 訪問zookeeper的埠: 2181
  - zookeeper叢集中追隨者連線 Leader 的埠: 2888
  - zookeeper叢集中選舉 Leader 的埠: 3888
4. extra_hosts
  - 設定伺服器名和其指向的IP地址的對應關係
  - zookeeper1:192.168.24.201
    - 看到名字zookeeper1就會將其解析為IP地址: 192.168.24.201

4.3 各個zookeeper節點的配置

zookeeper1 配置

# zookeeper1.yaml
version: '2'

services:

  zookeeper1:
    container_name: zookeeper1
    hostname: zookeeper1
    image: hyperledger/fabric-zookeeper:latest
    restart: always
    environment:
      # ID在集合中必須是唯一的並且應該有一個值，在1和255之間。
      - ZOO_MY_ID=1
      # server.x=[hostname]:nnnnn[:nnnnn]
      - ZOO_SERVERS=server.1=zookeeper1:2888:3888 server.2=zookeeper2:2888:3888 server.3=zookeeper3:2888:3888
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

zookeeper2 配置

# zookeeper2.yaml
version: '2'

services:

  zookeeper2:
    container_name: zookeeper2
    hostname: zookeeper2
    image: hyperledger/fabric-zookeeper:latest
    restart: always
    environment:
      # ID在集合中必須是唯一的並且應該有一個值，在1和255之間。
      - ZOO_MY_ID=2
      # server.x=[hostname]:nnnnn[:nnnnn]
      - ZOO_SERVERS=server.1=zookeeper1:2888:3888 server.2=zookeeper2:2888:3888 server.3=zookeeper3:2888:3888
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

zookeeper3 配置

# zookeeper3.yaml
version: '2'

services:

  zookeeper3:
    container_name: zookeeper3
    hostname: zookeeper3
    image: hyperledger/fabric-zookeeper:latest
    restart: always
    environment:
      # ID在集合中必須是唯一的並且應該有一個值，在1和255之間。
      - ZOO_MY_ID=3
      # server.x=[hostname]:nnnnn[:nnnnn]
      - ZOO_SERVERS=server.1=zookeeper1:2888:3888 server.2=zookeeper2:2888:3888 server.3=zookeeper3:2888:3888
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

5. Kafka設定

5.1 基本概念

Katka是一個分散式訊息系統，由LinkedIn使用scala編寫，用作LinkedIn的活動流（Activitystream)和運營資料處理管道（Pipeline）的基礎。具有高水平擴充套件和高吞吐量。

在Fabric網路中，資料是由Peer節點提交到Orderer排序服務，而Orderer相對於Kafka來說相當於上游模組，且Orderer還兼具提供了對資料進行排序及生成符合配置規範及要求的區塊。而使用上游模組的資料計算、統計、分析，這個時候就可以使用類似於Kafka這樣的分散式訊息系統來協助業務流程。

有人說Kafka是一種共識模式，也就是說平等信任，所有的HyperLedger Fabric網路加盟方都是可信方，因為訊息總是均勻地分佈在各處。但具體生產使用的時候是依賴於背書來做到確權，相對而言，Kafka應該只能是一種啟動Fabric網路的模式或型別。

Zookeeper一種在分散式系統中被廣泛用來作為分散式狀態管理、分散式協調管理、分散式管和分散式鎖服務的叢集。Kafka增加和減少伺服器都會在Zookeeper節點上觸發相應的事件，Kafka系統會捕獲這些事件，進行新一輪的負載均衡，客戶端也會捕獲這些事件來進行新一輪的處理。

Orderer排序服務是Fablic網路事務流中的最重要的環節，也是所有請求的點，它並不會立刻對請求給予回饋，一是因為生成區塊的條件所限，二是因為依託下游叢集的訊息處理需要等待結果。

5.2 kafka配置檔案模板

kafka配置檔案模板
```
version: '2'

services:
  kafka1:
    container_name: kafka1
    hostname: kafka1
    image: hyperledger/fabric-kafka
    restart: always
    environment:
      # broker.id
      - KAFKA_BROKER_ID=1
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=3
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
      # 99 * 1024 * 1024 B
      - KAFKA_MESSAGE_MAX_BYTES=103809024 
      - KAFKA_REPLICA_FETCH_MAX_BYTES=103809024 # 99 * 1024 * 1024 B
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_LOG_RETENTION_MS=-1
      - KAFKA_HEAP_OPTS=-Xmx256M -Xms128M
    ports:
      - 9092:9092
    extra_hosts:
      - zookeeper1:192.168.24.201
      - zookeeper2:192.168.24.202
      - zookeeper3:192.168.24.203
      - kafka1:192.168.24.204
      - kafka2:192.168.24.205
      - kafka3:192.168.24.206
      - kafka4:192.168.24.207
```
- 配置項解釋
1. Kafka 預設埠為: 9092
2. 環境變數:
  - KAFKA_BROKER_ID
    - 是一個唯一的非負整數, 可以作為代理Broker的名字
  - KAFKA_MIN_INSYNC_REPLICAS
    - 最小同步備份
    - 該值要小於環境變數 KAFKA_DEFAULT_REPLICATION_FACTOR的值
  - KAFKA_DEFAULT_REPLICATION_FACTOR
    - 默認同步備份, 該值要小於kafka叢集數量
  - KAFKA_ZOOKEEPER_CONNECT
    - 指向zookeeper節點的集合
  - KAFKA_MESSAGE_MAX_BYTES
    - 訊息的最大位元組數
    - 和配置檔案configtx.yaml中的Orderer.BatchSize.AbsoluteMaxBytes對應
    - 由於訊息都有頭資訊, 所以這個值要比計算出的值稍大, 多加1M就足夠了
  - KAFKA_REPLICA_FETCH_MAX_BYTES=103809024
    - 副本最大位元組數, 試圖為每個channel獲取的訊息的位元組數
    - AbsoluteMaxBytes<KAFKA_REPLICA_FETCH_MAX_BYTES <= KAFKA_MESSAGE_MAX_BYTES
  - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
    - 非一致性的 Leader 選舉
      
      開啟: true
      
      關閉: false
  - KAFKA_LOG_RETENTION_MS=-1
    - 對壓縮日誌保留的最長時間
    - 這個選項在Kafka中已經預設關閉
  - KAFKA_HEAP_OPTS
    - 設定堆記憶體大小, kafka預設為 1G
      
      -Xmx256M -> 允許分配的堆記憶體
      
      -Xms128M -> 初始分配的堆記憶體

5.3 各個kafka節點的配置

kafka1 配置

# kafka1.yaml
version: '2'

services:

  kafka1:
    container_name: kafka1
    hostname: kafka1
    image: hyperledger/fabric-kafka:latest
    restart: always
    environment:
      # broker.id
      - KAFKA_BROKER_ID=1
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=3
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
      # 100 * 1024 * 1024 B
      - KAFKA_MESSAGE_MAX_BYTES=104857600 
      - KAFKA_REPLICA_FETCH_MAX_BYTES=104857600
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_LOG_RETENTION_MS=-1
      - KAFKA_HEAP_OPTS=-Xmx512M -Xms256M
    ports:
      - 9092:9092
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

kafka2 配置

# kafka2.yaml
version: '2'

services:

  kafka2:
    container_name: kafka2
    hostname: kafka2
    image: hyperledger/fabric-kafka:latest
    restart: always
    environment:
      # broker.id
      - KAFKA_BROKER_ID=2
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=3
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
      # 100 * 1024 * 1024 B
      - KAFKA_MESSAGE_MAX_BYTES=104857600 
      - KAFKA_REPLICA_FETCH_MAX_BYTES=104857600
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_LOG_RETENTION_MS=-1
      - KAFKA_HEAP_OPTS=-Xmx512M -Xms256M
    ports:
      - 9092:9092
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

kafka3 配置

# kafka3.yaml
version: '2'

services:

  kafka3:
    container_name: kafka3
    hostname: kafka3
    image: hyperledger/fabric-kafka:latest
    restart: always
    environment:
      # broker.id
      - KAFKA_BROKER_ID=3
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=3
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
      # 100 * 1024 * 1024 B
      - KAFKA_MESSAGE_MAX_BYTES=104857600 
      - KAFKA_REPLICA_FETCH_MAX_BYTES=104857600
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_LOG_RETENTION_MS=-1
      - KAFKA_HEAP_OPTS=-Xmx512M -Xms256M
    ports:
      - 9092:9092
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

kafka4 配置

# kafka4.yaml
version: '2'
services:

  kafka4:
    container_name: kafka4
    hostname: kafka4
    image: hyperledger/fabric-kafka:latest
    restart: always
    environment:
      # broker.id
      - KAFKA_BROKER_ID=4
      - KAFKA_MIN_INSYNC_REPLICAS=2
      - KAFKA_DEFAULT_REPLICATION_FACTOR=3
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
      # 100 * 1024 * 1024 B
      - KAFKA_MESSAGE_MAX_BYTES=104857600 
      - KAFKA_REPLICA_FETCH_MAX_BYTES=104857600
      - KAFKA_UNCLEAN_LEADER_ELECTION_ENABLE=false
      - KAFKA_LOG_RETENTION_MS=-1
      - KAFKA_HEAP_OPTS=-Xmx512M -Xms256M
    ports:
      - 9092:9092
    extra_hosts:
      - zookeeper1:192.168.247.101
      - zookeeper2:192.168.247.102
      - zookeeper3:192.168.247.103
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

6. orderer節點設定

6.1 orderer節點配置檔案模板

orderer節點配置檔案模板

version: '2'

services:

  orderer0.example.com:
    container_name: orderer0.example.com
    image: hyperledger/fabric-orderer
    environment:
      - CORE_VM_DOCKER_HOSTCONFIG_NETWORKMODE=aberic_default
      - ORDERER_GENERAL_LOGLEVEL=debug
      - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
      - ORDERER_GENERAL_LISTENPORT=7050
      - ORDERER_GENERAL_GENESISMETHOD=file
      - ORDERER_GENERAL_GENESISFILE=/var/hyperledger/orderer/orderer.genesis.block
      - ORDERER_GENERAL_LOCALMSPID=OrdererMSP
      - ORDERER_GENERAL_LOCALMSPDIR=/var/hyperledger/orderer/msp
      # enabled TLS
      - ORDERER_GENERAL_TLS_ENABLED=false
      - ORDERER_GENERAL_TLS_PRIVATEKEY=/var/hyperledger/orderer/tls/server.key
      - ORDERER_GENERAL_TLS_CERTIFICATE=/var/hyperledger/orderer/tls/server.crt
      - ORDERER_GENERAL_TLS_ROOTCAS=[/var/hyperledger/orderer/tls/ca.crt]
      
      - ORDERER_KAFKA_RETRY_LONGINTERVAL=10s
      - ORDERER_KAFKA_RETRY_LONGTOTAL=100s
      - ORDERER_KAFKA_RETRY_SHORTINTERVAL=1s
      - ORDERER_KAFKA_RETRY_SHORTTOTAL=30s
      - ORDERER_KAFKA_VERBOSE=true
      - ORDERER_KAFKA_BROKERS=[192.168.24.204:9092,192.168.24.205:9092,192.168.24.206:9092,192.168.24.207:9092]
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric
    command: orderer
    volumes:
      - ./channel-artifacts/genesis.block:/var/hyperledger/orderer/orderer.genesis.block
      - ./crypto-config/ordererOrganizations/example.com/orderers/orderer0.example.com/msp:/var/hyperledger/orderer/msp
      - ./crypto-config/ordererOrganizations/example.com/orderers/orderer0.example.com/tls/:/var/hyperledger/orderer/tls
    networks:
    default:
      aliases:
        - aberic
    ports:
      - 7050:7050
    extra_hosts:
      - kafka1:192.168.24.204
      - kafka2:192.168.24.205
      - kafka3:192.168.24.206
      - kafka4:192.168.24.207

細節解釋
1. 環境變數
  - ORDERER_KAFKA_RETRY_LONGINTERVAL
    - 每隔多長時間進行一次重試, 單位:秒
  - ORDERER_KAFKA_RETRY_LONGTOTAL
    - 總共重試的時長, 單位: 秒
  - ORDERER_KAFKA_RETRY_SHORTINTERVAL
    - 每隔多長時間進行一次重試, 單位:秒
  - ORDERER_KAFKA_RETRY_SHORTTOTAL
    - 總共重試的時長, 單位: 秒
  - ORDERER_KAFKA_VERBOSE
    - 啟用日誌與kafka進行互動, 啟用: true, 不啟用: false
  - ORDERER_KAFKA_BROKERS
    - 指向kafka節點的集合
2. 關於重試的時長
  - 先使用ORDERER_KAFKA_RETRY_SHORTINTERVAL進行重連, 重連的總時長為ORDERER_KAFKA_RETRY_SHORTTOTAL
  - 如果上述步驟沒有重連成功, 使用ORDERER_KAFKA_RETRY_LONGINTERVAL進行重連, 重連的總時長為ORDERER_KAFKA_RETRY_LONGTOTAL

6.3 orderer各節點的配置

orderer0配置

# orderer0.yaml
version: '2'

services:

  orderer0.test.com:
    container_name: orderer0.test.com
    image: hyperledger/fabric-orderer:latest
    environment:
      - CORE_VM_DOCKER_HOSTCONFIG_NETWORKMODE=kafka_default
      - ORDERER_GENERAL_LOGLEVEL=debug
      - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
      - ORDERER_GENERAL_LISTENPORT=7050
      - ORDERER_GENERAL_GENESISMETHOD=file
      - ORDERER_GENERAL_GENESISFILE=/var/hyperledger/orderer/orderer.genesis.block
      - ORDERER_GENERAL_LOCALMSPID=OrdererMSP
      - ORDERER_GENERAL_LOCALMSPDIR=/var/hyperledger/orderer/msp
      # enabled TLS
      - ORDERER_GENERAL_TLS_ENABLED=false
      - ORDERER_GENERAL_TLS_PRIVATEKEY=/var/hyperledger/orderer/tls/server.key
      - ORDERER_GENERAL_TLS_CERTIFICATE=/var/hyperledger/orderer/tls/server.crt
      - ORDERER_GENERAL_TLS_ROOTCAS=[/var/hyperledger/orderer/tls/ca.crt]
      
      - ORDERER_KAFKA_RETRY_LONGINTERVAL=10s
      - ORDERER_KAFKA_RETRY_LONGTOTAL=100s
      - ORDERER_KAFKA_RETRY_SHORTINTERVAL=1s
      - ORDERER_KAFKA_RETRY_SHORTTOTAL=30s
      - ORDERER_KAFKA_VERBOSE=true
      - ORDERER_KAFKA_BROKERS=[192.168.247.201:9092,192.168.247.202:9092,192.168.247.203:9092,192.168.247.204:9092]
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric
    command: orderer
    volumes:
      - ./channel-artifacts/genesis.block:/var/hyperledger/orderer/orderer.genesis.block
      - ./crypto-config/ordererOrganizations/test.com/orderers/orderer0.test.com/msp:/var/hyperledger/orderer/msp
      - ./crypto-config/ordererOrganizations/test.com/orderers/orderer0.test.com/tls/:/var/hyperledger/orderer/tls
    networks:
    default:
      aliases:
        - kafka
    ports:
      - 7050:7050
    extra_hosts:
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

orderer1配置

# orderer1.yaml
version: '2'

services:

  orderer1.test.com:
    container_name: orderer1.test.com
    image: hyperledger/fabric-orderer:latest
    environment:
      - CORE_VM_DOCKER_HOSTCONFIG_NETWORKMODE=kafka_default
      - ORDERER_GENERAL_LOGLEVEL=debug
      - ORDERER_GENERAL_LISTENADDRESS=0.0.0.0
      - ORDERER_GENERAL_LISTENPORT=7050
      - ORDERER_GENERAL_GENESISMETHOD=file
      - ORDERER_GENERAL_GENESISFILE=/var/hyperledger/orderer/orderer.genesis.block
      - ORDERER_GENERAL_LOCALMSPID=OrdererMSP
      - ORDERER_GENERAL_LOCALMSPDIR=/var/hyperledger/orderer/msp
      # enabled TLS
      - ORDERER_GENERAL_TLS_ENABLED=false
      - ORDERER_GENERAL_TLS_PRIVATEKEY=/var/hyperledger/orderer/tls/server.key
      - ORDERER_GENERAL_TLS_CERTIFICATE=/var/hyperledger/orderer/tls/server.crt
      - ORDERER_GENERAL_TLS_ROOTCAS=[/var/hyperledger/orderer/tls/ca.crt]
      
      - ORDERER_KAFKA_RETRY_LONGINTERVAL=10s
      - ORDERER_KAFKA_RETRY_LONGTOTAL=100s
      - ORDERER_KAFKA_RETRY_SHORTINTERVAL=1s
      - ORDERER_KAFKA_RETRY_SHORTTOTAL=30s
      - ORDERER_KAFKA_VERBOSE=true
      - ORDERER_KAFKA_BROKERS=[192.168.247.201:9092,192.168.247.202:9092,192.168.247.203:9092,192.168.247.204:9092]
    working_dir: /opt/gopath/src/github.com/hyperledger/fabric
    command: orderer
    volumes:
      - ./channel-artifacts/genesis.block:/var/hyperledger/orderer/orderer.genesis.block
      - ./crypto-config/ordererOrganizations/test.com/orderers/orderer1.test.com/msp:/var/hyperledger/orderer/msp
      - ./crypto-config/ordererOrganizations/test.com/orderers/orderer1.test.com/tls/:/var/hyperledger/orderer/tls
    networks:
    default:
      aliases:
        - kafka
    ports:
      - 7050:7050
    extra_hosts:
      - kafka1:192.168.247.201
      - kafka2:192.168.247.202
      - kafka3:192.168.247.203
      - kafka4:192.168.247.204

orderer2配置

# orderer2.yaml
version: '2'

services:

  orderer2.test.com 
 
              
           
              
              
            
            相關推薦
			   
            
            
            
 

    

    
    在Hyperledger fabric中搭建小型Kafka叢集
      
							
							
							kafka叢集部署
1.準備工作




名稱
IP地址
Hostname
組織結構




zk1
192.168.247.101
zookeeper1



zk2
192.168.247.102
zookeeper2



zk3
192.168.247. 

  
 

    

    
    Hyperledger Fabric中的Identity
      靈活性   src   細節   每一個   一個人   cati   余額   all   元素   Hyperledger Fabric中的Identity
什麽是Identity
區塊鏈網絡中存在如下的角色：peers， orderers, client application, administrat 

  
 

    

    
    Hyperledger Fabric-v1.1多節點叢集
       
 
  
  
 Fabric v1.1 
 1.環境安裝 
 1).安裝go 1.9.x  下載地址  http://golang.org/dl/ 
 配置環境 
  
  #go的安裝根目錄  export GOROOT=/usr/local/go  #go的工作路徑根目錄  export GOPAT 

  
 

    

    
    centos7.3中搭建hadoop分散式叢集環境詳細過程
       
 
 一、準備工作 
 1、準備3臺物理機或者虛擬機器； 
 2、安裝centos7系統； 
 3、準備好相關軟體包並拷貝相關軟體到目標伺服器上 
 hadoop-2.9.0.tar.gz 
 jdk-8u131-linux-x64.tar.gz 
 二、配置網路 
 1、設定靜態網路ip 
 1）設定靜 

  
 

    

    
    Hyperledger fabric 環境搭建
       
 
  
  
  
 title: Hyperledger fabric環境搭建 tags: Hyperledger, fabric ,區塊鏈 
  
 一、需要的環境 
  
  注意：本文是在CentOS下演示 
  
 1.安裝golang 
  
   下載golang git clone ht 

  
 

    

    
    Zookeeper叢集搭建和Kafka叢集的搭建
       
  
  
 Zookeeper！！！ 一、Zookeeper叢集搭建步驟 0）叢集規劃 在hadoop01、hadoop02和hadoop03三個節點上部署Zookeeper。 1）解壓安裝 （1）解壓zookeeper安裝包到/home/hadoop/insatll/目錄下 [[email  

  
 

    

    
    區塊鏈100講：Hyperledger Fabric 中的鏈碼（智慧合約）
      
1
鏈碼概念

網路執行環境我們已經啟動完成，現在我們從開發者的角度來認識一下完成交易所必須的智慧合約（在 Hyperledger Fabric 中被稱之為 Chaincode，也就是鏈上程式碼）的相關知識，以便於理解賬本中的資料到底是通過什麼方式進行操作。

Chaincode：鏈上程式碼，簡稱鏈碼，一般 

  
 

    

    
    Hyperledger fabric中的幾個重要的角色
      
                
Application Backend
存在的目的:
    後端應用程式服務支援應用程式關聯到移動裝置或者瀏覽器
關鍵角色：
    1）通過成員服務管理末端使用者和註冊者
    2）啟動交易請求，傳送請求到末端
Owned by
    Solution provid 

  
 

    

    
    【區塊鏈】Ubuntu下 Hyperledger Fabric環境搭建
      
							
							
							一、環境準備


檢視source列表


sudo vi /etc/apt/sources.list


替換資源：  因為安裝的系統的時候，如果選擇的國內就可以略過，如果選的是香港或者其他地方，需要把開頭的兩個字母換成  cn,  例如選擇香港是HK開頭，需 

  
 

    

    
    HyperLedger Fabric 環境搭建 跑e2e測試用例最新版CentOS 7.4
      
                網上大多數教程 你們是起不來服務的，我也是走了很多彎路，吭哧吭哧的爬了三天 終於搞定啟動成功。2018-10-20搭建成功。

按步驟做，不要跳。一步錯就有可能起不來，網上的坑我都踩過了看過各種教程，跟著我走不會出問題：

有時間我要好好整理一下這個步驟，寫的太挫了，但是肯定 

  
 

    

    
    Hyperledger Fabric 手動搭建【區塊鏈學習三】
      #Hyperledger Fabric 手動搭建
>前面我們學習了[區塊鏈是什麼](https://www.cnblogs.com/chenxi001/p/13496269.html)、還有[自動搭建](https://www.cnblogs.com/chenxi001/p/13472111.html)學習東 

  
 

    

    
    Hyperledger Fabric v1.1 單機多節點叢集環境搭建
       
 
  
  
 Fabric v1.1 
 1.環境安裝 
 1).安裝go 1.9.x  下載地址  http://golang.org/dl/ 
 配置環境 
  
  #go的安裝根目錄  export GOROOT=/usr/local/go  #go的工作路徑根目錄  export GOPAT 

  
 

    

    
    centos7中kafka叢集環境搭建部署
       
 
 一、前期準備 
 1、下載kafka安裝包 
 官方下載地址：http://kafka.apache.org/downloads.html 
 kafka_2.11-2.0.0.tgz 
   
 2、準備好要安裝的叢集環境的目標機器(3檯安裝centos7系統) 
 3、將下載好的壓縮包 

  
 

    

    
    Hyperledger fabric基於kafka共識機制單機搭建
      
                cd /opt/gopath/src/github.com/hyperledger/fabric/scripts/fabric-samples
mkdir 181021
cd 181021
mkdir chaincode
mkdir network
cp ../../firs 

  
 

    

    
    Hyperledger fabric網絡中transaction產生以及流轉過程
      sta   並不會   font   eid   teset   amp   包括   ntb   當前   一、發起transaction
當client想要發起一個transaction時，它會首先發送一個PROPOSE消息到它選擇的一組endorser節點，消息模式有以下兩種，節點可以自由選擇（可能有更 

  
 

    

    
    搭建基於hyperledger fabric的聯盟社區（三） --生成公私鑰證書及配置文件
      ger   tput   reat   cts   crypto   github   最終   pda   成功   一.生成公私鑰和證書
Fabric中有兩種類型的公私鑰和證書，一種是給節點之前通訊安全而準備的TLS證書，另一種是用戶登錄和權限控制的用戶證書。這些證書本來應該是由CA來頒發，但是目前只有兩 

  
 

    

    
    搭建基於hyperledger fabric的聯盟社區（八） --Fabric證書解析
      一個   憑證   密鑰   設計   根證書   私鑰   文件   ons   crt   
一.證書目錄解析
 
通過cryptogen生成所有證書文件後，以peerOrgannizations的第一個組織樹org1為例，每個目錄和對應文件的功能如下：
 
ca: 存放組織的根證書和對應的私鑰文件，默認 

  
 

    

    
    Hyperledger Fabric 開發和運行環境搭建
      root用戶   x86   doc   googl   保存   username   新建   iyu   out   一 環境配置
VirtualBox 5.1.12
Git 2.18.0
Go 1.10.3
Windows下設置GOPATH開發目錄
Vagrant 2.1.2
進入BIOS設置Virt 

  
 

    

    
    docker中搭建Hadoop叢集
       
  
  
 前提：jdk和ssh服務都已經安裝完成，如未完成，請參考博主所寫部落格 1、建立映象容器 -P將容器的所有埠對映到主機埠 docker run -itd -v /c/Users:/root/build -P -h master --name master --net mynetwork -- 

  
 

    

    
    一、hyperledger fabric 基礎環境搭建
       
 
 一、安裝環境：centos 7 
  
 二、docker 安裝 
 1、使用 root 許可權登入 Centos。確保 yum 包更新到最新。 
 sudo yum update 
 3、解除安裝舊版本(如果安裝過舊版本的話) 
 yum remove docker docke