锐客网

  1. 首页 > 睿知 > it技术 > >

go语言写即时通的简单介绍( 五 )

IT技术语言


3.1 拓扑结构
topology
实验采用3台NSQD服务，2台LOOKUPD服务 。
采用官方推荐的拓扑 ， 消息发布的服务和NSQD在一台主机 。一共5台机器 。
NSQ基本没有配置文件，配置通过命令行指定参数 。
主要命令如下:
LOOKUPD命令
NSQD命令
工具类，消费后存储到本地文件 。
发布一条消息
3.2 nsqadmin
对Streams的详细信息进行查看，包括NSQD节点 ， 具体的channel，队列中的消息数，连接数等信息 。
nsqadmin
channel
列出所有的NSQD节点:
nodes
消息的统计:
msgs
lookup主机的列表:
hosts
4. 总结
NSQ基本核心就是简单性，是一个简单的队列，这意味着它很容易进行故障推理和很容易发现bug 。消费者可以自行处理故障事件而不会影响系统剩下的其余部分 。
事实上 ， 简单性是我们决定使用NSQ的首要因素，这方便与我们的许多其他软件一起维护，通过引入队列使我们得到了堪称完美的表现，通过队列甚至让我们增加了几个数量级的吞吐量 。越来越多的consumer需要一套严格可靠性和顺序性保障，这已经超过了NSQ提供的简单功能 。
结合我们的业务系统来看，对于我们所需要传输的发票消息，相对比较敏感，无法容忍某个nsqd宕机，或者磁盘无法使用的情况，该节点堆积的消息无法找回 。这是我们没有选择该消息中间件的主要原因 。简单性和可靠性似乎并不能完全满足 。相比Kafka ， ops肩负起更多负责的运营 。另一方面，它拥有一个可复制的、有序的日志可以提供给我们更好的服务 。但对于其他适合NSQ的consumer ， 它为我们服务的相当好，我们期待着继续巩固它的坚实的基础 。
gRPC服务开发和接口测试初探「Go」之前写过了Grpc服务开发和接口测试初探【Java】，中间耽搁了一些时间，Go版本的gRPC测试开发实践才有时间学习使用 。其中也是由于自己Go语言不够熟悉导致的 。之前有段时间想暂时放弃Go语言的学习，导致了Go的生疏，原因是从Groovy到Java性能 。
回归正题，Go语言版本的gRPC实践相对Java来说是比较简单的，但是总体的工具链是比较复杂的，可能是因为Go生态目前相比Java还是比较匮乏吧 。下面我先简述一下大致的步骤：
以上步骤亲自操作可能会遇到一些小问题，我本人搜到的教程什么的也是乱七八糟，踩了一些坑 。我没有整理出一个亲自实践之后的可行的教程，原因有二：
Go语言的gRPC的proto 编写跟Java大致一致，只有一个报名的参数不太一样 。下面是我的 Hello.proto 内容：
这里主要go_package 网上搜到的配置方式有些不一样，我没有全都尝试，大家在搜索的资料时候，尽量先看看 syntax 这个参数的值，以及文章教程写作的时间，如果距离现在太久了，我建议直接关掉 。搜索引擎有过滤功能，可以过滤掉过时的教程 。
这里Go语言gRPC的一点优势，就是在一个项目中即可实现 ， Java需要先弄一个SDK这样 。Go语言的gRPC的代码可以通过生成代码命令中的参数实现指定路径 。我是放在了和proto 文件的同级目录 。
【go语言写即时通的简单介绍】服务端代码也是比较格式化的内容，如下：
其中pb.RegisterHelloServiceServer(s, Ser{}) 如果报错，请检查自己安装的工具 protoc-gen-go 或者 protoc-gen-gofast 版本 ， 一般提取报错 message 搜索也能得到解决办法 。
下面是客户端的代码，由于学艺不精，其中大部分参数的含义目前我也不是很清楚，特别是基于stream 的请求响应的方式使用 。后面我先把Java的学完，再回过头来看Go的，按照这个顺序学习和分享 。

推荐阅读


上一篇：thinkphp3.2w3c路由，thinkphp 路由配置

下一篇：火星模拟经营游戏，火星模拟器游戏