一、 golang中开发http服务，可以用net/http包提供的功能。net/http包提供了非常全的功能，并且启动的http服务也非常稳定和高效，完全可以用在生产环境中。 package main import ( "fmt" "log" "net/http" ) // w表示response对象，返回给客户端的内容都在对象里处理 // r表示客户端请求对象，包含了请求头，请求参数等等 func index(w http.ResponseWriter, r *http.Request) { // 往w里写入内容，就会在浏览器里输出 fmt.Fprintf(w, "Hello golang http!") } func main() { // 设置路由，如果访问/，则调用index方法 ...阅读全文
基础代码说明 time类：系统的时间类 time.second/minute/hour time.Duration能够对时间进行转换，默认开始是1ns，换算单位是1ms = 1000µs = 1000,000ns，往上到时间的那一层也能正常转换 time类能够自动转换时间，通用的是nuix的时间格式，不需要手动处理时间格式 strings类提供的split方法能够拆分字符串为字符串数组 golang的post的请求和接收，并对数据进行处理 post的发送 func HttpServerSender(data data.SenderData) { jsonss,err :=json.Marshal(data) if err != nil { fmt.Println(err.Error() ) ...阅读全文
大数据技术的学习，逐渐成为很多程序员的必修课，因为趋势也是因为自己的职业生涯。在各个技术社区分享交流成为很多人学习的方式，今天很荣幸找到好程序员大数据培训给我们分享一些大数据基础知识，大家可以一起学习!1.集群机器监控 这通常用于那种对集群中机器状态，机器在线率有较高要求的场景，能够快速对集群中机器变化作出响应。这样的场景中，往往有一个监控系统，实时检测集群机器是否存活。过去的做法通常是：监控系统通过某种手段(比如ping)定时检测每个机器，或者每个机器自己定时向监控系统汇报“我还活着”。 这种做法可行，但是存在两个比较明显的问题： 集群中机器有变动的时候，牵连修改的东西比较多。 有一定的延时。 利用ZooKeeper有两个特性，就可以实时另一种集群机器存活性监控系统： 客户端在节点 x 上...阅读全文
go中elasticsearch sdk 常用基础操作1、创建客户端func getCli() *es.Client{cli :=es.SetURL("http://127.0.0.1:9200")client, err :=es.NewClient(es.SetSniff(enabled), cli)if err !=nil {panic(err)}}2、定义数据结构type ParamModel struct {Id int64 `json:"id"`Content string `son:"content"`.....}3、数据解析器func ParserFlOrder(res *es.SearchResult) (out interface{}) {temp :=ParamModel...阅读全文
服务的注册与发现是微服务必不可少的功能，这样系统才能有更高的性能，更高的可用性。go-micro框架的服务发现有自己能用的接口Registry。只要实现这个接口就可以定制自己的服务注册和发现。 go-micro在客户端做的负载，典型的Balancing-aware Client模式。 服务端把服务的地址信息保存到Registry, 然后定时的心跳检查，或者定时的重新注册服务。客户端监听Registry，最好是把服务信息保存到本地，监听服务的变动，更新缓存。当调用服务端的接口是时，根据客户端的服务列表和负载算法选择服务端进行通信。 go-micro的能用Registry接口 type Registry interface { Register(*Service, ...RegisterOpti...阅读全文
golang中开发http服务，可以用net/http包提供的功能。net/http包提供了非常全的功能，并且启动的http服务也非常稳定和高效，完全可以用在生产环境中。 package main import ( "fmt" "log" "net/http" ) // w表示response对象，返回给客户端的内容都在对象里处理 // r表示客户端请求对象，包含了请求头，请求参数等等 func index(w http.ResponseWriter, r *http.Request) { // 往w里写入内容，就会在浏览器里输出 fmt.Fprintf(w, "Hello golang http!") } func main() { // 设置路由，如果访问/，则调用index方法 htt...阅读全文
与TCP相比，UDP的服务器和客户端之间不用建立持久的连接，数据传输更加高效，但稳定性和安全性较差 一、服务器 package main import ( "fmt" "net" "time" ) func main() { //建立udp服务器结构体 udpServer, err := net.ResolveUDPAddr("udp", "127.0.0.1:8001") if err != nil { fmt.Println("net.ResolveUDPAddr err", err) return } //创建udp监听服务 conn, err := net.ListenUDP("udp", udpServer) defer conn.Close() if err != nil { f...阅读全文
server1:package main import ( "fmt" "net" ) func main() { l, err := net.Listen("tcp", "127.0.0.1:9876") if err != nil { fmt.Println(err) } fmt.Println("服务器等待客户端连接") conn, err := l.Accept() if err != nil { fmt.Println(err) } defer conn.Close() fmt.Println("客户端建立连接 ") buf := make([]byte, 4096) n, err := conn.Read(buf) if err != nil { fmt.Println(err)...阅读全文
确保所有客户端请求均得到正确处理 让我们从Pod的客户端的剖析（客户端消费Pod提供的服务）的角度来看Pod的生命周期。我们希望确保妥善处理客户端的请求，因为如果在pod启动或关闭时连接开始中断，则很麻烦。 Kubernetes本身并不能保证不会发生这种情况，所以让我们看看我们需要采取什么措施来防止这种情况发生。 在Pod启动时防止客户端连接断开 如果您了解service和service endpoints的工作方式，那么确保在pod启动时正确处理每个连接非常简单。Pod启动后，会将其作为端点添加到对应的服务（Kubernetes 采用了基于标签的服务发现方式，它们的标签选择器与Pod的标签匹配）。Pod还需要向Kubernetes发出信号，表明已经准备好（通过readiness probe...阅读全文
