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会循环等待该
对比于其他语言的程序，Go语言的跨平台能力是真的强，拿.Net和JAVA来说吧，.Net在.Net core出现之前是不能跨平台的，只能在windows上编译运行，即使是.net core出现以后，跨平台的程序也是相当的麻烦。而java虽然一直都可以跨平台，但是运行JAVA程序的机器上也必须要有JAVA程序运行环境JRE。而相对于Go程序，跨平台就简单的多了，只需要在编译指定目标程序运行的架构和环境即可编译出指定操作系统和架构的程序。
以上是指定了go的环境变量后执行的go build命令进行目标程序的构建，这种方式会一直生效的，如果不让他一直生效，可以在构建的时候临时指定环境变量，下面以window的环境为例，来介绍临时指定环境变量的方式构建可以在Linux环境下运行的可执行程序：
可以根据不同的架构和操作系统将其编写为不同的.bat的可执行文件放置在程序的根目录，Linux的和MAC的也一样编写成脚本文件放置在程序的根目录，这样在构建的时候就不用再敲命令了，直接运行脚本就可以了。
Java程序编译打包后为war包或者是java包，必须执行java -jar 命令或者将其放置到tomcat的指定目录下，运行tomcat程序。而Go语言编写的程序最终为可执行的文件（window下编译出的是.exe的可执行文件），只需要将其赋予可执行的权限就可以直接运行了。
构建JAVA程序的镜像需要指定java的基础镜像，否则就需要在镜像中安装java的运行环境了，下面展示的是构建的一个JAVA程序的镜像，构建出来镜像的体积相对比较大
而Go程序制作出的镜像就不需要安装任何的依赖环境，因为他在打包的时候就已经将依赖的包一块打包到一起了
拿着这个镜像就可以到处运行了。
通过对比我们可以发现，如果没有之前的技术和业务的积累，重新开发一个新的项目，使用go去开发无疑是最容易上手的，所以现在很多公司都使用go进行开发，也逐渐将其他语言的项目逐步的用go语言进行改造。其实用什么语言不重要，合适的才重要，开发项目在选择语言的时候也会综合多方面来考虑选择合适的语言和架构，毕竟很多公司都不是搞研究的，都需要项目来赚钱，所以开发的速度、客户的满意度、项目交付的时间才是驱动公司技术的主要因素。
我们个人也应该不断完善自己的技术栈，不应该太依靠某种语言，最重要的还是自己的架构思想和底层架构知识，只有掌握了这些才能够不被 社会 和公司“优化”。
一直直接操作的框架 使用vscode 打开就会自动装包，这次想写一个简单应用，确不会怎么建项目，记录如下。
go1.14 后，以及不再需要把项目写在GOPATH下，所有不需要再配置。
配置GOPRXY goenv-w GOPROXY=https://goproxy.cn,direct(国内无法访问https://proxy.golang.org)
使用go mod方法新建项目。
任意位置新建文件夹。
文件夹下执行go mod xxx ，生成一个go.mod文件。
新建一个main.go文件，就可以直接运行了。
我开始的时候，先建了main.go文件，再执行的go.mod。后面没法运行。
参考：李文周的博客。
