导语 rabbitMQ是市面上应用很广的一种应用间传送数据的通信方式，是由erlang语言开发，主要特点就是异步通信，实现服务与服务之间的解耦。特点可靠性：提供了持久化、传输时确认、发布时确认、跟踪机制灵活的路由：有四种交换器负责分发路由集群：支持集群多种协议：支持STOMP、和MQTT协议多语言：支持大部分流行语言友好的界面：提供了直观的管理界面可扩展：提供了许多插件。应用场景高并发排队机制：比如在秒杀场景，提示用户正在等待，在队列里存放了有序的待处理的消息，而不是所有的消息杂乱无章服务之间的解耦：服务之间可通过发布订阅的模式，让Rabbitmq队列通知订阅了该消息的服务执行相关代码。工作机制在其通信的过程中，有两个重要的角色，分别是生产者和消费者，需要强调的是RabbitMQ服务器并不产...阅读全文
之前写过一篇《Python修饰器的函数式编程》，这种模式很容易的可以把一些函数装配到另外一些函数上，可以让你的代码更为的简单，也可以让一些“小功能型”的代码复用性更高，让代码中的函数可以像乐高玩具那样自由地拼装。所以，一直以来，我对修饰器decoration这种编程模式情有独钟，这里写一篇Go语言相关的文章。 看过Python修饰器那篇文章的同学，一定知道这是一种函数式编程的玩法——用一个高阶函数来包装一下。多唠叨一句，关于函数式编程，可以参看我之前写过一篇文章《函数式编程》，这篇文章主要是，想通过从过程式编程的思维方式过渡到函数式编程的思维方式，从而带动更多的人玩函数式编程，所以，如果你想了解一下函数式编程，那么可以移步先阅读一下。所以，Go语言的修饰器编程模式，其实也就是函数式编程的模式...阅读全文
TiDB Markdown Plugin Repo: https://github.com/imiskolee/tidb-wasm-markdown一款可以让TiDB运行在Markdown中的插件。 背景 周三看到朋友圈在疯狂的刷 TiDB - Wasm 这个有意思的东西（让数据库运行在浏览器里？TiDB + WebAssembly 告诉你答案）。这的确是一件让人兴奋的工作成果，为WASM的应用提供了不错的思路。就这个项目本身而言也是有很大的价值。 我们在编程语言学习的时候，有诸如JSFiddle、Go Playground等很多不同的交互性环境可以使用，并且可以将这些环境内嵌到教学文章之中，形成了交互性的教学资料。但是在数据库的文章之中，只能是纯粹的纸上谈兵，读者很难进行直观的感受与实操。...阅读全文
// http.go package main import ( "log" "net/http" "time" ) func main() { server := &http.Server{ Addr: ":8888", WriteTimeout: 2 * time.Second, } mux := http.NewServeMux() mux.Handle("/", &myHandler{}) mux.HandleFunc("/bye", sayBye) server.Handler = mux log.Println("Starting server ...") log.Fatal(server.ListenAndServe()) } type myHandler struct{} f...阅读全文
课程介绍 SVN是现在软件开发之中的主流软件版本控制工具，在工作之中利用SVN可以有效的解决多人开发的代码管理问题，本课程将为读者讲解SVN服务器的配置以及基于MyEclipse的SVN客户端插件的配置与使用，并且在讲解之中着重讲解了冲突的产生于解决。 课时列表 • 课时1：SVN的配置及使用（SVN简介） • 课时2：SVN的配置及使用（搭建SVN服务器端） • 课时3：SVN的配置及使用（配置SVN客户端） • 课时4：SVN的配置及使用（项目发布与检出） • 课时5：SVN的配置及使用（冲突解决） 开始学习http://click.aliyun.com/m/27888/...阅读全文
大学里大家应该基本上都写过一些和控制台进行交互的课后作业，下面是一个go版本的简单交互程序。 package main import ( "bufio" "fmt" "os" ) func main() { in := bufio.NewReader(os.Stdin) // 声明并初始化读取器 fmt.Println("What is your name?") input, err := in.ReadString('\n') // 以回车为分隔符 if err != nil { fmt.Printf("oh, get error: %v\n", err) return } name := input[:len(input)-1] // 去除回车 fmt.Printf("Hello, %s...阅读全文
1.为什么要搞这种东西? 1.测试资源不够 ,没有时间测试iOS的需求 2.因为平时测试的不多, 所以对上报等问题总是漏测 3.会有一些改动, 会影响之前的一些上报逻辑 4.想自己跑一边所有的上报逻辑, 展示上报, 点击上报, trace上报等 2.为什么选择了Golang? 1.以前用python写过自动化的iOS app安装, 脱壳,打开,卸载等操作,想试试其他的方法. 2.考虑并尝试了privoxy , anyproxy ,对https的代理返回等都不够友好,花了很多时间没弄好,anyproxy有些https抓不到, 也不知道什么原因, 但是挺好写 3.同事跟我说要不试试golang, 看了下, 感觉可以符合需求, 还能学习新的知识点 安排 3.大致思路 1.因为我要测试的是SDK ,...阅读全文
全部11种状态 客户端独有的：（1）SYN_SENT （2）FIN_WAIT1 （3）FIN_WAIT2 （4）CLOSING （5）TIME_WAIT 。 服务器独有的：（1）LISTEN （2）SYN_RCVD （3）CLOSE_WAIT （4）LAST_ACK 。 共有的：（1）CLOSED （2）ESTABLISHED 。  状态变迁 1、建立连接时的状态变迁 一开始，建立连接之前服务器和客户端的状态都为CLOSED。服务器创建socket后开始监听，变为LISTEN状态。客户端请求建立连接，向服务器发送SYN...阅读全文
结构体定义的一般方式如下： type identifier struct { field1 type1 field2 type2 ... } type T struct {a, b int} 也是合法的语法，它更适用于简单的结构体。 var t *T t = new(T) 变量 t 是一个指向 T的指针，此时结构体字段的值是它们所属类型的零值，使用 new 函数给一个新的结构体变量分配内存，它返回指向已分配内存的指针。 无论变量是一个结构体类型还是一个结构体类型指针，都使用同样的 选择器符（selector-notation） 来引用结构体的字段，即： type myStruct struct { i int } var v myStruct // v是结构体类型变量 var p *mySt...阅读全文
解释服务器的几个概念： Request 用户请求的信息 Response 服务器返回的信息 Conn 用户的每次请求链接 Handler 处理请求和生成返回信息的处理逻辑 先写个小程序看看 func MyConn() { // 监听9090端口 listener, _ := net.Listen("tcp", "localhost:9090") defer listener.Close() // 建立用户请求的连接 conn, _ := listener.Accept() defer conn.Close() // 读取Request的内容 buff := make([]byte, 10000) len, _ := conn.Read(buff) fmt.Fprintln(os.Stdout...阅读全文
综述 http2Client实现自ClientTransport接口http2Server实现自ServerTransport接口 https://github.com/messixukej... 在liangzhiyang/annotate-grpc-go基础上补充了部分注释 客户端：http客户端连接创建 原理（引自http2-spec/HTTP2中英对照版(06-29).md at master · fex-team/http2-spec · GitHub.md)）：Upon establishment of a TCP connection and determination that HTTP/2 will be used by both peers, each endpoint ...阅读全文
说明 之前翻译的一个教程(没有备份原地址，梯子被封了)。原地址找到后补上 正文 使用预设的记录器可以节省时间，但如果确定要调整记录器，需要探索自定义记录器的方法 使用zap配置结构体创建记录器 可以使用配置zap.Config创建记录器，这是一个结构体，可以使用需要的值填充结构体，然后调用结构体的.Build()方法来获取记录器 cfg := zap.Config{...} logger, err := cfg.Build() 需要注意的是：zap.Config的结构体没有默认值，至少为zap需要的三个设置提供值 encoder: 只需要添加个Encoding:"XXX"，使用json就会创建一个JSON的encoder，另一个值是console 可以使用结构zapcore.EncoderC...阅读全文
背景 分布式多消息事务问题 在消息队列使用场景中，有时需要同时下发多条消息，但现在的消息队列比如kafka只支持单条消息的事务保证，不能保证多条消息，今天说的这个方案就时kafka内部的一个子项目中基于2PC和延迟更新来实现分布式事务 2PC 2PC俗称两阶段提交，通过将一个操作分为两个阶段：准备阶段和提交阶段来尽可能保证操作的原子执行(实际上不可能，大家有个概念先) 延迟更新 延迟更新其实是一个很常用的技术手段，简单来说，当某个操作条件不满足时，通过一定手段将数据暂存，等条件满足时在进行执行 基于2PC和延迟队列的分布式事务实现 系统架构 实现也蛮简单的， 在原来的业务消息之后再添加一条事务消息(事务消息可以通过类似唯一ID来关联到之前提交的消息)， worker未消费到事物提交的消息，就...阅读全文
前面写过关于深度拥抱区块链文章，区块链开发语言GO，被称为互联网时代的C语言，接下来我会以一个初学者的方式，由浅入深的介绍同时也会有搭配相应的代码，一步一步的学习GO语言，都说技多不压身，所以希望大家也一起践行，践行很重要。 首先我们要安装Go语言的开发包，根据自己的需求可以下载不同的对应平台的安装包，当然Go语言不管是在Windows平台、Mac平台还是Linux平台上都是支持的，这个无需担心不支持的情况，下载网址：https://studygolang.com/dl，可以到golang中国上查找相关资料也可以，网址：https://www.golangtc.com/ 下载好自己对应的版本，然后安装，因为占用空间不是很大，所以可以直接默认下一步下一步的推荐安装即可，接下来就是搭建开发环境，...阅读全文
前言 本章主要说一下如何去使用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() // ...阅读全文
得到了错误信息 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...阅读全文
序言（初衷） 设计该系统初衷是基于描绘业务（或机器集群）存储模型，分析代理缓存服务器磁盘存储与回源率的关系。系统意义是在腾讯云成本优化过程中，量化指导机房设备扩容。前半部分是介绍背景，对CDN缓存模型做一些理论思考。后半部分会实际操作搭建一个微型但是五脏俱全的分布式通用系统架构，最后赋予该系统一些跟背景相关的功能，解决成本优化中遇到的实际问题。缓存服务器存储模型架构（背景）： 图1 存储模型腾讯CDN的线上路由是用户à分布于各地区各运营商的OC->SOC->SMid->源站。各个层级节点部署的都是缓存服务器。来自用户的部分请求流量命中服务器，另一部分产生回源流量。随着业务带宽自然增长，用户端带宽增长，假设业务回源率不变的情况下，磁盘缓存淘汰更新（淘汰）速率变快，表现为以下业务瓶颈（iowai...阅读全文
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: ...阅读全文
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代码 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通常连接时间会很长，十几分钟到几天不等）。这样的话我们势必不能讲服务程序停止再启动的冷更新，服务进程热更新是非常有必要的。网关作为一个基础...阅读全文
