1 前置条件

       Golang基本情况自行baidu/google

1.1 环境与工具

IDE：liteide (windows )、mingw-w64 (gcc)

DB：SQL Server 2008 R2

MQ: Kakfa

1.2 环境变量

Golang 需要将GOPATH添加到环境变量中

 

1.3 版本查看

Cmd中输入 go version 可以查看当前golang版本

 

2 示例程序功能简介

2.1 主功能

  •  查询数据表A获取记录的消息编号MSG-Id.
  • 从数据表B查询大于MSG-Id的100条连续数据.
  • 将查询到的100条数据依次序列化成JSON数据，推送到消息队列Kafka中（供其它软件使用）.
  • 100条推送成功后将最大的MSG-Id更新到数据表A.

2.2 辅助项

  • 循环执行，每执行主功能一次，挂起2秒
  •        记录关键日志到文件
  •        从配置文件读取信息
  •        在Console上显示实时信息

 

3 代码描述

3.1 目录结构与程序包

      

       MainExe：主项目模块的目录

                     Domain领域层目录

                                   xxDomain.go 领域层源码文件（Package yyDomain）

                     Model模型层目录

                                   xxModel.go 模型层源码文件（Package yyModel）

                     Main.go:主函数源码文件，Package Main

       Common：通用/公共功能模块目录

                     MQ_kafka帮助类子目录

Sarama.go: kafka帮助类源码（package KafkaHelper）

                     DB_SQLServer帮助类子目录

SQLServer.go: SQLServer帮助类源码（package SQLHelper）

                     File_CFG帮助类子目录

CFG.go: 配置文件操作帮助类源码（package CFGHelper）

 

在Goalng中源码的物理文件是按照目录（Directory）来管理, 每个*.go文件都存放在一个目录下，一个目录下的所有源文件只能属于相同的包package。在逻辑上，源码使用包（package）这种语法元素来组织源码，所有语法可见性均定义在package这个级别，每个*.go文件都属于一个Package。

              导入：Import（”目录/子目录”）

              程序调用:  PackageName.xxxMethod/yyyFunction

3.2 源码文件SQLServer.go

       这里用到了go-mssqldb这个包，在命令行cmd使用go get github.com/denisenkom/go-mssqldb 可以将程序包下载到本地

    这个包在import时，前面加了横线，说明即使用【import _ 包路径】只是引用该包，仅仅是为了调用init()函数，所以无法通过包名来调用包中的其他函数。

 

// 参考资料

//Go-SQLServer         https://www.cnblogs.com/dfsxh/p/10207866.html

//Go-SQLServer          https://www.cnblogs.com/Liang2790912648/p/10604310.html

//Go-SQLServer         https://www.jianshu.com/p/136ac470fc17

//Go-SQLServer          https://blog.csdn.net/chen_peng7/article/details/89317922

//GO-MySQL(scan)        https://zhidao.baidu.com/question/1759806412743140028.html

 

3.3 源码文件Sarama.go

 

 因为在.net core 环境下用Confluent成功，本想goalng用Confluent package继续测试，但是下载这个包很困难（墙），所以放弃了。

// 参考资料

//Go-Kafka https://www.cnblogs.com/vincenshen/p/9824486.html

//Go-Kafka https://www.cnblogs.com/pyyu/p/8371649.html

//Go-Kafka https://blog.csdn.net/lanyang123456/article/details/78377152

 

3.4 源码文件CFG.go

 

 

3.4 源码文件main.go

  import 里面有很多测试导入的包，如果报错就屏蔽掉

 

3.4 源码文件xxModel.go

 

 

3.4 源码文件yyDomain.go

 

// 参考资料

// Go-JSON     https://www.cnblogs.com/pyyu/p/8309917.html

// Go-JSON     https://www.jianshu.com/p/3534532e06ed

// Go-JSON     https://studygolang.com/articles/8526  SQL结果集-JSON

// Go-base     https://www.jianshu.com/p/dbb39c69e3f1 类型转换string、int、int64

// Go-base     https://www.cnblogs.com/smallleiit/p/10694481.html 类型转换string、int、int64

// Go-base     https://www.cnblogs.com/pyyu/p/8258133.html 自定义类型struct

// Go-base     https://studygolang.com/articles/3383 log简介

3.4 配置文件conf.ini

 

 

    对于熟悉一门编程语言，学习另外一种语言，总有一些困难：

  •    首先是开始时的开发--编译-运行环境，也就是hello world，以及调试：需要搜集大量资料或教程才能敲门
  •    其次是习惯，从面向过程转面向对象或者反之，都需要克服习惯
  •    最后，是做一个工作上用到的，不大的有用的程序，除非你的兴趣特别强