Documentation
¶
Index ¶
Constants ¶
View Source
const ( AreaNameResult_same = 1 //相同 AreaNameResult_different = 2 //不同 NodeIdResult_offline = 1 //节点不在线，允许连接 NodeIdResult_online = 2 //节点已经在线，拒绝连接 NodeIdResult_self = 3 //自己连接自己 VNodeIdResult_offline = 4 //虚拟节点不在线 VNodeIdResult_online = 5 //虚拟节点在线 )
View Source
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消息号的消息 )
View Source
const ( C_Server_name = "libp2parea" //网络名称 C_root_name = "root" //网络管理员域名 //服务器角色，只有局域网开发模式才能用 C_role_client = "client" //客户端模式 C_role_super = "super" //超级节点模式 )
View Source
const ( CONN_TYPE_TCP = 1 << 0 // tcp连接 CONN_TYPE_QUIC = 1 << 1 // UDP CONN_TYPE_ALL = 0xFF // 全部连接 )
p2p连接方式
View Source
const ( MAX_CLEAN_DATA_LENGTH = 10000 // 单次最大清理数据量 CLEAN_DATA_TIME = time.Minute * 30 // 每30分钟清理一次数据 CLEAN_DATA_INTERVAL_TIME = time.Second // 删除的数据比较大时，清理中间的间隔时间 CUR_VERSION uint64 = 1 // 当前数据库版本号 )
View Source
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" //消息超时删除 )
View Source
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地址 单位：秒 )
View Source
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" //投票公钥对应的域名为空 )
View Source
const (
MaxMachineIDLen = 128 // 最大machineID长度
)
相关限制信息
View Source
const MsgCacheTimeOver = 60 * 60 * 24
Variables ¶
View Source
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" //消息转发时，发给消息接收者失败 )
View Source
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") //和对方节点正在建立连接中,本次连接重复 )
View Source
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{} )
View Source
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 )
View Source
var GreaterThanSelfMaxConn int = 20
网络地址大于本节点地址的最大连接数
View Source
var OnlyConnectList []string
View Source
var (
Time_find_network_peer = []int64{1, 1, 1, 1, 1, 1, 1, 1, 60 * 10} //查询逻辑节点间隔时间 单位：秒
)
Functions ¶
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.