docker_go

package module
v3.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

README

vm-docker-go 单独部署

1. 配置说明

新增配置

docker_vm_host: 合约管理服务 docker_vm_port: 合约管理服务端口号

删除了chainmaker配置里用于配置合约管理container的参数

vm:
  enable_dockervm: true
  uds_open: false
#  dockervm_mount_path 存放合约文件和socket文件。如果开启本地socket，需要将该路径中的以chainid命名的文件夹 mount 到容器里的 /mount 目录下
  dockervm_mount_path: ../data/org1/docker-go  
  docker_vm_host: 10.197.78.11
  docker_vm_port: 22359
  max_send_msg_size: 20
  max_recv_msg_size: 20

2. 部署启动流程

2.1. 启动合约服务容器
  1. 打包合约服务的镜像

在vm-docker-go项目根目录下执行打包镜像操作

make build-image

可以通过如下命令查看镜像的版本信息

docker inspect <image-name> | jq '.[].ContainerConfig.Labels'
  1. 参数说明： 容器中的参数，如果不设置会采用默认参数，默认如下
# 是否开启unix domain socket 通信
ENV_ENABLE_UDS=false
# 最大用户数，同样约束了最大进程数量
ENV_USER_NUM=100
# 交易过期时间，单位（s）
ENV_TX_TIME_LIMIT=2
# 日志等级
ENV_LOG_LEVEL=INFO
# 日志是否打印到标准输出
ENV_LOG_IN_CONSOLE=false
# 每个合约最大启用的进程数量
ENV_MAX_CONCURRENCY=50
# 监听的端口。如果启用unix domain socket，则监听 /mount/sock/cdm.sock 路径。
ENV_VM_SERVICE_PORT=22359
# 是否开启 pprof
ENV_ENABLE_PPROF=
# 指定 pprof 端口
ENV_PPROF_PORT=
ENV_MAX_SEND_MSG_SIZE= 
ENV_MAX_RECV_MSG_SIZE=
  1. 启动命令

容器的运行需要privileged的权限，启动命令添加 --privileged 参数

3.1 以tcp方式启动： 参数中需要再添加对外暴露的端口映射

docker run -it -p22359:22359 --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

例如 启动四个容器的脚本，分别监听22351 - 22354，并打印容器输出到标准输出:

docker run --rm -d -p22351:22359 --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run --rm -d -p22352:22359 --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run --rm -d -p22353:22359 --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run --rm -d -p22354:22359 --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

3.1 以uds方式启动： 参数中需要再添加：

  1. 启动uds的环境变量 -e ENV_ENABLE_UDS=true
  2. 通过 -v 指定本地合约文件和socket文件的映射
docker run -it -e ENV_ENABLE_UDS=true -v /root/chainmaker.org/chainmaker-go/build/release/chainmaker-v2.3.0-wx-org.chainmaker.org/data/wx-org.chainmaker.org/docker-go/chain1:/mount --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

例如 启动四个容器的脚本:

docker run -it -e ENV_ENABLE_UDS=true -v /root/chainmaker.org/chainmaker-go/build/release/chainmaker-v2.3.0-wx-org1.chainmaker.org/data/wx-org1.chainmaker.org/docker-go/chain1:/mount --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run -it -e ENV_ENABLE_UDS=true -v /root/chainmaker.org/chainmaker-go/build/release/chainmaker-v2.3.0-wx-org2.chainmaker.org/data/wx-org2.chainmaker.org/docker-go/chain1:/mount --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run -it -e ENV_ENABLE_UDS=true -v /root/chainmaker.org/chainmaker-go/build/release/chainmaker-v2.3.0-wx-org3.chainmaker.org/data/wx-org3.chainmaker.org/docker-go/chain1:/mount --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0

docker run -it -e ENV_ENABLE_UDS=true -v /root/chainmaker.org/chainmaker-go/build/release/chainmaker-v2.3.0-wx-org4.chainmaker.org/data/wx-org4.chainmaker.org/docker-go/chain1:/mount --privileged chainmakerofficial/chainmaker-vm-docker-go:v2.3.0
2.2. 配置启动 chainmaker

修改chainmaker配置文件中vm配置中的相关配置

2.2.1 tcp方式

保持 uds_open 为false，并配置docker_vm_host和docker_vm_port的值

uds_open: false
docker_vm_host: 10.197.78.11
docker_vm_port: 22359
2.2.2 uds方式

配置中 如果开启 uds 请保证 dockervm_mount_path 的路径与 容器中mount进容器中的路径一致。

uds_open: true
dockervm_mount_path: ../data/org1/docker-go

正常启动chainmaker: ./chainmaker strat -c config

Documentation

Overview

Copyright (C) THL A29 Limited, a Tencent company. All rights reserved.

SPDX-License-Identifier: Apache-2.0

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDockerManager 

func NewDockerManager(chainId string, vmConfig map[string]interface{}) protocol.VmInstancesManager

NewDockerManager return docker manager and running a default container

Types

type BlockElapsedTime 

type BlockElapsedTime struct {
	// contains filtered or unexported fields
}

func (*BlockElapsedTime) AddTxElapsedTime 

