config

Documentation

Index

• Constants
• Variables
• func CheckIsSuperPeer() bool
• func GetCPUSyncNum() int
• func SetLevelDBPath(leveldbPath string)
• type Config
• type NetModel

Constants

const (
	AreaNameResult_same      = 1 //相同
	AreaNameResult_different = 2 //不同

	NodeIdResult_offline = 1 //节点不在线，允许连接
	NodeIdResult_online  = 2 //节点已经在线，拒绝连接
	NodeIdResult_self    = 3 //自己连接自己

	VNodeIdResult_offline = 4 //虚拟节点不在线
	VNodeIdResult_online  = 5 //虚拟节点在线
)

const (
	Version_0 = 0 //
	Version_1 = 1 //此版本广播消息机制发生改变，只广播消息hash，节点自己去同步消息到本地

	Path_configDir = "conf"               //配置文件存放目录
	Core_keystore  = "keystore.key"       //密钥文件
	SQLITE3DB_name = "p2pmessagecache.db" //sqlite3数据库文件名称

	SQL_SHOW = false //是否打印sql语句

	Mining_block_time = 10
	Addr_byte_length  = 32

	MSGID_search_node              = 108 //搜索一个节点地址是否在线
	MSGID_search_node_recv         = 109 //搜索一个节点地址是否在线_返回
	MSGID_checkNodeOnline          = 110 //检查节点是否在线
	MSGID_checkNodeOnline_recv     = 111 //检查节点是否在线_返回
	MSGID_TextMsg                  = 112 //接收文本消息
	MSGID_getNearSuperIP           = 113 //从邻居节点得到自己的逻辑节点
	MSGID_getNearSuperIP_recv      = 114 //从邻居节点得到自己的逻辑节点_返回
	MSGID_multicast_online_recv    = 122 //接收节点上线广播
	MSGID_ask_close_conn           = 127 //询问关闭连接
	MSGID_ask_close_conn_recv      = 128 //询问关闭连接_返回
	MSGID_TextMsg_recv             = 129 //接收消息返回消息
	MSGID_getNearConnectVnode      = 115 //从邻居节点得到自己连接中的虚拟节点
	MSGID_getNearConnectVnode_recv = 116 //从邻居节点得到自己连接中的虚拟节点_返回
	MSGID_del_vnode                = 117 //通知邻居节点有vnode删除

	//---------------- 可靠传输加密通道协议 --------------------------
	MSGID_SearchAddr                = 130 //搜索一个节点，获取节点地址和身份公钥
	MSGID_SearchAddr_recv           = 131 //搜索一个节点，获取节点地址和身份公钥_返回
	MSGID_security_create_pipe      = 132 //发送密钥消息，对方建立通道
	MSGID_security_create_pipe_recv = 133 //发送密钥消息，对方建立通道_返回
	MSGID_security_pipe_error       = 134 //解密错误

	MSGID_searchID      = 135 //查询磁力节点的id
	MSGID_searchID_recv = 136 //查询磁力节点的id_返回

	MSGID_multicast_return = 211 //收到广播消息回复

	MSGID_multicast_offline_recv       = 212 // 接收广播告知某个节点下线
	MSGID_multicast_vnode_offline_recv = 213 // 接收广播告知某个虚拟节点下线

	MSGID_checkAddrOnline      = 214 // 询问指定的地址是否在线
	MSGID_checkAddrOnline_recv = 215 // 询问指定的地址是否在线_返回

	MSGID_checkVnodeAddrOnline      = 216 // 询问指定的虚拟地址是否在线
	MSGID_checkVnodeAddrOnline_recv = 217 // 询问指定的虚拟地址是否在线_返回

	MSGID_multicast_send_vnode_recv = 218 // 接收广播获取虚拟节点信息

	MsGID_recv_router_err = 219 // 接收广播获取虚拟节点信息

	//---------------- P2p代理 模块 --------------------------
	MSGID_sync_proxy             = 300 // 同步代理信息
	MSGID_sync_proxy_recv        = 301 // 同步代理信息_返回
	MSGID_search_addr_proxy      = 302 // 查询地址对应的代理信息
	MSGID_search_addr_proxy_recv = 303 // 查询地址对应的代理信息_返回

	//---------------- Vnode 模块 --------------------------
	MSGID_vnode_getstate            = 600 //查询一个节点是否开通了虚拟节点服务
	MSGID_vnode_getstate_recv       = 601 //查询一个节点是否开通了虚拟节点服务_返回
	MSGID_vnode_getNearSuperIP      = 602 //从邻居节点得到自己的逻辑节点
	MSGID_vnode_getNearSuperIP_recv = 603 //从邻居节点得到自己的逻辑节点_返回
	MSGID_vnode_searchID            = 604 //查询逻辑节点的id
	MSGID_vnode_searchID_recv       = 605 //查询逻辑节点的id_返回

	MSGID_MAX_ID = 700 // 最大消息id号限制，系统只能注册0-700之间的消息号消息，用户可以注册>=700消息号的消息
)

