一、后台整体架构小程序和后台间使用https通信，保证安全性，这也是为了满足小程序官方的硬性规定。腾讯负载均衡作为后台入口有几个好处：帮助处理https的流量，然后解密后再将请求通过http转发给后端的服务器，简化了逻辑，减少了https对后台服务的性能影响，同时还能配置进行动态的伸缩。负载均衡将请求通过http转发给cvm进行处理。nginx做了个反向代理，go服务端跑在本地。使用腾讯云的redis和mysql数据库。redis用于频繁的用户鉴权等，mysql保存常规数据。这样的设计在抽奖这种情境下，已经能保证足够的并发和流量了。如果想提高并发量，可以通过配置负载均衡来进行动态伸缩，然后增加云数据库的处理能力。有时间再写下怎么进行性能评测和相应的提高并发量的升级。更多go语言内容请关注：h...阅读全文
本文主要使用Golang实现一个可用但不够标准，支持basic authentication的http代理服务。 为何说不够标准，在HTTP/1.1 RFC中，有些关于代理实现标准的条目在本文中不考虑。 Http Proxy是如何代理我们的请求 Http 请求的代理如下图，Http Proxy只需要将接收到的请求转发给服务器，然后把服务器的响应，转发给客户端即可。 Https 请求的代理如下图，客户端首先需要发送一个Http CONNECT请求到Http Proxy，Http Proxy建立一条TCP连接到指定的服务器，然后响应200告诉客户端连接建立完成，之后客户端就可以与服务器进行SSL握手和传输加密的Http数据了。 为何需要CONNECT请求？ 因为Http Proxy不是真正的服务...阅读全文
问题及场景 业务当中有需要分发http.request.body的场景。比如微信回调消息只能指定一个地址，所以期望可以复制一份消息发给其他服务。由服务B和接收微信回调的服务A一起处理微信回调信息。 解决思路 最开始考虑的是直接转发http.request。使用ReverseProxy直接将http.request由服务A转发给服务B。但是微信涉及到验证等问题，完全调整好非常麻烦。所以转换思路，打算将http.request.body的内容直接post给服务B。 可是http.request是readcloser。我们将http.request readAll的时候讲无法再次读取http.request里面的信息。 如何才能将http.request.body复制使用呢？ 其中c表示的是htt...阅读全文
consul是一个可以提供服务发现，健康检查，多数据中心，Key/Value存储等功能的分布式服务框架 用于实现分布式系统的服务发现与配置。与其他分布式服务注册与发现的方案，Consul的方案更"一站式"，内置了服务注册与发现框架、分布一致性协议实现、健康检查、Key/Value存储、多数据中心方案，不再需要依赖其他工具（比如ZooKeeper等）。使用起来也较为简单。Consul用Golang实现，因此具有天然可移植性(支持Linux、Windows和Mac OS X)；安装包仅包含一个可执行文件，方便部署，与Docker等轻量级容器可无缝配合。 Consul 的使用场景 docker 实例的注册与配置共享 coreos 实例的注册与配置共享 vitess 集群 SaaS 应用的配置共享 ...阅读全文
Go中的系统Signal处理 九 21 bigwhite技术志 Blog, Blogger, C, Daemon, Debian, Go, Golang, Google, Interface, Linux, map, Opensource, Programmer, Redhat, Signal, Slice, Ubuntu, Unix, 信号, 切片, 博客, 开源, 接口, 程序员, 结构体, 编程，语言 2 Comments 我们在生产环境下运行的系统要求优雅退出，即程序接收退出通知后，会有机会先执行一段清理代码，将收尾工作做完后再真正退出。我们采用系统Signal来 通知系统退出，即kill pragram-pid。我们在程序中针对一些系统信号设置了处理函数，当收到信号后，会执行相关清...阅读全文
当请求http://localhost:8080/html/home.html 自动转发请求到 http://192.168.0.1/html/home.html，带cookie请求，不过cookie要每次都手工抓取 package main import ( "io/ioutil" "log" "net/http" // "strings" ) func statistic(w http.ResponseWriter, r *http.Request) { //r.URL.RequestURI() client := &http.Client{} req, err := http.NewRequest("GET", "http://192.168.0.1"+r.URL.Path, nil)...阅读全文
初学go，写一个端口转发工具。很方便的小工具，希望能对大家学习go语言有所帮助。```packagemainimport("fmt""io""net""sync")varlocksync.MutexvartrueList[]stringvaripstringvarliststringfuncmain(){ip="0.0.0.0:888"server()}funcserver(){fmt.Printf("Listening%s",ip)lis,err:=net.Listen("tcp",ip)iferr!=nil{fmt.Println(err)return}deferlis.Close()for{conn,err:=lis.Accept()iferr!=nil{fmt.Println("建立...阅读全文
我们在生产环境下运行的系统要求优雅退出，即程序接收退出通知后，会有机会先执行一段清理代码，将收尾工作做完后再真正退出。我们采用系统Signal来 通知系统退出，即kill pragram-pid。我们在程序中针对一些系统信号设置了处理函数，当收到信号后，会执行相关清理程序或通知各个子进程做自清理。kill -9强制杀掉程序是不能被接受的，那样会导致某些处理过程被强制中断，留下无法恢复的现场，导致消息被破坏，影响下次系统启动运行。 最近用Golang实现的一个代理程序也需要优雅退出，因此我尝试了解了一下Golang中对系统Signal的处理方式，这里和大家分享。Golang 的系统信号处理主要涉及os包、os.signal包以及syscall包。其中最主要的函数是signal包中的Notify...阅读全文
gosshtool provide some useful functions for ssh client in golang.implemented using golang.org/x/crypto/ssh. go语言中提供ssh相关操作，支持ssh本地端口转发服务...阅读全文
gooverssh 是基于[gosshtool](http://www.oschina.net/p/gosshtool)的一个ssh开发包开发的一个基于ssh本地端口转发服务小应用，可以方便突破一些网络限制，如通过ssh代理访问内网数据库服务。 使用 编辑config.toml文件：
[ssh] local_bind_address = ":3306" ssh_server = "222.222.222.222" ssh_user = "root" ssh_password = "pa...阅读全文
RoadRunner是一个用Go语言实现的高性能PSR-7服务器，你没看错，是Go语言实现的。 RoadRunner首先用Go实现了一个高性能的服务器，然后通过goridge IPC把请求转发给多个PHP CLI Worker，Worker会把请求重新封装成PSR-7 Request交给框架进行处理。 娱乐测试 使用siege测试Laravel的Welcome页面，250个并发用户，持续30秒，对比Nginx + FPM和RoadRunner。 Nginx + FPM： $ siege --no-parser -c 250 -t 30s http://127.0.0.1:3000/ > /dev/null ** SIEGE 4.0.4 ** Preparing 250 concurrent ...阅读全文
package main import ( "os" "io" "fmt" "net" "strings" "strconv" "syscall" "encoding/binary" ) type CSPair struct { clientaddr net.Addr serveraddr net.Addr clientconn *net.TCPConn serverconn *net.TCPConn } const ( SO_ORIGINAL_DST = 80 ) var ( connection_count = 0 ) func main() { laddr := &net.TCPAddr{} laddr.Port = 8838 ln, err := net.ListenTCP("tcp...阅读全文
package main import ( "os" "io" "fmt" "net" "strings" "strconv" "syscall" "encoding/binary" ) type CSPair struct { clientaddr net.Addr serveraddr net.Addr clientconn *net.TCPConn serverconn *net.TCPConn } const ( SO_ORIGINAL_DST = 80 ) var ( connection_count = 0 ) func main() { laddr := &net.TCPAddr{} laddr.Port = 8838 ln, err := net.ListenTCP("tcp...阅读全文
package main import ( "fmt" "net/http" ) func main() { http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { _, _ = w.Write([]byte("fm transfer")) }) http.HandleFunc("/fm", handleFm) _ = http.ListenAndServe(":80", nil) } func sendRequest(url string) (<-chan []byte,chan bool) { dataChannel :=make(chan []byte, 10) exitSignal:=make(chan ...阅读全文
项目已经上传到GitHub了 这是项目地址:https://github.com/wenj91/nat-ddns 关于这个项目有什么好的想法,还有有什么疑问的地方可以反馈给我 ...阅读全文
golang中对信号的处理主要使用os/signal包中的两个方法：一个是notify方法用来监听收到的信号；一个是 stop方法用来取消监听。 Notify函数 原型： func Notify(c chan<- os.Signal, sig …os.Signal) 说明： 该函数会将进程收到的系统Signal转发给channel c，转发哪些信号由该函数的可变参数决定，如果你没有传入sig参数，那么Notify会将系统收到的所有信号转发给c。 使用： 1.监听全部信号 package main import ( "fmt" "os" "os/signal" ) func main() { //创建chan c := make(chan os.Signal, 1) //buffered ch...阅读全文
在本系列的第一篇文章中，研究了kubernetes如何结合使用虚拟网络设备和路由规则，以允许在一个群集节点上运行的Pod与在另一个群集节点上运行的Pod通信，只要发送者知道接收者的Pod网络即可。 IP地址。如果您还不熟悉Pod的交流方式，那么在继续之前值得一读。集群中的Pod网络很简单，但仅凭其不足以创建持久性系统。那是因为kubernetes中的Pod是短暂的。您可以将Pod IP地址用作终结点，但不能保证该地址在下次重新创建Pod时不会更改，这可能由于多种原因而发生。 您可能已经意识到这是一个老问题，并且它有一个标准的解决方案：通过反向代理/负载均衡器运行流量。客户端连接到代理，代理负责维护将请求转发到的健康服务器列表。这对代理服务器提出了一些要求：代理服务器本身必须是耐用的并且能够抗...阅读全文