func (b *BlockElapsedTime) AddTxElapsedTime(t *TxElapsedTime)

todo add lock

func (*BlockElapsedTime) ToString 

func (b *BlockElapsedTime) ToString() string

type ClientManager 

type ClientManager interface {
	PutTxRequest(txRequest *protogo.CDMMessage)

	PutSysCallResponse(sysCallResp *protogo.CDMMessage)

	RegisterReceiveChan(chainId, txId string, receiveCh chan *protogo.CDMMessage) error

	DeleteReceiveChan(chainId, txId string) bool

	GetVMConfig() *config.DockerVMConfig

	GetUniqueTxKey(txId string) string

	NeedSendContractByteCode() bool

	HasActiveConnections() bool
}

type DockerManager 

type DockerManager struct {
	RequestMgr *RequestMgr
	// contains filtered or unexported fields
}

func (*DockerManager) AfterSchedule 

func (m *DockerManager) AfterSchedule(blockFingerprint string, blockHeight uint64)

func (*DockerManager) BeforeSchedule 

func (m *DockerManager) BeforeSchedule(blockFingerprint string, blockHeight uint64)

func (*DockerManager) NewRuntimeInstance 

func (m *DockerManager) NewRuntimeInstance(txSimContext protocol.TxSimContext, chainId, method,
	codePath string, contract *common.Contract,
	byteCode []byte, logger protocol.Logger) (protocol.RuntimeInstance, error)

func (*DockerManager) StartVM 

func (m *DockerManager) StartVM() error

StartVM Start Docker VM

func (*DockerManager) StopVM 

func (m *DockerManager) StopVM() error

StopVM stop docker vm and remove container, image

type RequestMgr 

type RequestMgr struct {
	RequestMap map[string]*BlockElapsedTime
	// contains filtered or unexported fields
}

func NewRequestMgr 

func NewRequestMgr() *RequestMgr

func (*RequestMgr) AddRequest 

func (r *RequestMgr) AddRequest(requestId string)

func (*RequestMgr) AddTx 

func (r *RequestMgr) AddTx(requestId string, txTime *TxElapsedTime)

AddTx if add tx to tx request map need lock

func (*RequestMgr) PrintBlockElapsedTime 

func (r *RequestMgr) PrintBlockElapsedTime(requestId string) string

func (*RequestMgr) RemoveRequest 

func (r *RequestMgr) RemoveRequest(requestId string)

type RuntimeInstance 

type RuntimeInstance struct {
	ChainId       string // chain id
	ClientManager ClientManager
	Log           protocol.Logger
	DockerManager *DockerManager
	// contains filtered or unexported fields
}

RuntimeInstance docker-go runtime

func (*RuntimeInstance) Invoke 

func (r *RuntimeInstance) Invoke(contract *commonPb.Contract, method string,
	byteCode []byte, parameters map[string][]byte, txSimContext protocol.TxSimContext,
	gasUsed uint64) (contractResult *commonPb.ContractResult, execOrderTxType protocol.ExecOrderTxType)

Invoke process one tx in docker and return result nolint: gocyclo, revive

type SysCallElapsedTime 

type SysCallElapsedTime struct {
	OpType    protogo.CDMType
	StartTime int64
	//EndTime              int64
	TotalTime            int64
	StorageTimeInSysCall int64
}

func NewSysCallElapsedTime 

func NewSysCallElapsedTime(opType protogo.CDMType, startTime int64, totalTime int64,
	storageTime int64) *SysCallElapsedTime

func (*SysCallElapsedTime) ToString 

func (s *SysCallElapsedTime) ToString() string

type TxElapsedTime 

type TxElapsedTime struct {
	TxId                  string
	StartTime             int64
	EndTime               int64
	TotalTime             int64
	SysCallCnt            int32
	SysCallTime           int64
	StorageTimeInSysCall  int64
	ContingentSysCallCnt  int32
	ContingentSysCallTime int64
	CrossCallCnt          int32
	CrossCallTime         int64
	SysCallList           []*SysCallElapsedTime
}

func NewTxElapsedTime 

func NewTxElapsedTime(txId string, startTime int64) *TxElapsedTime

func (*TxElapsedTime) Add 

func (e *TxElapsedTime) Add(t *TxElapsedTime)

func (*TxElapsedTime) AddContingentSysCall 

func (e *TxElapsedTime) AddContingentSysCall(spend int64)

func (*TxElapsedTime) AddSysCallElapsedTime 

func (e *TxElapsedTime) AddSysCallElapsedTime(sysCallElapsedTime *SysCallElapsedTime)

todo add lock (maybe do not need)

func (*TxElapsedTime) AddToSysCallList 

func (e *TxElapsedTime) AddToSysCallList(sysCallElapsedTime *SysCallElapsedTime)

todo add lock (maybe do not need)

func (*TxElapsedTime) PrintSysCallList 

func (e *TxElapsedTime) PrintSysCallList() string

func (*TxElapsedTime) ToString 

func (e *TxElapsedTime) ToString() string

Source Files

View all Source files

Directories

Path Synopsis
pb
protogo

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.