const (
	C_Server_name = "libp2parea" //网络名称
	C_root_name   = "root"       //网络管理员域名

	//服务器角色，只有局域网开发模式才能用
	C_role_client = "client" //客户端模式
	C_role_super  = "super"  //超级节点模式

)

const (
	CONN_TYPE_TCP  = 1 << 0 // tcp连接
	CONN_TYPE_QUIC = 1 << 1 // UDP
	CONN_TYPE_ALL  = 0xFF   // 全部连接
)

p2p连接方式

const (
	MAX_CLEAN_DATA_LENGTH           = 10000            // 单次最大清理数据量
	CLEAN_DATA_TIME                 = time.Minute * 30 // 每30分钟清理一次数据
	CLEAN_DATA_INTERVAL_TIME        = time.Second      // 删除的数据比较大时，清理中间的间隔时间
	CUR_VERSION              uint64 = 1                // 当前数据库版本号
)

const (
	TSK_build_temp_name        = "TSK_build_temp_name"        //定时查询临时域名
	TSK_build_temp_name_remove = "TSK_build_temp_name_remove" //删除一个临时域名，域名注册失败，过期

	TSK_find_name = "TSK_find_name" //定时查询域名
	//	TSK_build_temp_name_remove = "TSK_build_temp_name_remove" //删除一个临时域名，域名注册失败，过期
	TSK_name_sync_multicast = "TSK_name_sync_multicast" //定时广播需要同步的域名
	TSK_key_sync_multicast  = "TSK_key_sync_multicast"  //定时广播需要同步的公钥

	TSK_msg_timeout_remove = "TSK_msg_timeout_remove" //消息超时删除
)

const (
	Time_name_sync_multicast = 10 //广播需要同步的域名间隔时间 单位：秒
	Time_key_sync_multicast  = 10 //广播需要同步的公钥间隔时间 单位：秒
	Time_Multicast_online    = 60 //广播节点上线间隔时间 单位：秒
	Time_register_addr_name  = 10 //循环注册域名的地址间隔时间 单位：秒
	Time_find_name_self      = 20 //循环查找自己的域名间隔时间 单位：秒
	Time_getNear_super_ip    = 10 //循环获取相邻节点的超级节点ip地址 单位：秒
)

const (
	VOTE_agree_build_name      = "VOTE_agree_build_name"      //同意构建域名
	VOTE_find_name             = "VOTE_find_name"             //查找到的域名地址
	VOTE_find_keyname          = "VOTE_find_keyname"          //投票公钥对应的域名
	VOTE_DISAGREE_find_keyname = "VOTE_DISAGREE_find_keyname" //投票公钥对应的域名为空
)

const (
	MaxMachineIDLen = 128 // 最大machineID长度
)

相关限制信息

const MsgCacheTimeOver = 60 * 60 * 24

Variables

var (
	AddrPre                     = "TEST"
	Wallet_keystore_default_pwd = "123456789"

	VNODE_get_neighbor_vnode_tiker = []time.Duration{time.Second * 1}  //定时获取邻居节点的虚拟节点地址
	VNODE_tiker_sync_logical_vnode = []time.Duration{time.Second * 10} //每个虚拟节点定时从自己的逻辑节点查询逻辑节点
	VNODE_heartbeat_timeout        = time.Second * 60                  //
	Entry                          = []string{}

	CPUNUM      = runtime.NumCPU()
	SyncNum_min = 6 //异步最少数量

	CLASS_wallet_broadcast_return = "CLASS_wallet_broadcast_return" //广播消息回复
	CLASS_im_security_create_pipe = "CLASS_im_security_create_pipe" //创建加密通道消息
	CLASS_security_searchAddr     = "CLASS_security_searchAddr"     //加密通信搜索节点
	CLASS_engine_multicast_sync   = "CLASS_engine_multicast_sync"   //广播消息同步
	CLASS_get_MachineID           = "CLASS_get_MachineID"           //获取节点的机器id
	CLASS_im_msg_come             = "CLASS_im_msg_come"             //消息到达
	CLASS_router_err              = "CLASS_router_err"              //消息转发时，发给消息接收者失败
)

