go语言p2p通讯 go语言 oop

go语言语法(基础语法篇)

import "workname/packetfolder"

创新互联建站是一家专注于网站制作、成都网站设计和乐山服务器托管的网络公司，有着丰富的建站经验和案例。

导入多个包

方法调用 包名.函数//不是函数或结构体所处文件或文件夹名

packagename.Func()

前面加个点表示省略调用，那么调用该模块里面的函数，可以不用写模块名称了:

当导入一个包时，该包下的文件里所有init()函数都会被执行，然而，有些时候我们并不需要把整个包都导入进来，仅仅是是希望它执行init()函数而已。下划线的作用仅仅是为了调用init()函数，所以无法通过包名来调用包中的其他函数

import _ package

变量声明必须要使用否则会报错。

全局变量运行声明但不使用。

func 函数名 (参数1，参数2，...) (返回值a 类型a, 返回值b 类型b，...)

func 函数名 (参数1，参数2，...) (返回值类型1, 返回值类型2，...)

func (this *结构体名) 函数名(参数 string) (返回值类型1, 返回值类型2){}

使用大小来区分函数可见性

大写是public类型

小写是private类型

func prifunc int{}

func pubfunc int{}

声明静态变量

const value int

定义变量

var value int

声明一般类型、接口和结构体

声明函数

func function () int{}

go里面所有的空值对应如下

通道类型

内建函数 new 用来分配内存，它的第一个参数是一个类型，不是一个值，它的返回值是一个指向新分配类型零值的指针

func new(Type) *Type

[这位博主有非常详细的分析]

Go 语言支持并发，我们只需要通过 go 关键字来开启 goroutine 即可。

goroutine 是轻量级线程，goroutine 的调度是由 Golang 运行时进行管理的。

同一个程序中的所有 goroutine 共享同一个地址空间。

语法格式如下:

通道（channel）是用来传递数据的一个数据结构。

通道的声明

通道可用于两个 goroutine 之间通过传递一个指定类型的值来同步运行和通讯。操作符 - 用于指定通道的方向，发送或接收。如果未指定方向，则为双向通道。

[这里有比较详细的用例]

go里面的空接口可以指代任何类型(无论是变量还是函数)

声明空接口

go里面的的强制类型转换语法为:

int(data)

如果是接口类型的强制转成其他类型的语法为:

go里面的强制转换是将值复制过去,所以在数据量的时候有比较高的运行代价

区块链技术想要快速入门，一般涉及哪些编程语言？

任何一门计算机语言，都能在特定某个领域的应用中，实现区块链技术；

具体使用哪一门语言，完全看我们相应领域行业企业项目的技术要求，以及更关键的：跟已有信息系统的有效对接联通。

区块链具有自下而上生成记录，生成两方或多方合同类记录，加入第三方确认机制，分布存储，……等特点；

从而让它相比集中式的存储运算而言，变得更为可信。

常见的总统投票，就非常适合以区块链技术重新架构；采用区块链技术的投票系统，能够避免哪一家技术公司、某一个关键技术人员，操纵选票统计结果的可能。

像我们的法院证据，也特别适合采用区块链技术重新架构开发。

其实像当前我们各类互联网时代的“版权系统”，它们中一些就是采用区块链技术架构而来，只不过，目前我们的新闻出版局、专利局（或者更广义地被称作“专家评委”），都尚未接入这些由互联网公司创新而来的版权平台。

我们耳熟能详 的“法大大”（虽然名字不甚好听、甚至乍一听来有些让人“摸不着头脑”），它也其实正准备采用最新的区块链技术重新架构；采用区块链技术的合同平台，因为变得更加可信，也才能更便于互联网时代人们签订各类商务合同。

还有像我们的“征信系统”，也非常适合以区块链技术加以改造。能够让它更有说服力，而不致于出现一家单位、乃至随意某个关键技术人员，能随意往其中添加“征信污点数据”的情况。

还有像我们的P2P贷款，如果能够以区块链技术重新架构的话，也能够变得更加可信，而不致于出现违约、卷款跑路这样的失信情况。

golang p2p网

继续进入下一个初始化

n.netService, err = nebnet.NewNebService(n)

if err != nil {

logging.CLog().WithFields(logrus.Fields{

"err": err,

}).Fatal("Failed to setup net service.")

}

netservice有两个成员

type NebServicestruct {

node      *Node

dispatcher *Dispatcher

}

跳出stup()函数

先进入start()函数看一看

if err := n.netService.Start(); err != nil {

logging.CLog().WithFields(logrus.Fields{

"err": err,

}).Fatal("Failed to start net service.")

}

进入netservice.start()

func (ns *NebService) Start() error {

logging.CLog().Info("Starting NebService...")

// start dispatcher.

ns.dispatcher.Start()

// start node.

if err := ns.node.Start(); err != nil {

ns.dispatcher.Stop()

logging.CLog().WithFields(logrus.Fields{

"err": err,

}).Error("Failed to start NebService.")

return err

}

logging.CLog().Info("Started NebService.")

return nil

}

可以看到第一个start()的函数是dispatcher.start()

进入dispatch.start()

func (dp *Dispatcher) Start() {

logging.CLog().Info("Starting NebService Dispatcher...")

go dp.loop()

}

然后就出现一个新的线程、goruntime

go dp.loop()

进入该线程，看它干了些什么

timerChan := time.NewTicker(time.Second).C

for {

select {

case -timerChan:

metricsDispatcherCached.Update(int64(len(dp.receivedMessageCh)))

case -dp.quitCh:

logging.CLog().Info("Stoped NebService Dispatcher.")

return

case msg := -dp.receivedMessageCh:

msgType := msg.MessageType()

v, _ := dp.subscribersMap.Load(msgType)

if v == nil {

continue

  }

m, _ := v.(*sync.Map)

m.Range(func(key, valueinterface{}) bool {

select {

case key.(*Subscriber).msgChan - msg:

default:

logging.VLog().WithFields(logrus.Fields{

"msgType": msgType,

}).Warn("timeout to dispatch message.")

}

return true

  })

}

}

一个有点长的循环

metricsDispatcherCached.Update(int64(len(dp.receivedMessageCh)))一秒钟刷新一次缓冲区

case msg := -dp.receivedMessageCh:

msgType := msg.MessageType()如果能取出dp.receivedMessageCh

msgType := msg.MessageType()首先判断取出的信息类型

v, _ := dp.subscribersMap.Load(msgType)

if v == nil {

continue

}

根据类型取出相应的map

如果取不出，那么使用continue结束这个case

m, _ := v.(*sync.Map)

断言

m.Range(func(key, valueinterface{}) bool {

select {

case key.(*Subscriber).msgChan - msg:

default:

logging.VLog().WithFields(logrus.Fields{

"msgType": msgType,

}).Warn("timeout to dispa+tch message.")

}

return true

})

将msg推入其他管道里面去。其他goruntime会循环等待该