数组 Golang 中，数组是值类型。 数组的声明 var arr [10]int 数组的初始化 var arr1 [3]int = [3]int{1, 2, 3} var arr2 = [3]int{4, 5, 6} var arr3 = [...]int{7, 8, 9} var arr4 = [...]int{1: 100, 2: 200, 3: 300} 用 for-range 遍历数组 基本语法： for index, value := range 数组变量{ } 其中：index 为数组下标，value 是该下标位置的值。 长度是数组类型的一部分 长度是数组类型的一部分，就是说数组不可以脱离长度而存在。听起来不太明白，我们来看下面的一个示例就明白了，这真的是一个大坑。 假设，我们...阅读全文
文章有点长，亲，要慢慢看！ 1. 概述 1.1 注册中心作用 在Dubbo中，注册中心为核心模块，Dubbo通过注册中心实现各个服务之间的注册与发现等功能，而本次源码的分析为registry模块的api和zookeeper的实现。 服务的提供者和消费者都需要把自己注册到注册中心，提供者让消费者感知到服务存在，从而消费者发起远程调用，也让服务治理中心感知到有服务提供者上线；消费者则是让服务治理中心可以发现自己。 1.2 Zookeeper Zookeeper是一个提供分布式协调服务的开源软件，常用于解决分布式应用中经常遇到的一些数据管理问题。Zookeeper功能非常强大，可以实现如分布式应用配置管理、统一命名服务、状态同步服务、集群管理等功能。关于Zookeeper，大家如果想了解可以关注一...阅读全文
介绍： json 是一种常见的数据交互模式， 从语法来看， 他类似于javascript 的 对象和列表。 通常情况下， json 被用于在web 后端服务器和 运行在浏览器上的js 程序进行通信， 偶尔， 该数据结构也用被其他地方用于通信。 你可以使用json 包在你的go 程序中非常简单的读写json. 编码： 编码json 数据可以使用 Marshal 函数 func Marshal(v interface{}) ([]byte, error) 下面给出go 数据结构： Message type Message struct { Name string Body string Time int64 } 和 Message 的实例: m m := Message{"Alice"， "He...阅读全文
前言 RPC（Remote Procedure Call），翻译过来为“远程过程调用”，是一种分布式系统中服务或节点之间的有效通信机制。通过 RPC，某个节点（或客户端）可以很轻松的调用远端（或服务端）的方法或服务，就像在本地调用一样简单。现有的很多 RPC 框架都要求暴露服务端地址，也就是需要知道服务器的 IP 和 RPC 端口。而本篇文章将介绍一种不需要暴露 IP 地址和端口的 RPC 通信方式。这种方式是基于 Redis BRPOP/BLPOP 操作实现的延迟队列，以及 Golang 中的 goroutine 协程异步机制，整个框架非常简单和易于理解，同时也很高效、稳定和安全。这种方式已经应用到了 Crawlab 中的节点通信当中，成为了各节点即时传输信息的主要方式。下面我们将从 Cr...阅读全文
一、解析JSON 1、解析JSON有两种方法 解析到结构体中（需要提前知道结构体的结构）； 解析到接口； 2、JSON数据与struct字段是如何相匹配的 首先查找tag（标签）中，含有Foo的可导出的struct字段（若标签不匹配，则匹配失败） 其次查找，字段名是Foo的导出字段 最后查找类似FOO或者FoO这样的除了首字母之外其他大小写不敏感的导出字段 注意：当接收到一个很大的JSON数据结构而你只想获取其中的部分数据的时候，只需将想要的数据对应的字段名大写，即可轻松解决这个问题。 3、匹配流程 tag——Foo——FOO或FoO或FOo 4、tag注意事项 字段的tag是“-”，直接忽略该字段 tag中如果带有“omitempty”选项，那么如果该字段值为空，则忽略该字段（json编码...阅读全文
副本_未命名.jpg 原创声明 本文作者：黄小斜 转载请务必在文章开头注明出处和作者。 系列文章介绍 本文是《五分钟学Java》系列文章的一篇 本系列文章主要围绕Java程序员必须掌握的核心技能，结合我个人三年多的Java学习和工作经历，总结和沉淀下来的方法论，希望能让Java学习这件事变得更简单，作者目前在阿里做Java，忙里偷闲分享一些技术文章，有兴趣看本系列更多文章可以关注我的公众号【Java技术江湖】 系列文章将会把一些技术学习方法、过程、要领与我的学习经验相结合，更加浅显易懂，并且我也会把我学习时用的资料，书籍和文章拿出来分享给大家，节省你我的时间。所谓授人以鱼也要授人以渔，是本系列文章希望达到的目标。 本文思维导图 什么是Java Web 不知道Java Web这个词是从什么时候...阅读全文
真实比特币序列化参考资料：https://www.blockchain.com/btc/block/00000000000000000a1f57cd656e5522b7bac263aa33fc98c583ad68de309603本文链接： https://dreamerjonson.com/2018/12/12/golang-43-blockchain-serialize/版权声明： 本博客所有文章除特别声明外，均采用 CC BY 4.0 CN协议 许可协议。转载请注明出处...阅读全文
微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。 之前写了一篇关于 RocketMQ 队列与 Kafka 分区副本的区别文章，里面提到了 RocketMQ 的消息冗余主要是通过主备同步机制实现的，这跟 Kafka 分区副本的 Leader-Follower 模型不同，HA（High Available) 指的是高可用性，而 RocketMQ 的HA机制是通过主备同步实现消息的高可用。 HA 核心类 HA 的实现逻辑放在了 store 存储模块的ha目录中，其核心实现类如下： image HAService：主从同步的核心实现类 HAService$AcceptSocketService：主服务器监听从服务器连接实现类 HAServic...阅读全文
和Windows系统一样，Linux服务器运行过程中也会一些没用的软件服务默认运行，这些占用了很多系统资源，也会有安全隐患，所以一般是建议关闭的。那么，工作中Linux主机到底需要有哪些开机自启动服务呢? 新装Linux系统之后，有必要保留的开机自启动服务有5个： Ø sshd：远程连接Linux服务器时要用到，所以必须开启，不然就无法提供远程连接服务了。 Ø rsyslog：日志相关软件，这是操作系统提供的一种机制，系统的守护程序通常会使用rsyslog程序将各种信息写到各个系统日志文件中。 Ø network：系统启动时，如果想激活或关闭各个网络接口的话，可以考虑开启。 Ø crond：用于周期性的执行系统及用户配置的任务计划。有需要时开启。几乎是运维工作中必须要用的一个软件。 Ø sy...阅读全文
前言 RPC（Remote Procedure Call），翻译过来为“远程过程调用”，是一种分布式系统中服务或节点之间的有效通信机制。通过 RPC，某个节点（或客户端）可以很轻松的调用远端（或服务端）的方法或服务，就像在本地调用一样简单。现有的很多 RPC 框架都要求暴露服务端地址，也就是需要知道服务器的 IP 和 RPC 端口。而本篇文章将介绍一种不需要暴露 IP 地址和端口的 RPC 通信方式。这种方式是基于 Redis BRPOP/BLPOP 操作实现的延迟队列，以及 Golang 中的 goroutine 协程异步机制，整个框架非常简单和易于理解，同时也很高效、稳定和安全。这种方式已经应用到了 Crawlab 中的节点通信当中，成为了各节点即时传输信息的主要方式。下面我们将从 Cr...阅读全文
1 前言 使用 vscode 作为 go 语言的开发环境，vscode 下载和安装过程就不介绍了，直接下二进制包然后图形化安装即可。2 下载 go 语言支持包 选择 vscode 的扩展菜单（extensions），填写 go，然后选择安装：3 编写 hello world 根据我上章内容设置 GO 项目结构，然后用 vscode 打开目录，比如我的目录结构如下：$GOPATH/src/jiuxi.org/jiuxi/helloworld 创建 main.go 文件，内容如下：4 编译 hello world4.1 项目根目录下编译 直接在项目根目录下执行如下语句进行编译：go build 编译成功会生成以项目名称命名的可执行文件： 如果想执行可执行文件名，需要添加 -o 参数:go bui...阅读全文
作者：freewind 比原项目仓库： Github地址：https://github.com/Bytom/bytom Gitee地址：https://gitee.com/BytomBlockc... 在上一篇我们已经知道了比原是如何监听节点的p2p端口，本篇就要继续在上篇中提到的问题：我们如何成功的连接上比原的节点，并且通过身份验证，以便后续继续交换数据？ 在上一篇中，我们的比原节点是以solonet这个chain_id启动的，它监听的是46658端口。我们可以使用telnet连上它： $ telnet localhost 46658 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. ט�S��%�z...阅读全文
1. Protocol Buffer 简介 先引用官网的一段话： Protocol buffers are Google's language-neutral, platform-neutral, extensible mechanism for serializing structured data – think XML, but smaller, faster, and simpler. You define how you want your data to be structured once, then you can use special generated source code to easily write and read your structured data t...阅读全文
在科学技术日益发展的今天，如雨后春笋般呈现出越来越多的具有很高的性能和开发效率的服务端语言。go迄今在很多公司有用武之地，它支持高并发、低延时、低内存消耗，有很好的社区，所以引起很多的开发者逐渐转入go的阵地。下面用示例来运行第一个go程序。go环境安装，https://golang.google.cn/dl/，从上面选择适合自己的环境进行安装；go开发工具，像Goland，LieteIDE，VsCode，我选择Goland进行开发，青睐它的语法高亮，动态提示很方便。创建go工程，通过new-project创建工程，go工程要配置go path，否则无法被发现。具体步骤是，点击File-OtherSettings-Preference for new project，在搜索栏搜索GoPath...阅读全文
server1:package main import ( "fmt" "net" ) func main() { l, err := net.Listen("tcp", "127.0.0.1:9876") if err != nil { fmt.Println(err) } fmt.Println("服务器等待客户端连接") conn, err := l.Accept() if err != nil { fmt.Println(err) } defer conn.Close() fmt.Println("客户端建立连接 ") buf := make([]byte, 4096) n, err := conn.Read(buf) if err != nil { fmt.Println(err)...阅读全文
51.go modules依赖管理 简介 一般从GOPATH、vendor文件夹下寻找依赖包。使用该功能后根据go.mod文件中的记录下载依赖。 go.mod中使用//作为注释 module：定义当前模块和包路径 require：定义依赖的模块和版本 exclude：排除特定模块和版本的使用 replace：模块源的替换 使用 go get xxx会自动将依赖模块添加到go.mod文件中 网络访问不了golang.org/x等谷歌扩展包，可以使用replace replace （ golang.org/x/crypto => github.com/golang/crypto latest golang.org/x/sys => github.com/golang/sys latest ） g...阅读全文
在之前的文章中分析过kubernetes是如何进行多版本管理中提到了一个关键的设计解码器, 负责将请求对象反序列化成一个具体的数据模型，今天一起来了解下其内部是如何实现多版本管理、转换的设计要点 1.版本化管理的关键设计 1.1 从拓扑转换到星状转换 在通常的web开发中更多的时候，大家都是断代向前兼容更新，大多数情况下当版本更新之后会独立演进，如果要在多版本之间转换通常则会出现如下的情况如果我们要为每个版本都去适配其他所有的版本，则复杂度会指数级上升，而在kubernetes中则通过一个内部版本的设计来进行解决，内部版本是一个稳定的版本，所有的版本都只针对目标版本来进行转换的实现，而不关注其他版本 1.2 兼容设计之转换 那如果谋个版本需要独立的演进，或者增设一些新的字段，修改字段名称等破...阅读全文
文地址[https://mojotv.cn/go/golang-reflect-string] 1. ???? 解决了什么 我有很多行日志数据单行的格式是这样的 HOST;000012000629948340196501;ipv4;3; ips: user_id=2;user_name=172.21.1.102;policy_id=1;src_mac=52:54:00:62:7f:4a;dst_mac=58:69:6c:7b:fa:e7;src_ip=172.21.1.102;dst_ip=172.22.2.3;src_port=48612;dst_port=80;app_name=网页浏览(HTTP);protocol=TCP;app_protocol=HTTP;event_id=1310...阅读全文
反射 变量介绍 变量的内在机制 类型信息，这部分是元信息，是预先定义好的 值类型，这部分是在程序运行过程中动态改变的 反射介绍 反射与空接口 空接口可以存储任何类型的变量 在程序运行时动态获取变量的类型信息和值信息，就叫反射 import ( "fmt" "reflect" ) func TestType(a interface{}) { //获取类型（静态信息） t := reflect.TypeOf(a) kind := t.Kind() switch kind { case reflect.Int: fmt.Printf("a is a int\n") a = 2 case reflect.String: fmt.Printf("a is a string\n") } fmt.Prin...阅读全文
简介 在上一篇文章中我们介绍了如何使用gjson快速读取 JSON 串中的值。为了内容的完整性，今天我们介绍一下如何使用sjson快速设置 JSON 串中的值。 快速使用 先安装： $ go get github.com/tidwall/sjson 复制代码后使用： package main import ( "fmt" "github.com/tidwall/sjson" ) const json = `{"name":{"first":"li","last":"dj"},"age":18}` func main() { value, _ := sjson.Set(json, "name.last", "dajun") fmt.Println(value) } 复制代码上面代码通过sjso...阅读全文
前篇 一个TCP长连接设备管理后台工程(一) 一个TCP长连接设备管理后台工程(二) 一个TCP长连接设备管理后台工程(三) 一个TCP长连接设备管理后台工程(四)一个TCP长连接设备管理后台工程(五) Github仓库地址 封包器 上面介绍了过滤器，过滤器实际就是一个能够处理粘包和拆包的解析器，和封包器的作用正好相反。但是封包器会很简单，因为封包没有粘包和拆包的处理。 代码如下： //Packer is proto Packer api func Packer(msg Message) []byte { data := make([]byte, 0) tempbytes := codec.Word2Bytes(msg.HEADER.MID) data = append(data, temp...阅读全文
结构体后续&指针 指针 变量和内存地址 每个变量都有内存地址，可以通过变量来操作对应的内存 func varMem() { var a int32 = 100 fmt.Printf("addr %p\n",&a) } func pointMem() { var b int32 b = 32 var a *int32 fmt.Printf("addr of a:%v\ntype of a %T\n",a,a) //取出a的地址和类型 a = &b fmt.Printf("a %d addr:%p\ntype of a:%T\nb %d addr %p\n",*a,&a,a,b,&b) } 指针的定义与取值 &： 取地址 *： 取指针对应的值 充分判断指针为nil的情况 func pointMe...阅读全文
