golang
已收录文章:12371篇
-
NATSStreaming通过消息持久化和可靠传递保障Golang应用消息不丢失,核心步骤包括:1.用Docker部署NATSStreaming服务器;2.安装stan.go客户端库;3.使用stan.Connect()建立连接并指定唯一客户端ID;4.通过Publish()发布消息,支持同步与异步模式;5.使用Subscribe()实现广播、QueueSubscribe()实现负载均衡消费;6.通过持久化ID实现断线重连后消息续传。尽管NATSStreaming仍用于部分存量系统,新项目建议优先评估Je101 收藏
-
Linkerd数据平面由Rust编写的Linkerd-proxy实现,通过边车代理透明处理服务间通信,支持mTLS、流量控制与可观测性;尽管代理本身非Go编写,但Golang广泛用于构建与其集成的扩展组件,如自定义指标导出器、策略控制器、可观测性网关及诊断工具;在Go服务中应避免自行处理TLS,合理配置超时,暴露Prometheus指标,并优先使用gRPC以充分利用Linkerd的协议感知能力。101 收藏
-
错误 认识错误 在Go中,错误是一种表示程序错误状态。包含了在程序在运行时、编译时的状态信息。一般我们在编写Go代码中,都会碰到如下的处理方式。 file, err := os.Create("test.txt") fmt.Println(fil100 收藏
-
a.txt文件内容: ABCDEFGHI HELLO GOLANG package main import ( "fmt" "os" "io" ) func main() { fileName := "C:\\Robert\\日志分析\\tools_go\\vdn_sqlInterface\\a.txt" file, err := os.OpenFile(fileName, os.O_RDWR, 0666) if err != nil {100 收藏
-
golang.org/x/time/rate 提对速度进行限制的算法 l := rate.NewLimiter(1, 3) // 一个参数为每秒发生多少次事件,第二个参数是最大可运行多少个事件(burst) Limter提供三中主要的函数 Allow, Reserve, Wait. 大部分100 收藏
-
问题内容 func second\_115() { i := 0 f := func() int { i++ return i } ch := make(chan int, 1) // ch <- f() select { case ch <- f(): fmt.Println("hello") default: fmt.Println(i)100 收藏