golang 分布式框架 (持续更新)

源码地址:

https://github.com/MwlLj/go-micro-service

go-micro-service
golang分布式框架

zookeeper 安装与启动
http://mirrors.hust.edu.cn/apache/zookeeper/

服务注册说明
import
* s "github.com/MwlLj/go-micro-service/service_discovery_nocache"
* proto "github.com/MwlLj/go-micro-service/common_proto"

example

func main() {var conns []proto.CConnectPropertyconns = append(conns, proto.CConnectProperty{ServerHost: "127.0.0.1", ServerPort: 2182, ServiceId: "server_1"})sds := s.New(&s.CInitProperty{PathPrefix:   "micro-service",ServerMode:   s.ServerModeZookeeper,ServerName:   "testserver",NodeData:     proto.CNodeData{ServerIp: "127.0.0.1", ServerPort: 50000, ServerUniqueCode: "cacd3aa4-4eb8-4bf6-b967-fbcee5377992", Weight: 1},Conns:        conns,ConnTimeoutS: 10})var _ = sdsfor {time.Sleep(100 * time.Millisecond)}}

description
* 服务端只需要调用 New 方法, 就可以将服务信息注册到 zookeeper 中, 内部自动实现重连机制
* 对于类似 http 的服务端, 可以不需要填写 ServerUniqueCode 字段
* ServerUniqueCode 字段是针对利用消息队列做成的服务端(这种服务没有ip和port监听, 是通过第三方的 broker 来做为中介者进行消息传递的), 所以这类的服务必须要填写 ServerUniqueCode 字段, 而 ServerIp / ServerPort 字段非必填
> 这类服务实现分布式机制的一种方式:
服务端存在一个 ServerUniqueCode, 客户端连接到服务端时, 服务端将自己的 ServerUniqueCode 发送给客户端, 客户端每次发送消息时, 将这个 uniqueCode 传递给集群中的服务, 每个服务接收到消息, 都判断一下传来的 uniqueCode 是否与自己的 ServerUniqueCode 相等, 只有相等的时候才会接收, 否则丢弃

负载均衡说明
import
* bl "github.com/MwlLj/go-micro-service/loab_blance"
* proto "github.com/MwlLj/go-micro-service/common_proto"

example

func main() {var conns []proto.CConnectPropertyconns = append(conns, proto.CConnectProperty{ServerHost: "127.0.0.1", ServerPort: 2182, ServiceId: "server_1"})bls, connChan := bl.New(bl.ServerModeZookeeper, &conns, "micro-service", 10)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmRoundRobin)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmWeightRoundRobin)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmRandom)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmWeightRandom)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmIpHash)// algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmUrlHash)algorithm := bls.GetNormalNodeAlgorithm(bl.AlgorithmLeastConnect)select {case <-connChan:break}data, err := bls.GetMasterNode("testserver")if err != nil {fmt.Println("[ERROR] get master node error, ", err)} else {fmt.Println("------------master------------")fmt.Println(data.ServerIp, data.ServerPort, data.ServerUniqueCode, data.Weight)fmt.Println("------------master------------")}fmt.Println("------------normal------------")for i := 0; i < 20; i++ {// data, err = algorithm.Get("testserver", "192.168.9.2")// data, err = algorithm.Get("testserver", "192.168.9.2")// data, err = algorithm.Get("testserver", "/data/user")data, err = algorithm.Get("testserver", "/data/video")if err != nil {fmt.Println("[ERROR] get normal node error, ", err)} else {fmt.Println(data.ServerIp, data.ServerPort, data.ServerUniqueCode, data.Weight)}}fmt.Println("------------normal------------")var _ = blsfor {time.Sleep(100 * time.Millisecond)}}

description
* ServerModeZookeeper 这种方式是通过接口直接调用的, 后续将支持 Http 版本的
* 通过 GetMasterNode 接口获取 master 节点
> master节点的作用:
如果需要同步操作数据库等不可以同时进行的事务时, 就不能让多个 server 同时执行, 这种任务, 同一时刻只能有一个服务运行
这个服务就是 master (master 节点的逻辑不需要使用者关心, 使用者只需要通过 GetMasterNode 接口获取此时的 master 节点对应的服务信息就可以)
* 负载均衡获取normal节点是通过 GetNormalNodeAlgorithm 来指定所需的算法
* 通过 GetNormalNodeAlgorithm 返回的对象, 调用 Get 方法就可以, 获取到一个 normal 节点信息

golang 分布式框架 (持续更新)相关推荐

iOS之github第三方框架(持续更新)
1.MBProgressHUD MBProgressHUD是一个开源项目,实现了很多种样式的提示框使用上简单.方便,并且可以对显示的内容进行自定义,功能很强大,很多项目中都有使用到. 到Github ...
golang 分布式框架Origin学习笔记
最近项目的后端需求是全球同服的,在使用语言方面确定了为golang之后,了解了一下当前的一些goalng游戏服务器框架,终于在leaf/pitaya/ 等众多框架中选择了 Origin, 主要是因为它 ...
Go-lang分布式框架选择上的历程记录【go-micro、go-zero、go-kratos】
三者在github上的star数差别不大. go-micro,原本的老大,但最近变动很大,作者去搞云原生去了,分布式框架的这个分支不确定后续还能分得创作者多少精力,担心后续万一go语言有啥大改动,框架 ...
Java进阶学习 - Dubbo框架(持续更新中~~)
Java进阶学习 - Dubbo框架 1.简介 Dobbo是一个高性能的RPC框架,解决了分布式钟的调用问题优点:解决了分布式系统中互相调用问题缺点:缺少统一管理的调度中心 2.为什么Dubbo说 ...
几款不错的golang应用包持续更新中~~~
队列 1.hibiken/asynq 保证至少执行一次任务任务调度重试失败的任务在工作进程崩溃时自动恢复任务加权优先级队列严格优先级队列由于Redis中的写入速度很快,因此添加任务的延迟很 ...
ThinkPhp5开发实战1：搭建环境配置TP5框架(持续更新收藏关注)
文章目录前言一.下载thinkphp5.0.10和安装本地环境二.下载H-UI后端模板三.静态文件引入四.创建后台页面首页前言 php框架有助于促进快速应用开发,不仅节省时间,有助于建立更 ...
golang 小知识-持续更新中
Golang 中的指针 - Pointer Go 的原生数据类型可以分为基本类型和高级类型,基本类型主要包含 string, bool, int 及 float 系列,高级类型包含 struct,ar ...
深度模型框架(持续更新)
文章目录 1.翻译 1.1.快照 1.2.详解 2.reading comprehension 快照详解展望在各个领域,在一项技术渐于成熟的时候,就会摒弃掉一些底层枯燥的东西,一步步抽象出更加高 ...
TKDragView_iOS开发常用第三方开源框架持续更新中...
网络请求 AFNetworking Alamofire AFNetworking swift版本 YTKNetwork AFNetworking的封装 YQNetworking 基于AFNetwork ...

golang 分布式框架 (持续更新)

golang 分布式框架 (持续更新)相关推荐

最新文章

热门文章