前言 本章主要说一下如何去使用Jetbrains的各类工具，并且在上周参加了Jetbrains开发者日的大会，把参会的感受和体验在这里分享给各位。话不多说，我们进入正题。 使用 想必各位一定使用过Jetbrains的任意一款产品，就算没用过也应该听说过吧。Jetbrains从开始至今总共分为三大模块 Developer Ide (集成开发工具) Language (Jetbrains的开发语言 Kotlin) DevOps (任务管理，持续集成，持续部署的一些东西) 对于Developer Ide我推荐使用Jetbrains ToolBox，它是管理所有Jetbrains Ide的工具。 Jetbrains平均一个月做一次小更新，安装了Jetbrains ToolBox就不必再去关心更新的事...阅读全文
问题： 和一些做mmo大型网络游戏服务器端的人讨论了一些mysql数据库访问的问题，因为我本人没有实际开发大型网游的经验，所以他们说的我也理解的不深，我还是努力理解，但还是觉得他们所谈的好象并不是那么一回事； mysql数据库的访问一般就通过他提供的c api接口访问就可以了，网络游戏服务器端事先和mysql建立并保持1个或者几个连接，正常情况下这些连接将一直保持； 为提高性能，网络游戏服务器程序启动后一般都会把事先需要的数据从数据库提取到内存供使用，以减少读数据库的频率，这到好理解； 当然，网游开发中，遇到需要立即写库或者更新库的内容时，我们会立即向数据库服务器发送insert,delete,update等以期望数据库能立即更新我们的数据，比如玩家切换到新地图，这种数据就有必要立即提交到数...阅读全文
这是探讨 Go 编译器两篇文章的最后一篇。在[第 1 部分中](https://studygolang.com/articles/25101)，我们通过构建自定义的编译器，向 Go 语言添加了一条新语句。为此，我们按照此图介绍了编译器的前五个阶段:  在"rewrite AST"阶段前，我们实现了 until 到 for 的转换；具体来说，在[gc/walk.go](https://github.com/golang/go/blob/master/...阅读全文
### 定时器 + [查找更多案例](http://www.5lmh.com/ "查找更多案例") + Timer：时间到了，执行只执行1次 ```go package main import ( "fmt" "time" ) func main() { // 1.timer基本使用 //timer1 := time.NewTimer(2 * time.Second) //t1 := time.Now() //fmt.Printf("t1:%v\n", t1) //t2 := <-timer1.C //fmt.Printf("t2:%v\n", t2) // 2.验证timer只能响应1次 //timer2 := time.NewTimer(time.Second) //for { // <...阅读全文
Buffer 介绍 Buffer 是 bytes 包中的一个 type Buffer struct{…} A buffer is a variable-sized buffer of bytes with Read and Write methods. The zero value for Buffer is an empty buffer ready to use. （是一个变长的 buffer，具有 Read 和Write 方法。 Buffer 的 零值 是一个 空的 buffer，但是可以使用） Buffer 就像一个集装箱容器，可以存东西，取东西（存取数据） 创建缓冲器 func main() { buf1 := bytes.NewBufferString("hello") buf2...阅读全文
现需要设计一款SNMP采集器，采集共约50台机器的数据，每台机器上有若干指标值需采集，且每个指标值需独立设置采集周期，我设想的是使用goroutine对50台机器进行并发采集，其中对每项指标采集也使用goroutine，请大牛们赐教，这样的goroutine嵌套能实现吗？P.S.新手上路，求...阅读全文
前一阵子看到了一个Golang的JSON库go-simplejson，用来封装与解析匿名的JSON，说白了就是用map或者slice等来解析JSON，觉得挺好玩，后来有个项目恰好要解析JSON，于是就试了试，不小心看了一眼源代码，发现竟然是用的Golang自带的encoding/json库去做的解析，而其本身只是把这个库封装了一层，看起来更好看罢了。于是心想能不能徒手写一个解析器，毕竟写了这么多年代码了，也JSON.parse，JSON.stringify了无数次。捣腾了两天，终于成了，测试了一下，性能比自带的库要高很多，速度基本上在1.6到7倍之间（视JSON串的大小和结构而定），所以决定写这篇文章分享一下思路。 先插一个段子，作为一个已经完完整整写了将近三年代码的老码农，前一段面试，不止...阅读全文
本博客是深入研究Envoy Proxy和Istio.io 以及它如何实现更优雅的方式来连接和管理微服务系列文章的一部分。 这是接下来几个部分的想法（将在发布时更新链接): 断路器（第一部分） 重试/超时（第二部分） 分布式跟踪（第三部分） Prometheus的指标收集（第四部分） rate limiter（第五部分） 第五部分 - rate limiter Envoy ratelimit filters Envoy通过两个过滤器与Ratelimit服务集成： Network Level Filter： envoy为安装过滤器的侦听器上的每个新连接调用Ratelimit服务。这样，您可以对通过侦听器的每秒连接进行速率限制。 HTTP Level Filter：Envoy为安装过滤器的侦听器上...阅读全文
在面对对象编程(OOP)，我们常把某个对象实现的具体行为的函数称作方法。例如 C++中A类的某个函数实现了某种行为，我们就叫做 A 的方法。在 golang 中如果要定义一个方法，只需要在函数声明时，在函数名前加上某个变量，即该变量实现了某个方法。 方法声明 type Point struct{ X, Y float64 } //按照传统方法,我们可能会按照下面的方式来写 func Distance(p, q Point) float64 { return math.Hypot(q.X - p.X, q.Y - p.Y) } //但在 go 语言中则是这样 func (p Point) Distance(q Point) float64 { return math.Hypot(q.X-p.X...阅读全文
beego怎样将日志发送到网络服务器， 文档里面写到了这种方式： logs.SetLogger(logs.AdapterConn, `{"net":"tcp","addr":":7020"}`) 这样不需要接收的服务器接收么·？ 需要接收的又怎样去接收·？ 跪求示...阅读全文
Go不是面向对象的语言，但是使用组合、嵌套和接口可以支持代码的复用和多态。关于结构体嵌套：外层结构体类型通过匿名嵌套一个已命名的结构体类型后就可以获得匿名成员类型的所有导出成员，而且也获得了该类型导出的全部的方法。比如下面这个例子： type ShapeInterface interface { GetName() string } type Shape struct { name string } func (s *Shape) GetName() string { return s.name } type Rectangle struct { Shape w, h float64 } Shape类型上定义了GetName()方法，而在矩形Rectangle的定义中匿名嵌套了Shape类型...阅读全文
service.go package main import ( "net" "fmt" ) // TCP service func main() { // 1.监听本地端口 linser, err := net.Listen("tcp", "127.0.0.1:27666") if err != nil{ fmt.Println("Linsten 127.0.0.1:27666 faild, error of:", err) return } // 2.等待客户端连接 client_conn, err := linser.Accept() if err != nil { fmt.Println("conn error of:", err) return } // 3.接收客户端信息 var...阅读全文
并发：一箭多发 并行：同一时刻一起执行(齐头并进) 例子： package main import ( "fmt" "sync" ) // goroutine 多任务操作 var wg sync.WaitGroup // 声明一个全局的 wg 计数器对象[上下文管理器] (WaitGroup 结构体类型) func fun1(i int) { defer wg.Done() // 延迟调用，当次函数将要执行完毕时调用 fmt.Println(i) } func main() { for i := 0; i < 100; i++{ // 每次循环开启一个新的线程执行一个匿名函数 wg.Add(1) //go func(i int){ // 匿名函数 // defer wg.Done() // ...阅读全文
背景 最近在开发一个功能时，需要通过 http 协议上报大量的日志内容，但是在 Go 标准库里的 http client 的 API 是这样的： http.NewRequest(method, url string, body io.Reader) body 是通过io.Reader接口来传递，并没有暴露一个io.Writer接口来提供写入的办法，先来看看正常情况下怎么写入一个body，示例： buf := bytes.NewBuffer([]byte("hello")) http.Post("localhost:8099/report","text/pain",buf) 需要先把要写入的数据放在Buffer中，放内存缓存着，但是我需要写入大量的数据，如果都放内存里肯定要 OOM 了，htt...阅读全文
得到了错误信息 minikube start image.png 进入minikube github 官网 https://github.com/kubernetes/minikube 在 minikubhe docs 中 https://minikube.sigs.k8s.io/docs/start/macos/ image.png minikube start --vm-driver=virtualbox //估计跑很久很久吧 157517584167110414 我的界面卡在这一步，等一下排除原因 快速入门给你的几个命令行 kubectl get po -A minikube config set memory 4096 下一步就是 exmplate https://minikube....阅读全文
Rabbitmq 简单介绍,安装和go客户端使用 1，消息队列介绍 1.1 什么是消息队列？ 消息队列（英语：Message queue）是一种进程间通信或同一进程的不同线程间的通信方式，软件的贮列用来处理一系列的输入，通常是来自用户。消息队列提供了异步的通信协议，每一个贮列中的纪录包含详细说明的数据，包含发生的时间，输入设备的种类，以及特定的输入参数，也就是说：消息的发送者和接收者不需要同时与消息队列互交。消息会保存在队列中，直到接收者取回它。消息队列，一般我们会简称他为MQ(Message Queue)，消息队列可以简单的理解为：把要传输的数据放在队列中 说明： Producer：消息生产者，负责产生和发送消息到 Broker； Broker：消息处理中心。负责消息存储、确认、重试等，一...阅读全文
1. 我的工作主要是pomelo node.js后端主程，因为之前经常用async.waterfall 这个第三方async库，并且这个库也很好用，就是代码有些多，后来换工作了公司用了新框架。2. 开始大量使用async/await来开发， 或者用promise或者其他的东西，主要目的就是为了解决低于地狱回调的问题。3. 使用async/await的过程中发现一个问题，因为服务器端开发，所以对错误是很敏感的，并不允许有错误，而不去管它，当时能想到的方案有两个。其一：对用到 await的地方用try catch 方法一 其二是： 方法二 如果有多个await的话，每个都用try catch那样体验很不好，所以我经常在项目中用到的就是方法二，但是方法二也不是很好。然后我在网上找了找，还有一种方法...阅读全文
作者：Adam Presley | 地址：Writing a Lexer and Parser in Go - Part 1 译者前言 一直对词法分析与解析的话题比较感兴趣，最近发现了好几篇相关的优秀文章，准备好好翻译和研究下。我的理解，词法分析与解析的应用还是比较广泛的，无论简单的配置文件、各种模板语言、还是我们每天在写编程语言都离不开它。 本篇文章一个系列文章的第一篇，主要介绍的是词法分析与解析的一些基础概念，包括什么是词法分析，什么是解析，Token 如何表示等等。 正文如下： 从今天开始，我将会用三篇文章介绍在 Go 中如何构建一个简单的词法分析与解释器。文中介绍的内容主要是基于 Rob Pike 在 2011 年关于 Lexical Scanning In Go 的演讲。这个系列文...阅读全文
由于公司经常需要异地办公，在调试的时候需要用到内网环境，因此手动写了个代理转发服务器給兄弟们用，项目地址是：socks5proxy。 选型上，语言上就选择了Go，简单清晰，转发协议选择了socks5。 SOCKS5协议介绍 SOCKS是一种网络传输协议，主要用于客户端与外网服务器之间通讯的中间传递，SOCKS是"SOCKetS"的缩写。 SOCKS5是SOCKS4的升级版，其主要多了鉴定、IPv6、UDP支持。 SOCKS5协议可以分为三个部分： (1) 协议版本及认证方式 (2) 根据认证方式执行对应的认证 (3) 请求信息 （1）协议版本及认证方式 创建与SOCKS5服务器的TCP连接后客户端需要先发送请求来协议版本及认证方式， VER NMETHODS METHODS 1 1 1-25...阅读全文
文章将会被同步至微信公众号：Android部落格 Android OKHttp系列皆为本人原创文章，未经允许严禁转载 概述 选定连接接口，并开始连接目标 流程图如下： okhttp-ConnectInterceptor.jpg 原图片地址：http://i66.tinypic.com/rjqglx.jpg 1、找RealConnection 选择合适的HttpCodec，为什么要选择呢？因为涉及到Http版本的问题，此处需要兼容，先看代码： boolean doExtensiveHealthChecks = !request.method().equals("GET"); HttpCodec httpCodec = streamAllocation.newStream(client, cha...阅读全文
藏在正则表达式里的陷阱，一个正则表达式导致CPU 利用率居高不下 前几天线上一个项目监控信息突然报告异常，上到机器上后查看相关资源的使用情况，发现 CPU 利用率将近 100%。通过 Java 自带的线程 Dump 工具，我们导出了出问题的堆栈信息。 藏在正则表达式里的陷阱，一个正则表达式导致CPU 利用率居高不下 我们可以看到所有的堆栈都指向了一个名为 validateUrl 的方法，这样的报错信息在堆栈中一共超过 100 处。通过排查代码，我们知道这个方法的主要功能是校验 URL 是否合法。 很奇怪，一个正则表达式怎么会导致 CPU 利用率居高不下。为了弄清楚复现问题，我们将其中的关键代码摘抄出来，做了个简单的单元测试。 public static void main(String[] ...阅读全文
序言（初衷） 设计该系统初衷是基于描绘业务（或机器集群）存储模型，分析代理缓存服务器磁盘存储与回源率的关系。系统意义是在腾讯云成本优化过程中，量化指导机房设备扩容。前半部分是介绍背景，对CDN缓存模型做一些理论思考。后半部分会实际操作搭建一个微型但是五脏俱全的分布式通用系统架构，最后赋予该系统一些跟背景相关的功能，解决成本优化中遇到的实际问题。缓存服务器存储模型架构（背景）： 图1 存储模型腾讯CDN的线上路由是用户à分布于各地区各运营商的OC->SOC->SMid->源站。各个层级节点部署的都是缓存服务器。来自用户的部分请求流量命中服务器，另一部分产生回源流量。随着业务带宽自然增长，用户端带宽增长，假设业务回源率不变的情况下，磁盘缓存淘汰更新（淘汰）速率变快，表现为以下业务瓶颈（iowai...阅读全文
前言 大家好，我是煎鱼，本章节将介绍 gRPC 的流式，分为三种类型： Server-side streaming RPC：服务器端流式 RPC Client-side streaming RPC：客户端流式 RPC Bidirectional streaming RPC：双向流式 RPC 流 任何技术，因为有痛点，所以才有了存在的必要性。如果您想要了解 gRPC 的流式调用，请继续 图 gRPC Streaming 是基于 HTTP/2 的，后续章节再进行详细讲解 为什么不用 Simple RPC 流式为什么要存在呢，是 Simple RPC 有什么问题吗？通过模拟业务场景，可得知在使用 Simple RPC 时，有如下问题： 数据包过大造成的瞬时压力 接收数据包时，需要所有数据包都接受成...阅读全文
1.array的定义 定义数组的格式: var a[4]int //元素自动初始化为零 a := [...]int{19:1} //编译器按照初始化值数量确定数组长度 a := [5]int{1,2} //未提供初始值的元素自动初始化为零 数组长度也是类型的一部分，因此具有不同长度的数组为不同类型 数组在go中为值类型 2.数组指针和指针数组 //数组指针是指获取数组变量的地址。 //此时变量p就是指向数组的指针。特别注意p定义的类型为长度为100的数组的指针。 长度必须相等才能赋值。 func main() { var a = [...]int{99:1} var p *[100]int = &a fmt.Println(p) } //指针数组是指元素为指针类型的数组 func main(...阅读全文
系统：Mac编辑器：Sublime text 3+gosublime(1)go语言安装Golang中国下载：https://www.golangtc.com/download本文在编写的时候，使用的版本是：go1.9.darwin-amd64.pkg，下载后直接安装就行，安装完开一个终端，输入：go version可以查看是否安装成功安装完后需要配置环境变量export GOPATH=/Users/lihan/Develop/golang/workspaceexport GOBIN=$GOPATH/binexport PATH=$PATH:$GOBIN(2)安装sublime Text 3中的package install去网上搜索此类相关的教程(3)通过package install安装g...阅读全文
摘要： 概述 阿里云的公网入口产品共有三个，SLB、EIP、NAT网关，这几个产品都可以作为云上资源的公网入口，他们之间有何区别，又分别应该在什么场景下使用呢？ **点此查看原文：http://click.aliyun.com/m/41840/** **开始** 阿里云的公网入口产品共有三个，SLB、EIP、NAT网关，这几个产品都可以作为云上资源的公网入口，他们之间有何区别，又分别应该在什么场景下使用呢？ 概念 -- **负载均衡SLB** **对多台云服务器进行流量分发的负载均衡服务，可以通过流量分发扩展应用系统对外的服务能力，通过消除单点故障提升应用系统的可用性。** 可见云计算中的负载均衡除了通过流量分发让后端的服务器负载均衡，还有两个重...阅读全文
请从github下载配套代码： https://github.com/shuningzhang/learn_golang 大家都知道Web服务是基于HTTP协议的，而HTTP协议又是TCP协议上的应用层协议。因此我们在开发一个Web服务之前，我们先介绍一下如何使用Go语言开发一个基于TCP的客户端与服务端程序（关于TCP协议的原理可以参考本号之前的文章《从socket到TCP协议，透彻理解网络编程》）。 Go语言从入门到精通-04｜ Socket客户端与服务端 程序比较简单，服务端用于等待客户端的连接，连接建立成功后，如果接到客户端的数据，则原封不动的返回相同的数据。客户端建立与服务端的连接，连接建立成功后向服务端发送字符串数据，并等待接收服务端的返回。 服务端 前面已经介绍，服务端用于等待...阅读全文
在本系列的第一篇文章中，研究了kubernetes如何结合使用虚拟网络设备和路由规则，以允许在一个群集节点上运行的Pod与在另一个群集节点上运行的Pod通信，只要发送者知道接收者的Pod网络即可。 IP地址。如果您还不熟悉Pod的交流方式，那么在继续之前值得一读。集群中的Pod网络很简单，但仅凭其不足以创建持久性系统。那是因为kubernetes中的Pod是短暂的。您可以将Pod IP地址用作终结点，但不能保证该地址在下次重新创建Pod时不会更改，这可能由于多种原因而发生。 您可能已经意识到这是一个老问题，并且它有一个标准的解决方案：通过反向代理/负载均衡器运行流量。客户端连接到代理，代理负责维护将请求转发到的健康服务器列表。这对代理服务器提出了一些要求：代理服务器本身必须是耐用的并且能够抗...阅读全文
一、前言 RabbitMQ是一个开源的消息代理软件（面向消息的中间件），它的核心作用就是创建消息队列，异步接收和发送消息，MQ的全程是：Message Queue中文的意思是消息队列。 1.1 使用场景 削峰填谷：用于应对间歇性流量提升对于系统的“破坏”，比如秒杀活动，可以把请求先发送到消息队列在平滑的交由系统去处理，当访问量大于一定数量的时候，还可以直接屏蔽后续操作，给前台的用户友好的显示； 延迟处理：可以进行事件后置，比如订单超时业务，用户下单30分钟未支付取消订单； 系统解耦：消息队列也可以帮开发人员完成业务的解耦，比如用户上传头像的功能，最初的设计是用户上传完之后才能发帖，后面有增加了经验系统，需要在上传头像之后增加经验值，到后来又上线了金币系统，上传头像之后可以增加金币，像这种需求...阅读全文
本人从事游戏行业，因此这个缓存系统主要针对网络游戏的数据访问模式设计。 首先分析下网络游戏的数据访问模式： 1）关系性弱：对于绝对大多数的游戏类型来说，能通过一个key来访问数据就够了。 2）读多写多：用户登录时通常需要加载大量数据，查询其它玩家信息也是一个频繁的操作请求。在不考虑定时回写的情况下，玩家的每个更新类请求都会产生一次数据库回写请求，对于一个在线10W,养成类游戏，每秒写请求达到10W+是可能的。 3）冷数据多：游戏的注册用户数和活跃用户数差距非常大。大量数据平时几乎不被访问，只有偶尔做活动用户回流时才被访问。 4）响应及时性：即使是一个查看其它用户信息的查询请求，响应时间超过200ms也是非常不友好的。 基于以上考量，我设计了一套名为flyfish的冷热缓存系统，系统设计目标如...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ 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: ...阅读全文
前言 大家好，五一到了，在这里先祝大家节日快乐。不知道这个假期你打算出门吗？我是打算不出远门了，怕死，哈哈。索性好好宅家里学习，强化一下自己。 相信大家也感受到了，随着互联网加速了信息的流动速度，知识的更新迭代也在加速。可能原本靠着一门手艺可以过一辈子，现在可能每5～10年就需要一次大的迭代才能跟上社会的发展步伐，不被out。 并且，随着最近几年知识付费的兴起，提倡「终身学习」的声音越来越大了。不管是出于什么目的在鼓吹「终身学习」，这个观点的价值取向总是正向的。 但是对于学习这个问题，困扰我们大部分人的并不是学什么或者怎么学。而是，总是学着学着没动力，半途而废了。甚至是一开始学习就犯困、打瞌睡。 不瞒你说，我之前也在这种状态困扰过好久，深知这种感受的滋味。 毕竟，再好的美食，吃不下去对你来说...阅读全文
闭包 通过一个累加器来看闭包的概念 python 闭包 def fun1(): sum = 0 def fun2(v): nonlocal sum sum += v return sum return fun2 a = fun1() for i in range(10): print(a(i)) fun1返回的不是一个值,而是一个函数 fun2,a = fun2,所以 a(i)会打印 sum 的值,为什么 sum 一直在加呢,函数里的值为什么可以带到函数体外呢,这就是闭包的神奇之处,闭包是离散数学的一个概念,可以多看看网上的讲解加深印象 其实可以把闭包看做一个类, sum 就是类里的属性, fun2就是类的方法 所以 fun2可以使用 sum(自由变量) java 闭包 static Fun...阅读全文
1. 下载安装go语言安装包进入https://golang.org/dl/ 选择下载.pkg 直接双击.pkg文件即可，这里安装路径默认方便后续环境配置2. 配置环境打开iTerm终端查看隐藏文件ls -a若不存在文件 .bash_profile就新建touch .bash_profile进入文件vim .bash_profile编辑文件i添加代码 export GOPATH=/Users/guoyu/go export GOBIN=$GOPATH/bin export PATH=$PATH:$GOBIN 需要注意的是GOPATH=/Users/用户/go，用户修改为mac登录用户结束编辑Esc保存推出:wq使配置文件生效source .bash_profile3. 下载编辑器开始上手进入...阅读全文
最近因为换了Mac，以前的Linux基本上不再使用了，但是我的SS代理还得用。SS代理大家都了解，一个很NB的Socket代理工具，但是就是因为他是Socket的，想用HTTP代理的时候很不方便。 以前在Linux下的时候，会安装一个Privoxy把Socket代理转换为HTTP代理，开机启动，也比较方便。但是Mac下使用Brew安装的Privoxy就很难用，再加上以前一个有个想法，一个软件搞定Socket和HTTP代理，这样就不用安装一个单独的软件做转换了。 想着就开始做吧，以前基本上没有搞过太多的网络编程，最近也正好在研究Go，正好练练手。 我们这里主要讲使用HTTP／1.1协议中的CONNECT方法建立起来的隧道连接，实现的HTTP Proxy。这种代理的好处就是不用知道客户端请求的数...阅读全文
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之路，包括我身边的一些技术同事给自己“充电”新技术，能在未来工作中更好的生存发展。个人使用Mac环境，下面大概简述一安装过程：一、准备工作官网下载安装包：备注：目前最新稳定版本是v1.9开发工具包又分为安装版和压缩版。安装版是Mac和Windows特有的，他们的名字类似于：go1.9.darwin-amd64.pkggo1.9.windows-386.msigo1.9.windows-amd64.msi安装版，有点傻瓜式安装，环境路径都默认好，操作起来比较简单方便。压缩版的就是一个压缩文件，可以解压得到里面的内容，他们的名字类似于：go1.9.darwin-amd64.tar.gzgo1.9.linux-386.tar.gzgo1.9.linux-amd...阅读全文
一，效果 服务器返回了一张图片 二，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...阅读全文
使用golang网络编程实现一个简单的TCP代理（不支持HTTP） package main import ( "flag" "github.com/rs/zerolog" "net" "os" ) var logger = zerolog.New(os.Stdout).With().Timestamp().Logger() func main() { help := flag.Bool("help", false, "print usage") bind := flag.String("bind", "127.0.0.1:6000", "The address to bind to") backend := flag.String("backend", "", "The backend s...阅读全文
注意： 此文章只是我的个人笔记，如有谬误，错误， 请一定指出！ 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...阅读全文
golang是特别不适合拿来做应用层可靠协议开发的语言。所有的可靠协议都依赖于连接状态，在讲究并发的场景下，所有的状态都依赖于事件，所有的事件都依赖于内核文件描述符，问题是，在可靠场景下，我们常常需要将一个端口用作一块网卡，一块网卡可以有65536个描述符并发处理事件，一个端口却只有一个描述符，这一个描述符需要模拟出65536个描述符的事件处理效能，这本来就是令人头大的问题。golang本身的协程机制----固然golang和大多数的协程实现不尽一致----导致每一个事件的处理都应短暂，且事件之间应是无状态的，如果对于可靠协议各阶段的业务与事件理解不到位，极其容易实现出资源有余，而协议效能低下的情况。为什么要有上面一段呢？因为目前的Sia，IPFS，Storj，Swarm都是golang实现...阅读全文
前言以前也研究过这个protobuf这一语言标准，这一google开发的用来网络协议指定的标准。这次再遇到这里就着研究fabric的机会深入的说明一下。用这个进行协议的指定是比较节约网络带宽，编解码方便。下面我们就从数据类型和编解码方式两个方面来加以说明。通过本文的阅读你将会发现，利用好protobuf有利于你提高程序编写的效率和减少协议指定的繁杂性。特别是如果你要设计的是一个网络系统的时候。1、protobuf的关键字和数据类型针对不同的程序语言（C++,java，golang）有不同的protobuf解析器，但是他们的数据类型是一样的，关键字略有差别。这里我们以golang和protoc-gen-go解析器为例来进行说明。protocol buffer 语言的源文件一般以name.pro...阅读全文
兄弟连Go语言培训课程体系设计架构包括了区块链的基础语言Go语言、区块链后端技术体系、区块链公链、区块链分布式应用开发等内容讲解，以及到最后的面试指导和项目实战。课程由清华微软谷歌名师团队精心打造，历时半年时间共同研发而出。 Go可变长参数列表 支持可变长参数列表的函数可以支持任意个传入参数，比如fmt.Println函数就是一个支持可变长参数列表 的函数。 packagemain import"fmt" //这个函数可以传入任意数量的整型参数 funcsum(nums...int){ fmt.Print(nums,"") total:=0 for_,num:=rangenums{ total+=num } fmt.Println(total) } funcmain(){ //支持可变长参数...阅读全文
states 是服务端传来的一个包含结构体的列表，stateIndex 是服务端传来的一个数字 detail.html 中的代码片段 ```html {{ range $i, $v := .states }} {{ if le $i .stateIndex }} // 此行报错: can't evaluate field stateIndex in type string qqqqq {{ else }} xxx {{ end }} {{ end }} ``` 请问怎么处...阅读全文
5263. 二维网格迁移 给你一个 n 行 m 列的二维网格 grid 和一个整数 k。你需要将 grid 迁移 k 次。 每次「迁移」操作将会引发下述活动： 位于 grid[i][j] 的元素将会移动到 grid[i][j + 1]。 位于 grid[i][m - 1] 的元素将会移动到 grid[i + 1][0]。 位于 grid[n - 1][m - 1] 的元素将会移动到 grid[0][0]。 请你返回 k 次迁移操作后最终得到的 二维网格。 拿golang刷题简直有病 执行结果：通过 执行用时 :32 ms, 在所有 golang 提交中击败了100.00%的用户 内存消耗 :6.2 MB, 在所有 golang 提交中击败了100.00%的用户 func pos(n int,...阅读全文
简述 无副作用（No Side Effects） 高阶函数（High-Order Function） 科里化（Currying） 闭包（Closure） 不可变（Immutable） 惰性计算（Lazy Evaluation） Monad 一等公民 高阶函数（High-Order Function）是函数式编程思维中的重要条件，而满足该条件的编程语言则需要将函数作为该语言的一等公民来看待。符合一等公民的条件是： 函数可以作为一种数据类型的值，赋值于一个变量； 函数可以作为参数，在其他函数中进行传递； 函数可以作为返回值，在其他函数中返回； image 将函数视作一等公民的语言有：JavaScript、Golang、Python、Scala、Lua、Lisp、Scheme等。同时，有着越来越多...阅读全文