var (
	ERROR_send_to_sender     = errors.New("need send back to sender")              //发回给sender，消息发送失败
	ERROR_not_in_waitRequest = errors.New("not in waitRequest")                    //waitRequest中没加载出来
	ERROR_wait_msg_timeout   = errors.New("wait message timeout")                  //等待消息返回超时
	ERROR_get_node_conn_fail = errors.New("get node conn fail")                    //获取连接失败
	ERROR_offline            = errors.New("node offline")                          //节点离线
	ERROR_online             = errors.New("node online")                           //节点已经在线
	ERROR_sent_myself        = errors.New("sent to myself")                        //消息发送给自己
	ERROR_no_neighbor        = errors.New("no neighbor")                           //没有可用的邻居节点
	ERROR_no_super           = errors.New("no super")                              //没有可用的超级节点
	ERROR_conn_self          = errors.New("Connect yourself, disconnect yourself") //自己连接自己
	ERROR_conn_exists        = errors.New("This link already exists")              //这个连接已经存在
	ERROR_router_fail        = errors.New("message router fail")                   //消息中转失败
	ERROR_params_fail        = errors.New("params fail")                           //参数错误
	Error_retry_over         = errors.New("retry send error")                      //重试发送失败
	Error_node_connecting    = errors.New("Node is connnecting")                   //和对方节点正在建立连接中,本次连接重复
)

var (
	Init_IsGlobalOnlyAddress = false //本地ip是否是公网全球唯一ip

	Init_IsMapping             = false //是否映射了端口
	Init_GatewayAddress        = ""    //网关地址
	Init_GatewayPort    uint16 = 9981  //网关端口

	Mode_local = true          //是否是局域网开发模式
	Init_role  = C_role_client //服务器角色，当为开发模式时可用

	//	LnrTCP   net.Listener //获得并占用一个TCP端口
	IsOnline      = false //是否已经连接到网络中了
	IsNotInternet = true  //是否没有因特网

	//根节点公钥
	Root_publicKeyStr = []byte{}
)

var (
	Path_leveldb = "messagecache" //leveldb保存广播消息缓存

	DBKEY_peers_entry         = []byte{1}                            //key以“1_”前缀的含义：保存节点地址列表 格式：22_[地址]
	DBKEY_version             = utils.Uint64ToBytesByBigEndian(2000) //数据版本号
	DBKEY_broadcast_msg_add   = utils.Uint64ToBytesByBigEndian(3000) //存放广播消息自增值的key
	DBKEY_broadcast_msg_clear = utils.Uint64ToBytesByBigEndian(3001) //存放广播消息最后清理值的key
	DBKEY_broadcast_msg       = utils.Uint64ToBytesByBigEndian(3002) //存放广播消息的key

	CurBroadcastAddValue   uint64 = 1
	CurBroadcastClearValue uint64 = 1
)

var GreaterThanSelfMaxConn int = 20

网络地址大于本节点地址的最大连接数

var OnlyConnectList []string

var (
	Time_find_network_peer = []int64{1, 1, 1, 1, 1, 1, 1, 1, 60 * 10} //查询逻辑节点间隔时间 单位：秒
)

Functions

func CheckIsSuperPeer

func CheckIsSuperPeer() bool

获得本机是否是超级节点

func GetCPUSyncNum

func GetCPUSyncNum() int

根据CPU数量

func SetLevelDBPath

func SetLevelDBPath(leveldbPath string)

设置leveldb数据库路径

Types

type Config

type Config struct {
	IsFirst bool
	Addr    string
	Port    uint16
	// contains filtered or unexported fields
}

type NetModel

type NetModel uint8

const (
	NetType_release NetModel = 0
	NetType_test    NetModel = 1
)