最近因为换了Mac，以前的Linux基本上不再使用了，但是我的SS代理还得用。SS代理大家都了解，一个很NB的Socket代理工具，但是就是因为他是Socket的，想用HTTP代理的时候很不方便。 以前在Linux下的时候，会安装一个Privoxy把Socket代理转换为HTTP代理，开机启动，也比较方便。但是Mac下使用Brew安装的Privoxy就很难用，再加上以前一个有个想法，一个软件搞定Socket和HTTP代理，这样就不用安装一个单独的软件做转换了。 想着就开始做吧，以前基本上没有搞过太多的网络编程，最近也正好在研究Go，正好练练手。 我们这里主要讲使用HTTP／1.1协议中的CONNECT方法建立起来的隧道连接，实现的HTTP Proxy。这种代理的好处就是不用知道客户端请求的数...阅读全文
《Go语言四十二章经》第二十二章 通道(channel) 作者：李骁 ## 22.1 通道(channel) Go 奉行通过通信来共享内存，而不是共享内存来通信。所以，**channel 是goroutine之间互相通信的通道**，goroutine之间可以通过它发消息和接收消息。 channel是进程内的通信方式，因此通过channel传递对象的过程和调用函数时的参数传递行为比较一致，比如也可以传递指针等。 channel是类型相关的，一个channel只能传递（发送或接受 | send or receive）一种类型的值，这个类型需要在声明channel时指定。 默认的，信道的存消息和取消息都是阻塞的 (叫做无缓冲的信道) 使用make来建立一个通道： ```go var channel...阅读全文
HTTP Proxy Demo 代码1、Python#! -- encoding:utf-8 --import requests# 要访问的目标页面targetUrl = "http://ip.hahado.cn/ip"# 代理服务器proxyHost = "ip.hahado.cn"proxyPort = "39010"# 代理隧道验证信息proxyUser = "username"proxyPass = "password"proxyMeta = "http://%(user)s:%(pass)s@%(host)s:%(port)s" % { "host" : proxyHost, "port" : proxyPort, "user" : proxyUser, "pass" : prox...阅读全文
一，效果 服务器返回了一张图片 二，Golang代码 package main import ( "fmt" "./models" "log" "net/http" ) func main(){ // 1, 迷你服务器 http.HandleFunc("/", handler) // 注册函数 类似于 路由管理 urls.py http.HandleFunc("/sanhuo", handlerLisa) // 注册函数 log.Fatal(http.ListenAndServe("localhost:8000", nil)) // 服务器启动 } // 1, "/" 的回调函数 类似于Django的 视图 views.py func handler(w http.ResponseWrite...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ package main import "fmt" //IA test for methodset. type IA interface { Value() Pointer() } //A is a test type. type A int //Value receiver. func (a A) Value() { fmt.Printf("Value:%p, %d\n", &a, a) } //Pointer receiver. func (a *A) Pointer() { fmt.Printf("Pointer:%p, %d\n", a, *a) } func main() { //type A method set: ...阅读全文
静态语言在服务器编程时都会遇到这样的问题：如何保证已有的连接服务不中断同时又升级版本？最近花了点时间看了下nginx热更新代码流程，想了下结合之前的经验一并总结下热更新1. 热更新是什么？简单翻译成人类可读的实例是如下这个样子：举个例子，你现在在坐卡车，卡车开到了150KM/H然后，有个轮胎，爆了然后，司机说，你就直接换吧，我不停车。你小心点换嗯。就这个意思2.网关中的热更新服务程序热更新这个问题在层7网关中尤其严重，网关中承载着大量的请求，包括HTTP/HTTPS短连接、HTTP/HTTPS长连接、甚至是websocket这种超长连接（websocket通常连接时间会很长，十几分钟到几天不等）。这样的话我们势必不能讲服务程序停止再启动的冷更新，服务进程热更新是非常有必要的。网关作为一个基础...阅读全文
导语 上一节介绍了简单的工作模式，即一个队列可以被多个消费者进行消费，只有一条消息被送到消费者，采用公平调度的方式，在以往的例子中似乎我们还没用到交换器进行发送消息，我们都知道，往队列里发送消息，是需要用交换器进行分发的消息的，为什么我们没有申请交换器仍然可以发送消息呢？因为在RabbitMQ服务器中，如果不申请交换器，服务器会使用默认的交换器，所以说，交换器在发送消息的时候必不可少，今天我们学习两种交换器分别为fanout（扇形交换器）和direct（直连交换器） 扇形交换器（日志记录器） 特性 分发消息到与之绑定的所有队列，发送消息到交换器时会忽略routing key（路由），我们可以称它为广播消息。 生产者 申请交换器 指定交换器的名字 指定交换器的类型 err = ch.Excha...阅读全文
一、概念channel是golang语言级别提供的协程(goroutine)之间的通信方式。goroutine运行在相同的地址空间，因此访问共享内存必须做好同步。那么goroutine之间如何进行数据的通信呢，Go提供了一个很好的通信机制channel。channel可以与Unix shell 中的双向管道做类比：可以通过它发送或者接收值。这些值只能是特定的类型：channel类型。定义一个channel时，也需要定义发送到channel的值的类型。 二、声明方式 var chanName chan ElementType var ch chan int 使用make，可以指定channel容量 ch = make(chan int) 三、channel得读和写channel通过操作符<-来...阅读全文
下面先列举一下程序使用到的函数,省的大家去找，直接拷贝官方api的解释吧。 func DialTCP(net string, laddr, raddr *TCPAddr) (*TCPConn, error) DialTCP在网络协议net上连接本地地址laddr和远端地址raddr。 net必须是"tcp"、"tcp4"、"tcp6"；如果laddr不是nil，将使用它作为本地地址，否则自动选择一个本地地址。 func ResolveTCPAddr(net, addr string) (*TCPAddr, error) ResolveTCPAddr将addr作为TCP地址解析并返回。 参数addr格式为"host:port"或"[ipv6-host%zone]:port"，解析得到网络名和端...阅读全文
编程过程中遇到了粘包问题，看到这篇很详尽的就mark下来了，虽然看代码很简单，也没能解决我的粘包问题，但是对于自己了解粘包还是有用的么，是吧。 在使用golang做socket服务时，我想大多数人都会碰见粘包的问题。 以前用python做socket服务时就想写一篇关于tcp粘包的问题，后来因为单纯的tcp服务器开发功能实在烦杂，索性直接用http tornado进行通信了。 下面的资料有些是来自我个人的印象笔记，相关的参考引用链接早就找不到了。 该文章写的有些乱，欢迎来喷 ! 另外文章后续不断更新中，请到原文地址查看更新。 http://xiaorui.cc/?p=2888 什么是半包 ? 接受方没有接受到完整的包，只接受了一部分。 由于发送方看到内容太大切分数据包进行发送，这样切包能提高...阅读全文
前言以前也研究过这个protobuf这一语言标准，这一google开发的用来网络协议指定的标准。这次再遇到这里就着研究fabric的机会深入的说明一下。用这个进行协议的指定是比较节约网络带宽，编解码方便。下面我们就从数据类型和编解码方式两个方面来加以说明。通过本文的阅读你将会发现，利用好protobuf有利于你提高程序编写的效率和减少协议指定的繁杂性。特别是如果你要设计的是一个网络系统的时候。1、protobuf的关键字和数据类型针对不同的程序语言（C++,java，golang）有不同的protobuf解析器，但是他们的数据类型是一样的，关键字略有差别。这里我们以golang和protoc-gen-go解析器为例来进行说明。protocol buffer 语言的源文件一般以name.pro...阅读全文
title: golang 网络编程 golang 网络编程 go-shadowsocks是一个非常好的学习golang网络编程的例子。在本篇博文中重点 阐述golang网络通信几个各种不同协议下服务端和客户端的实现。 网络通信协议主要有以下两种外加一种增加的协议 golang tcp golang upd golang kcp：在upd上进行增强的协议，KCP 是一个快速可靠协议，能以比 TCP浪费10%-20%的带宽的代价，换取平均延迟降低 30%-40%，且最大延迟降低三倍的传输效果。 golang的一大优势就是多核、并行、网络编程。通过goroutine与channel可以很方便地协程，协程比线程更轻量级，占用资源更小，可以更好地适用与并行计算。 下面对这三种分别进行说明。 gola...阅读全文
## 简明笔记:Goroutine &channel > f() // call f()；wait for it to return > > go f() //create a new goroutine that calls f();don't wait ## Goroutine 调用普通函数，等待函数返回值返回。 创建一个goroutine，调用函数，不会等待其函数返回值返回。 ```go package main import ( "fmt" ) func helloworld(){ fmt.Println("goroutine...") } func main() { go helloworld() //在函数面前加上关键字Go，创建一个goroutine。 fmt.Println(...阅读全文
1. 安装 golang到 golang.org 官网下载最新版的golang, Leanote至少需要golang 1.7。如果被墙, 可以在 http://golangtc.com/download 下载。以下为 1.8 版本的快速下载链接:linux 64位: http://www.golangtc.com/static/go/1.8/go1.8.darwin-amd64.pkglinux 32位: http://www.golangtc.com/static/go/1.8/go1.8.linux-386.tar.gz假设将文件下载到 /home/user1 下, 解压文件：$> cd /home/user1$> tar -xzvf go1.6.linux-amd64.tar.gz在 ...阅读全文
写在前面 本文实现的Godis代码版本为：v0.0.3 在前三篇文章中，实现了客户端/服务端的交互（基于textprotoco）、服务端初始化和get/set命令。如果阅读过或者调试过粗略的代码实现，会发现使用文本协议进行交互，除了容易阅读之外，解析效率是比较低下的。因为我们的示例是"set alpha 123n"，工整的单个空格和n分割，可能在分割上效率还好；既要分割，不免低效。 在本文，将替换文本协议为Redis1.2版本后的统一协议。 Redis通信协议 Redis通信协议解析高效、二进制安全，同时也对人类友好（可直接阅读解析）。 协议格式 Redis在发送命令和返回结果中均使用同一套标准协议。Reids协议“肉眼可辨”，在发送命令是使用类型为"multi bulk reply"的协议...阅读全文
WebSocket的实现原理 一、什么是websocket Websocket是应用层第七层上的一个应用层协议，它必须依赖 HTTP 协议进行一次握手 ，握手成功后，数据就直接从 TCP 通道传输，与 HTTP 无关了。即：websocket分为握手和数据传输阶段，即进行了HTTP握手 + 双工的TCP连接。 下面我们分别来看一下这两个阶段的具体实现原理： １、握手阶段 客户端发送消息： GET /chat HTTP/1.1 Host: server.example.com Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ== Origin: http://example.com ...阅读全文
``` import ( "fmt" "strings" "sync" "time" ) type ( subscriber chan interface{} //订阅者 topicFunc func(v interface{}) bool //主题过滤器 ) type Publisher struct { m sync.RWMutex //读写锁 buffer int //订阅队列缓存大小 timeout time.Duration //发布超时 subscribers map[subscriber]topicFunc //订阅者信息 } //新建一个发布者对象，可以设置发布超时和缓存队列打长度 func NewPublisher(publishTimeout time.Duration,...阅读全文
项目地址 https://github.com/hetiansu5/... 简介 使用Go语言实现的URL Query字符串编码器和解码器。写好后才发现官方已有实现的querystring，但只实现了编码器，没有解码器，且只支持顶层数据结构为结构体，实现上不算特别完善。 特性 支持丰富的Go数据结构互转： 基础数据类型: 有符号整型[8,16,32,64] 无符号整形[8,16,32,64] 字符串 布尔值 浮点型[32,64] 字节 字面量 复合数据类型: 数组 切片 哈希 结构体 嵌套结构体 支持顶层的数据结构为数组 切片 哈希，不仅仅是结构体 支持自定义的URL-Encode编码规则，支持全局、局部设置方式，支持默认规则 支持自定义的键名映射规则（结构体Tag示例：query:"nam...阅读全文
RabbitMQ 概述 RabbitMQ是采用Erlang编程语言实现了高级消息队列协议AMQP (Advanced Message Queuing Protocol)的开源消息代理软件（消息队列中间件） 市面上流行的消息队列中间件有很多种,而RabbitMQ只是其中比较流行的一种 我们简单说说消息队列中间件的作用 解耦 削峰 异步处理 缓存存储 消息通信 提高系统拓展性 RabbitMQ 特点 可靠性 通过一些机制例如,持久化,传输确认等来确保消息传递的可靠性 拓展性 多个RabbitMQ节点可以组成集群 高可用性 队列可以在RabbitMQ集群中设置镜像,如此一来即使部分节点挂掉了,但是队列仍然可以使用 多种协议 原生的支持AMQP,也能支持STOMP,MQTT等协议 丰富的客户端 我们...阅读全文
参考资料 由于fabric采用go语言编写，故需要安装go环境。 安装要求： Java VM version 8 or later. Eclipse 4.6 (Neon) or later. 1. JDK安装1.8以上+Eclipse 安装过程省略 2.安装go环境 https://golang.org/ 进入go的官网，下载对应的安装包。本例子下载的是go1.8.3.windows-amd64.zip 解压到E:\fabric\go目录。 3.在eclipse中安装GoClipse help->Eclipse Marketplace->检索GoClipse，检索到以后直接安装即可 安装后重...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ package main import "fmt" //IA test for methodset. type IA interface { Value() Pointer() } //A is a test type. type A int //Value receiver. func (a A) Value() { fmt.Printf("Value:%p, %d\n", &a, a) } //Pointer receiver. func (a *A) Pointer() { fmt.Printf("Pointer:%p, %d\n", a, *a) } func main() { //type A method set: ...阅读全文
// code_041_sync_WaitGroup project main.go package main import ( "fmt" "sync" ) func main() { fmt.Println("Hello World!") var wg sync.WaitGroup wg.Add(2) go func() { defer wg.Done() for i := 0; i < 10000; i++ { fmt.Printf("Hello,Go.This is %d\n", i) } }() go func() { defer wg.Done() for i := 0; i < 10000; i++ { fmt.Printf("Hello, world.This is %d\n...阅读全文
socket 图片.png 客户端代码 package main import ( "bufio" "fmt" "io" "net" "time" ) func main() { var tcpAddr *net.TCPAddr tcpAddr,_ = net.ResolveTCPAddr("tcp","127.0.0.1:9999") conn,err := net.DialTCP("tcp",nil,tcpAddr) if err!=nil { fmt.Println("Client connect error ! " + err.Error()) return }else { fmt.Println(conn.LocalAddr().String() + "客户端连接成功!") } d...阅读全文
一、目的 使用Go语言实现一个服务器端与客户端的聊天室。 软件：Goland，Go1.9 代码仓库地址 二、思路 1，首先启动服务器端，使用listen_socket函数监听IP地址上的客户端连接； 2，启动客户端，并向服务器端发送数据，发送结束后端口阻塞，等待服务器端的消息； 3，服务器端接收到由客户端发送来的消息； 4，服务器端向客户端发送数据，发送结束后； 5，客户端接收到由服务器端发送来的消息，发送结束后端口阻塞，等待客户端的消息； 6，重复步骤2-5； 7，如果服务器端接收到由客户端发送来的“close"消息后，服务器端关闭与客户端的连接，继续等待下一个客户端的连接； 8，客户端关闭，聊天结束。 三、Go代码实现 Sever端 // One-to-one ChatRoom Seve...阅读全文
gonet 游戏服务器架构，mmo架构，分布式snowflake64为整形uuid,ai行为树，配置data，游戏大部分都在内存运算,分布式缓存redis。设计之初，建立在actor模式下的；rpc，以及消息驱动，rpc无需注册，支持int，数据，struct（struct必须要注册结构题即可）；sql封装简单的orm，具体看demowebsocket模式下，要在net，websocket注视掉如下代码：https://studygolang.com/articles/14842代码除了mysql，protobuf，redis这几个第三方库以外，其他都是自己写的，方便性能和修改，主动权在自己手里服务器之间rpc，客户端服务器之间protobuf + rpc，客户端tcp遵从如下消息包头前四位...阅读全文
elliptic包实现了几条覆盖素数有限域的标准椭圆曲线。 type Curve type Curve interface { // Params返回椭圆曲线的参数 Params() *CurveParams // IsOnCurve判断一个点是否在椭圆曲线上 IsOnCurve(x, y *big.Int) bool // 返回点(x1,y1)和点(x2,y2)相加的结果 Add(x1, y1, x2, y2 *big.Int) (x, y *big.Int) // 返回2*(x,y)，即(x,y)+(x,y) Double(x1, y1 *big.Int) (x, y *big.Int) // k是一个大端在前格式的数字，返回k*(Bx,By) ScalarMult(x1, y1 *bi...阅读全文
类和继承 在面向对象的编程语言中存在“类”的概念，类就表示数据的类型，比如说People类；继承是指某个类是由另一个类派生出来的。生成的新类是子类，被继承的类是父类。 JS中的“var” 在某一类编程语言中会采用动态类型，是指编码时不要求指定变量类型，实际的变量类型由编译器/解释器在加载程序时动态分配。在JavaScript中用var声明变量，用let声明常量。 nil，null和undefined 通常声明变量的步骤为var a_varible = null;这里表示变量a_varible的值初始化时是空的，即null；在某些语言中是nil,比如Objective-C，Golang。有时声明变量也可以写成var a_varible,在JavaScript中，此时的变量值是undefined...阅读全文
web.go package main import ( "fmt" "log" "net/http" "strings" ) func sayhello(w http.ResponseWriter, r *http.Request) { r.ParseForm() //解析参数, 默认是不会解析的 fmt.Println(r.Form) //这些是服务器端的打印信息 fmt.Println("path", r.URL.Path) fmt.Println("scheme", r.URL.Scheme) fmt.Println(r.Form["url_long"]) for k, v := range r.Form { fmt.Println("key:", k) fmt.Println("v...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ package main import "fmt" //IA test for methodset. type IA interface { Value() Pointer() } //A is a test type. type A int //Value receiver. func (a A) Value() { fmt.Printf("Value:%p, %d\n", &a, a) } //Pointer receiver. func (a *A) Pointer() { fmt.Printf("Pointer:%p, %d\n", a, *a) } func main() { //type A method set: ...阅读全文
在Golang中使用for range语句进行迭代非常的便捷，但在涉及到指针时就得小心一点了。 下面的代码中定义了一个元素类型为*int的通道ch： package main import ( "fmt" ) func main() { ch := make(chan *int, 5) //sender input := []int{1,2,3,4,5} go func(){ for _, v := range input { ch <- &v } close(ch) }() //receiver for v := range ch { fmt.Println(*v) } } 在上面代码中，发送方将input数组发送给ch通道，接收方再从ch通道中接收数据，程序的预期输出应该是： 1 2 3...阅读全文
1.格式化输出 fmt.Printf() 输出到控制台.fmt.PrintLn()输出到控制台并换行。str := fmt.Sprintf("%f", 3.1415926)格式化后返回格式化后的字符串。fmt.FprintLn(os.Stdout, "hello world")格式化输出到输出ioWrite上（控制台、文件、网络请求等）更多操作请见https://studygolang.com/stati... 2.基本IO 读取器函数 func ReadFrom(reader io.Reader, num int )([]byte, error){ p := make([]byte, num) n, err := reader.Read(p) if n>0 { return p[:n], ...阅读全文
点击上方蓝色“Go语言中文网”关注我们，领全套Go资料，每天学习 Go 语言Todd Kulesza 2020-04-20概览、感谢 首先，我要非常感谢参与本次调查的数千名 Go 开发人员。在 2019 年，我们收到了 10,975 份回复，几乎是去年的两倍！[1]我要代表团队的其他成员，充分强调您花时间和精力向我们介绍您在 Go 方面的经验，我们对此深表感谢。谢谢！关于前几年调查说明 敏锐的读者可能会注意到，我们每年的比较与我们过去分享的数字不太吻合。原因是从 2016 年至 2018 年，我们使用开始调查的总人数作为分母来计算每个问题的百分比。尽管这很不错而且很一致，但它忽略了并非每个人都会完成调查的事实——多达 40％ 的参与者在到达最后一页之前就停止了调查，这意味着在调查的后面出现的...阅读全文
上两篇帖子主要说了一下nsq的拓扑结构，如何进行故障处理和横向扩展,保证了客户端和服务端的长连接，连接保持了，就要传输数据了，nsq如何保证消息被订阅者消费，如何保证消息不丢失，就是今天要阐述的内容。 nsq topic、channel、和消费我客户端的结构如上图，一个topic下有多个channel每个channel可以被多个客户端订阅。 消息处理的大概流程:当一个消息被nsq接收后，传给相应的topic,topic把消息传递给所有的channel ,channel根据算法选择一个订阅客户端，把消息发送给客户端进行处理。 看上去这个流程是没有问题的，我们来思考几个问题 网络传输的不确定性，比如超时；客户端处理消息时崩溃等，消息如何重传； 如何标识消息被客户端成功处理完毕； 消息的持久化，n...阅读全文
ssmperf 是 SSMP 协议的服务器基础加载测试工具。 使用
./ssmperf <address> [flags] -cacert="" path to CA cert -cert="" path to client cert -conn=100 number of client connections -count=10000 number of messages sent per connection -cpuprofile="" write cpu profile to file -insecure=false d...阅读全文
//1 获取当前发送邮件的时间 t := time.Now() s := t.Format("2006-01-02 15:04:05") //2准备发送人的邮箱信息（用户名，密码等，以及发送者邮箱域名） hostname := "smtp.bszhihui.com" auth := smtp.PlainAuth("", "yunwei@bszhihui.com", "xxxxxx", hostname) //3 组织发送内容 msg := []byte("From: DevOps
1. 对象存活判断 1.1. 引用计数算法 Reference Counting 给对象添加一个引用计数器，每当有一个地方引用它的时候，计数器值就加一；当引用失效时，计数器值就减一；任何时刻计数器为0的对象就是不可能再被使用的。 主流的JVM没有选用引用计数算法来管理内存，主要的原因是它很难解决对象之间的相互循环引用的问题。 1.2. 可达性分析算法 Reachability Analysis 通过一系列称为“GC-Roots”的对象作为起点，从这些结点开始向下搜索，搜索所走过的路径称为引用链（Reference Chain），当一个对象到GC Roots没有任何引用链相连时，则证明此对象是不可用的（图论中的不可达）。 可作为GC Roots的对象： 虚拟机栈（战争中的本地变量表）中引用的对...阅读全文
写PHP的时候遇到一个问题 *如何在把响应发送给客户端之后，继续执行后续任务？ * 在stackoverflow上找到解决方案，如下 https://stackoverflow.com/questions/15273570/continue-processing-php-after-sending-http-response 想知道，如何在Golang中实现这种需求，google了一会没能找到，汗... 求助，能赐几行代码更好，多谢:...阅读全文
作者：Max 一直以来都有个梦想： 希望有一个数据库能够弹性扩展（分布式）到成百上千节点的规模，易于学习和理解，可以运行在私有云、公有云、Multi-Cloud、Kubernetes，也能够跑在嵌入式设备（比如树莓派）上，更酷的是也能够直接运行在浏览器里，而且不需要任何浏览器扩展（Extension），变成「口袋数据库」，就像那部电影《蚁人》。 今天，这一切都变成了现实：TiDB 可以直接运行在浏览器本地。打开浏览器，你可以直接创建数据库，对数据进行增删改查。关掉浏览器，一切都消失了，干净绿色环保—— 首先在笔记本浏览器打开 play.pingcap.com（这里用的是 MacOS 上面的 Chrome，不确定其它浏览器是否正常），可能需要几秒来加载页面，然后就能看到熟悉的 Shell 了。...阅读全文
课程介绍 阿里云虚拟主机市场占用率第一，20年专业品质保证；产品特点：预装网站运行环境，赠送正版数据库，可通过图形化控制面板管理，主要用于搭建网站。 独享系列虚机特点：客户独享整台服务器资源，无资源争抢更稳定，不限流量更快速、独立IP更易推广，适合企业建站客户； 共享系列虚机特点：多客户共享服务器硬件资源，价格优惠，简单易用，适合于开发者、个人站长建站； 产品详情：https://wanwang.aliyun.com/hosting/ 课时列表 • 课时1：购买虚拟主机和初始化密码信息 • 课时2：FTP 上传与解压缩文件 • 课时3：绑定并解析域名 • 课时4：切换语言环境 • 课时5：虚拟主机临时域名的使用 开始学习http:...阅读全文
Home Menu 解析器眼中的 Go 语言 02 Feb 2019 Golang Go实现原理 编译原理 词法分析 语法分析 抽象语法树 词法分析 lex Go 语法分析 文法 分析方法 自顶向下 自底向上 Lookahead Go 辅助方法 节点 总结 相关文章 Reference 代码其实就是按照约定格式编写的一堆字符串，工程师可以在脑内对语言的源代码进行编译并运行目标程序，这是因为经过训练的软件工程师能够对本来无意义的字符串进行分组和分析，按照约定的语法来理解源代码。既然工程师能够按照一定的方式理解和编译 Go 语言的源代码，那么我们如何模拟人理解源代码的方式构建一个能够分析编程语言代码的程序呢。 我们在这一节中将介绍词法分析和语法分析这两个非常重要的编译过程，这两个过程的主要作用就...阅读全文
用 Go 来了解一下 Redis 通讯协议 Go、PHP、Java... 都有那么多包来支撑你使用 Redis，那你是否有想过 有了服务端，有了客户端，他们俩是怎样通讯，又是基于什么通讯协议做出交互的呢？ 介绍 基于我们的目的，本文主要讲解和实践 Redis 的通讯协议 Redis 的客户端和服务端是通过 TCP 连接来进行数据交互， 服务器默认的端口号为 6379 客户端和服务器发送的命令或数据一律以 \r\n （CRLF）结尾（这是一条约定） 协议 在 Redis 中分为请求和回复，而请求协议又分为新版和旧版，新版统一请求协议在 Redis 1.2 版本中引入，最终在 Redis 2.0 版本成为 Redis 服务器通信的标准方式 本文是基于新版协议来实现功能，不建议使用旧版（1.2 挺...阅读全文
前言 矿工在PoW中负责了产生区块的工作，把一大堆交易交给它，它生成一个证明自己做了很多工作的区块，然后将这个区块加入到本地区块链并且广播给其他节点。 接下来我们将从以下角度介绍矿工： 角色。矿工不是一个人，而是一类人，可以把这一类人分成若干角色。 通过了解一个区块产生的主要流程，掌握矿工的工作流。 通过了解矿工的主要函数介绍，掌握矿工的主要挖矿机制。 介绍矿工由哪些部分组成，会和哪些其他模块进行交互，这些部分是如何协作产生区块的。 角色 有3种角色：miner、worker、agent。我们分别使用矿长、副矿长、矿工进行类比。 miner：是矿长，负责管理整个矿场的运作，比如：启动、停止挖矿，处理外部请求，设置挖矿获得的奖励的钱包地址等等。 worker：副矿长，负责具体挖矿工作的安排，把...阅读全文
请教一个问题：我多个硬件设备通过udp跟服务器连接，他会隔1小时给服务器去上报数据 每个设备是有唯一的标识码IMEI 现在想通过服务器把数据发给指定设备 该怎么操作 之前的做法是 当设备连接服务器时就把UDPAddr的对象存到一个map里 key值为imei号 但是设备连着 第二次发报文后 ip是不会变的 端口变了 我想用WriteToUDP 就找不到接受对象...阅读全文
作为golang并发编程思想的重要组成，channel(通道)非常重要，和goroutine(go协程)一起使用，用来实现go的CSP(Communicating Sequential Processes)并发模型。 Do not communicate by sharing memory; instead, share memory by communicating 不要以共享内存的方式来通信，相反，要通过通信来共享内存。 因为channel的重要性，有必要对其原理和源码进行学习，在参考了网络上各种大牛的分享后，将其作为笔记记录下来，如有不足之处，还请指正。 源码路径: go1.11/src/runtime/chan.go channel结构体 type hchan struct { //...阅读全文
What you are wasting today is tomorrow for those who died yesterday; what you hate now is the future you can not go back. 你所浪费的今天是昨天死去的人奢望的明天； 你所厌恶的现在是未来的你回不去的曾经。 Channel通道介绍 什么是channel， channel可以理解为goroutine之间通信的通道。一端发送数据方到达接收数据方的桥梁。 声明通道 每个channel都有一个与之相关联的类型， 这种类型是信道允许传输的数据类型。 channel的零值是nil， 一个nil channle没有任何用途。因此必须使用类似map和slice的方式定义。 package m...阅读全文
package main import ( "fmt" "sync" "time" ) /* WaitGroup用于等待一组线程的结束。父线程调用Add方法来设定应等待的线程的数量。每个被等待的线程在结束时应调用Done方法。 同时，主线程里可以调用Wait方法阻塞至所有线程结束。 */ var wg sync.WaitGroup func test(i int){ fmt.Println("test func...", i) time.Sleep(time.Second) // 表示goroutine已经执行完成 wg.Done() } func main() { var count = 100 // 添加goroutine计数器 wg.Add(count) for i:=0;i
版权声明：本文为博主Liigo原创，未经授权不得转载。 https://blog.csdn.net/liigo/article/details/7467309 Go语言（golang）第一个正式版Go1发布了，但是这个新兴的编程语言还是非常不完善。这不，我（Liigo）又发现它的编译器竟然不支持编译带BOM的UTF-8编码的.go源文件。这就很奇怪，该语言明明要求源代码文件.go必须是UTF-8编码，但又不允许带UTF-8 BOM。要知道，这个世界上带BOM的文件太多了，很多文本编辑器/代码编辑器/IDE支持生成、甚至默认生成带有BOM的UTF-8文件。如果仅仅因为源代码文件多了BOM，编译器就不能编译这个文件，那也太低能了。 Go语言编译器(gc)不支持带有BOM的UTF-8源文件： Go...阅读全文
模板方法模式 定义一个操作中的算法的骨架，而将一些步骤延迟到子类中。 模板方法使得子类可以不改变一个算法的结构即可重定义该算法的某些特定步骤 Lock接口及其实现 中，DemoReentrantLock 和 DemoReadWriteLock 代码相似度很高。DemoReentrantLock 中的加解锁完全可以用DemoReadWriteLock中代替，即可实现加解锁。 优化两个锁的代码-采用模板方法模式 CommonMask实现两个锁共有的方法 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurr...阅读全文
最近在开发过程当中遇到了几个goroutine通信的问题，我觉得这几个问题非常具有代表性，因此拿出来和大家分享一下。 检查channel是否关闭 开发过程当中有遇到这样的一种情况，需要检查channel是否关闭，如果关闭则不进行相应操作，否则会panic等现象。在golang的select语法当中，default分支可以解决上述问题，请看如下例子： closechan := make(chan int,0) dchan := make(chan int,0) select{ case <- closechan: fmt.Println("channel already closed.") return default: fmt.Println("channel not closed, do ...阅读全文
微服务架构将某个单一的复杂系统拆分成多个可独立自治的服务，服务之间通过松耦合的方式进行交互，这为我们带来了许多好处，包括低耦合、可重用性、业务敏捷性和分布式部署能力、强扩展性。但于此同时，也给我们引进了新的挑战。 在微服务场景下，每个模块之间的互通都通过远程调用的方式来代替传统单体架构中的内存调用，在获得扩展性、重用性的同时，也使得整个体系结构因为网络的不稳定性、资源的过量使用变得更加脆弱。当一项或多项依赖服务持续不可用或出现高延迟时，将会导致整个服务级联失败。而且，服务客户端中的重试逻辑会使呈现高延迟的服务状况恶化，最终使整个系统陷入瘫痪。就像多米诺骨牌效应一样推倒整个系统。 duominuo.jpg 为了提高服务的可用性，避免级联影响，最经典的解决办法之一就是在服务之间的RPC边界引入...阅读全文
