机器一般过质保之后，就会因为各种各样的问题而宕机。而这一次的宕机，让笔者观察到了平常观察不到的tcp在对端宕机情况下的行为。经过详细跟踪分析原因之后，发现可以通过调整内核tcp参数来减少宕机造成的影响。
某日收到工单，用户反馈在6.8.2版本的kibana中，对在Discovery中查询到的数据想导出到CSV文件，点击"生成CSV"按钮无响应，如下图所示：
上一篇文章我们讲到go client的大概实现的大概思路，整理了相关client.go的核心源码，详情请翻阅：Golang源码深入-Go1.15.6发起http请求流程-1。笔者这一篇分享一下transport.go相关核心的代码，整理相关核心的技术点，希望读者多交流学习。
https://github.com/tidwall/redcon 是一个 Go实现 的 Redis 兼容服务器框架。它实现了redis协议，封装了网络连接，我们可以基于这个库快速实现一个基于redis协议的服务器。简单的redis服务器https://github.com/redis-go/redis 就是基于这个包实现的。
一、问题现象：通过监控发现访问MySQL偶尔出现异常，查看日志错误为unexpected EOF。
这部分我们将使用 TCP 协议和之前讲到的协程范式编写一个简单的客户端-服务器应用，一个（web）服务器应用需要响应众多客户端的并发请求：Go 会为每一个客户端产生一个协程用来处理请求。我们需要使用 net 包中网络通信的功能。它包含了处理 TCP/IP 以及 UDP 协议、域名解析等方法。
对tcp连接部分以及与连接绑定的业务部分进行抽象和封装 主要是对连接的开启关闭和读写进行封装，抽象出接口，使用回调进行具体业务的绑定 zinterface/iconnection.go package zinterface import "net" type IConnection interface{ Start() Stop() GetConnId() uint32 IsClosed() bool Send(data []byte,len int) error
关于http请求的报错：connect reset by peer，我相信大家应该都有所见过。今天我来剖析一下这个报错情况以及整理一下相关技术知识。
WEB服务器是解析HTTP协议并根据HTTP请求的信息提供服务的应用程序，所以要编写一个WEB服务器首先需要了解HTTP协议。HTTP协议是 Hyper Text Transfer Protocol（超文本传输协议） 的缩写，是一个基于TCP/IP协议来传递数据的应用层协议，下面简单介绍一下HTTP协议的文法。
-Run方法接收请求，然后通过c.dispatch(c.ctx, data)进行分发
接下来让我们来编写一个简单的 echo 程序，服务端直接返回收到的客户端信息，不做任何处理。首先是服务端：
关于golang http transport的讲解，网上有很多文章进行了解读，但都比较粗，很多代码实现并没有讲清楚。故给出更加详细的实现说明。整体看下来细节实现层面还是比较难懂的。
博主在使用WordPress博客中出现了提交评论前台超时发送失败，但后台还能正常接收评论的问题，尝试了多种方法都不能解决。最后，博主发现这是邮件发送失败导致的，安装一个WP SMTP Mail插件并配置SMTP服务即可解决该问题。
初始化连接池的核心代码如下 client.pool = &redis.Pool{ MaxIdle: client.MaxIdle, IdleTimeout: time.Duration(client.IdleTimeoutS) * time.Second, MaxActive: client.MaxActive, Dial: func() (redis.Conn, error) { var c redis.Conn var err e
netpoll是字节不久前开源的一款golang编写的高性能网络框架(基于Multi-Reactor模型)，旨在用于处理rpc场景，详细的介绍可参见下图介绍。
1、数据更新频率低，则大多数请求是无效的 2、在线用户量多，则服务端的查询负载高 3、定时轮询拉取，实时性低
如果在这个目录没有这个包就去github下载net库，放进这个目录$GOPATH/src/golang.org/x/net就行了
在Server端我们通过Conn的SetReadDeadline方法设置了10微秒的读超时时间，Server的执行结果如下： $go run server4.go 2015/11/17 14:21:17 accept a new connection 2015/11/17 14:21:27 start to read from conn 2015/11/17 14:21:27 conn read 0 bytes, error: read tcp 127.0.0.1:8888->127.0.0.1:609
Go 内置的 net/http 包提供了最简洁的 HTTP 客户端实现，我们无需借助第三方网络通信库（比如 libcurl）就可以直接使用 HTTP 中用得最多的 GET 和 POST 方式请求数据。
今天我们来讨论微服务架构中的自我恢复能力。通常情况下，服务间会通过同步或异步的方式进行通信。我们假定把一个庞大的系统分解成一个个的小块能将各个服务解耦。管理服务内部的通信可能有点困难了。你可能听说过这两个著名的概念：熔断和重试。
每次更新完代码，更新完配置文件后 就直接这么 ctrl+c 真的没问题吗，ctrl+c到底做了些什么事情呢？
上次Redis MQ分布式改造之后，编排的容器稳定运行一个多月，昨天突然收到ETL端同事通知，没有采集到解析日志。
总体来说，我认为上一篇才是 Go 并发的基础与核心。context 是在前章基础之上，为 goroutine 控制而开发的一套便于使用的库。毕竟，在不同的 goroutine 之间只传递 done channel，包含信息量确实是太少。
我们平时在开发中肯定避不开的一个问题是如何在不可靠的网络服务中实现可靠的网络通信，其中 http 请求重试是经常用的技术。但是 Go 标准库 net/http 实际上是没有重试这个功能的，所以本篇文章主要讲解如何在 Go 中实现请求重试。
IO 有阻塞和非阻塞两种模式，在阻塞IO下，我们需要耗费一个线程去阻塞在read操作下，去等待有足够多的数据可读并返回。在非阻塞IO下，不停对所有fd集合进行轮询，筛选出所有可读fd进行处理。
最近项目中遇到了请求被pending的状态 本来以为超时候多发几次请求就ok了 后来发现...
什么是三次握手呢？这是服务器和客户端之间沟通的过程。 首先，客户端对服务器发送了条信息。 然后，服务端对客户端说，我收到了。 最后，客户端对服务端说，好的，我知道你收到了。 怎么样？这就是三次握手。哈哈！ 服务端，我们先声明本地要监听的地址和端口。 netListent, err := net.Listen("tcp", "localhost:7373") 有开始就有结束，当主函数运行结束时，需要释放资源。 defer netListent.Close() 在服务端做标记，表明现在开始等待客户端访问了。
公司内部的一个 golang 中间件报 UDP 连接异常的日志，问题很明显，对端的服务挂了，自然重启下就可以了。
在浏览器输入“http://127.0.0.1:8000”得到输出“Hi,Stranger,welcome”；输入“http://127.0.0.1:8000/test”得到输出“Hi,Tester”
作者：汪娇娇 时间：2017年8月2日 先看一个有道释义： 其实释义的挺形象的，下面我来一一解释哈： 1、聊天室：webSocket有名的应用就是聊天室了； 2、服务：webSocket提供客户端请求
一种更优的异步编程统一 方法，如果直接使用传统的回调函数去完成复杂操作就会形成回调深渊
socket.io与cluster 在线上系统中，需要使用node的多进程模型，我们可以自己实现简易的基于cluster模式的socket分发模型，也可以使用比较稳定的pm2这样进程管理工具。在常规的http服务中，这套模式一切正常，可是一旦server中集成了socket.io服务就会导致ws通道建立失败，即使通过backup的polling方式仍会出现时断时连的现象，因此我们需要解决这种问题，让socket.io充分利用多核。 在这里之所以提到socket.io而未说websocket服务，是因为so
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
我们在上一篇文章中简单地讨论了网络编程和 socket，并由此提及了 Go 语言标准库中的syscall代码包和net代码包。
https://www.npmjs.com/package/network-speed-test
网上都说jedis实例是非线程安全的，常常通过JedisPool连接池去管理实例，在多线程情况下让每个线程有自己独立的jedis实例，但都没有具体说明为啥jedis实例时非线程安全的，下面详细看一下非线程安全主要从哪个角度来看。
package main import ( "net" "fmt" ) var ( maxRead = 1100 msgStop = []byte("cmdStop") msgStart = []byte("cmdContinue") ) func main() { hostAndPort := "localhost:54321" listener := initServer(hostAndPort) for { conn, err
跨域简介 当两个域具有相同的协议(如http), 相同的端口(如80)，相同的host，那么我们就可以认为它们是相同的域（协议，域名，端口都必须相同）。 跨域就指着协议，域名，端口不一致，出于安全考虑，跨域的资源之间是无法交互的(例如一般情况跨域的JavaScript无法交互，当然有很多解决跨域的方案) 解决跨域几种方案 /* CORS 普通跨域请求：只服务端设置Access-Control-Allow-Origin即可， 前端无须设置，若要带cookie请求：前后端都需要设置。
https://github.com/go-sql-driver 实现了基本的sql操作
如果想多个协程处理，handleMessages()调用多次即可，是不会导致处理信息重复的。
package main import ( "fmt" "golang.org/x/net/websocket" //go get golang.org/x/net/websocket 下载websocket包 "html/template" //支持模板html "log" "net/http" ) func Echo(ws *websocket.Conn) { var err error for { var reply string //websocket接受信息 if err = websocket.Message.Receive(ws, &reply); err != nil { fmt.Println("can't receive") break } fmt.Println("reveived back from client: " + reply) msg := "received:" + reply fmt.Println("send to client:" + msg) //这里是发送消息 if err = websocket.Message.Send(ws, msg); err != nil { fmt.Println("can't send") break } } } func web(w http.ResponseWriter, r *http.Request) { //打印请求的方法 fmt.Println("method", r.Method) if r.Method == "GET" { //如果请求方法为get显示login.html,并相应给前端 t, _ := template.ParseFiles("websocket.html") t.Execute(w, nil) } else { //否则走打印输出post接受的参数username和password fmt.Println(r.PostFormValue("username")) fmt.Println(r.PostFormValue("password")) } } func main() { //接受websocket的路由地址 http.Handle("/websocket", websocket.Handler(Echo)) //打开html页面 http.HandleFunc("/web", web) if err := http.ListenAndServe(":1234", nil); err != nil { log.Fatal("ListenAndServe:", err) } } -------------------------------------------------- <!DOCTYPE html> <html> <head> <meta charset="utf-8"/> <title>go测试socket</title> </head> <body> <script type="text/javascript"> var sock = null; var wsuri = "ws://127.0.0.1:1234/websocket"; window.onload = function() { console.log("onload"); sock = new WebSocket(wsuri); sock.onopen = function() { console.log("connected to " + wsuri); } sock.onclose = function(e) { console.log("connection closed (" + e.code + ")");
Axios 是一个开源的基于 promise 的 HTTP 请求库，一般常用于浏览器和 node.js 中。它能够在具有相同代码库的浏览器和 nodejs 中同时运行，在服务器侧，它利用服务器端原生的 node.js http 模块，而在客户端侧（一般是浏览器），则使用的是 XMLHttpRequest。
在自动化运维系统中，常常需要监控日志，这些日志是不断更新的。本文提供了一种实时日志监控的 Python 实现。主要实现以下功能：
11-01 12:00 中午午饭期间，手机突然收到业务网关非200异常报警，平时也会有一些少量499或者网络抖动问题触发报警，但是很快就会恢复（目前配置的报警阈值是5%，阈值跟当时的采样窗口qps有直接关系）。
服务器模块，是对当前所实现的所有模块的⼀个整合，并进⾏服务器搭建的⼀个模块，最终封装实现出⼀个gobang_server的服务器模块类，向外提供搭建五⼦棋对战服务器的接⼝。通过实例化的对象可以简便的完成服务器的搭建。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
