首页 / GO / Golang组件化网络服务器框架Halia指南

Golang组件化网络服务器框架Halia指南

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Golang组件化网络服务器框架Halia指南，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7309字，纯文字阅读大概需要11分钟。

内容图文

写在前面
在netty框架面世之前，几乎没有一个成熟的OOP/组件化规范指导网络服务器开发，一些常用的FrameDecoder,BusinessHandler等等组件紧密耦合在了项目当中，整个项目可以说扩展性比较差。

netty的出现可以说是划时代的，基于OOP/组件化屏蔽了底层 BlockingIO/NonBlockingIO/AsynchrousIO之间的差异，各种组件可以无缝切换，网络服务器开发效率有了非常大的提高。

通过阅读netty源码，以及核心组件的架构，基于Golang进行了实现，至此，Golang的Halia框架面世了！

Halia特性
组件化/可扩展
Halia框架面向接口编程，并提供默认实现，同时内置常用的解码器，真正做到开箱即用。

高性能
基于Golang原生网络库进行开发，无第三方依赖，性能有保障。

易用性
Halia框架采用极简设计，没有冗余代码，并附带3个常用解码器示例，助您基于Halia快速开始开发。

开源免费
Halia框架基于MIT开源协议发布，无论是商用以及非商用都可以免费试用。

社区驱动
Halia框架托管于Github，任何人都可以贡献一臂之力。

快速开始
接下来将演示如何开发一个时间回显服务器。

客户端每隔1秒发送时间字符串给服务器，服务器回显该数据。

公用代码
encoder.go
字符串编码器，将字符串转换为[]byte传输到下一个出站处理器

package main

import (
 "halia/channel"
)

type StringToByteEncoder struct{}
// 编码器不处理处理，交由下一个处理器(也就是业务处理器)处理
func (e *StringToByteEncoder) one rror(c channel.HandlerContext, err error) {
 c.FireOnError(err)
}

func (e *StringToByteEncoder) Write(c channel.HandlerContext, msg interface{}) error {
 if str, ok := msg.(string); ok { // string才转换
  return c.Write([]byte(str))
 }
 return c.Write(msg)
}

func (e *StringToByteEncoder) Flush(c channel.HandlerContext) error {
 return c.Flush()
}

客户端代码
handler.go
客户端业务处理代码。


package main

import (
 "fmt"
 log "github.com/sirupsen/logrus"
 "halia/channel"
 "strings"
 "time"
)

type EchoClientHandler struct {
 log *log.Entry
}

func NewEchoClientHandler() *EchoClientHandler {
 return &EchoClientHandler{
  log: log.WithField("component", "EchoClientHandler"),
 }
}
// 发送错误回调
func (p *EchoClientHandler) one rror(c channel.HandlerContext, err error) {
 p.log.WithField("peer", c.Channel().RemoteAddr()).Warnln("error caught", err)
}
// 连接已建立
func (p *EchoClientHandler) ChannelActive(c channel.HandlerContext) {
 p.log.WithField("peer", c.Channel().RemoteAddr()).Infoln("connected")

 if err := c.WriteAndFlush("Hello World\r\n"); err != nil {
  p.log.WithError(err).Warnln("write error")
 }
 p.log.Infof("pipeline in: %v", strings.Join(c.Pipeline().InboundNames(), "->"))
 p.log.Infof("pipeline out: %v", strings.Join(c.Pipeline().OutboundNames(), "->"))
}

// 连接已断开
func (p *EchoClientHandler) ChannelInActive(c channel.HandlerContext) {
 p.log.WithField("peer", c.Channel().RemoteAddr()).Infoln("disconnected")
}

// 读取到完整的消息回调
func (p *EchoClientHandler) ChannelRead(c channel.HandlerContext, msg interface{}) {
 data, ok := msg.([]byte)
 if !ok {
  p.log.WithField("peer", c.Channel().RemoteAddr()).Warnf("unknown msg type: %+v", msg)
  return
 }
 str := string(data)
 p.log.WithField("peer", c.Channel().RemoteAddr()).Infoln("receive ", str)
    // 1秒后发送数据给服务器
 time.AfterFunc(time.Second, func() {
  if err := c.WriteAndFlush(fmt.Sprintf("client say:%s\r\n", time.Now().String())); err != nil {
   p.log.WithError(err).Warnln("write error")
  }
 })
}

main.go

package main

import (
 log "github.com/sirupsen/logrus"
 "halia/bootstrap"
 "halia/channel"
 "halia/handler/codec"
 "net"
 "os"
)

func init() {
 log.SetOutput(os.Stdout)
 log.SetLevel(log.DebugLevel)
}

func main() {
 client := bootstrap.NewClient(&bootstrap.ClientOptions{
        // 将原始net.Conn包装为Channel实现，一般情况下用DefaultChannel即可
  ChannelFactory: func(conn net.Conn) channel.Channel {
   c := channel.NewDefaultChannel(conn)
            // 添加解码器，换行符分割报文解码器
   c.Pipeline().AddInbound("decoder", codec.NewLineBasedFrameDecoder())
            // 添加业务处理器
   c.Pipeline().AddInbound("handler", NewEchoClientHandler())
            // 添加编码器
   c.Pipeline().AddOutbound("encoder", &StringToByteEncoder{})
   return c
  },
 })
 // 连接服务器
 log.WithField("component", "client").Fatal(client.Dial("tcp", "127.0.0.1:8080"))
}

服务端代码
handler.go


package main

import (
 log "github.com/sirupsen/logrus"
 "halia/bootstrap"
 "halia/channel"
 "halia/handler/codec"
 "net"
 "os"
)

func init() {
 log.SetOutput(os.Stdout)
 log.SetLevel(log.DebugLevel)
}

func main() {
 s := bootstrap.NewServer(&bootstrap.ServerOptions{
  ChannelFactory: func(conn net.Conn) channel.Channel {
   c := channel.NewDefaultChannel(conn)
   c.Pipeline().AddInbound("decoder", codec.NewLineBasedFrameDecoder())
   c.Pipeline().AddInbound("handler", NewEchoServerHandler())
   c.Pipeline().AddOutbound("encoder", &StringToByteEncoder{})
   return c
  },
 })

 log.WithField("component", "server").Fatal(s.Listen("tcp", "0.0.0.0:8080"))
}

运行
先运行服务端，再运行客户端。

服务端输出


time="2021-01-12T11:30:13+08:00" level=info msg=started addr="0.0.0.0:8080" component=server network=tcp pid=7584
time="2021-01-12T11:30:13+08:00" level=info msg=initialized component=channelId machineId=a0c5895a25a3 pid=7584
time="2021-01-12T11:30:18+08:00" level=info msg=connected component=EchoServerHandler peer="127.0.0.1:57641"
time="2021-01-12T11:30:18+08:00" level=info msg="pipeline in: InHeadContext->decoder->handler" component=EchoServerHandler
time="2021-01-12T11:30:18+08:00" level=info msg="pipeline out: OutHeadContext->encoder->OutTailContext" component=EchoServerHandler
time="2021-01-12T11:30:18+08:00" level=info msg="receive  Hello World" component=EchoServerHandler peer="127.0.0.1:57641"
time="2021-01-12T11:30:19+08:00" level=info msg="receive  client say:2021-01-12 11:30:19.5192868 +0800 CST m=+1.046443501" component=EchoServerHandler peer="127.0.0.1:57641"
time="2021-01-12T11:30:20+08:00" level=info msg="receive  client say:2021-01-12 11:30:20.5193884 +0800 CST m=+2.046545101" component=EchoServerHandler peer="127.0.0.1:57641"
time="2021-01-12T11:30:21+08:00" level=info msg="receive  client say:2021-01-12 11:30:21.5345887 +0800 CST m=+3.061745401" component=EchoServerHandler peer="127.0.0.1:57641"
time="2021-01-12T11:30:22+08:00" level=info msg="receive  client say:2021-01-12 11:30:22.5459978 +0800 CST m=+4.073154501" component=EchoServerHandler peer="127.0.0.1:57641"

客户端输出


time="2021-01-12T11:30:18+08:00" level=info msg=connected component=EchoClientHandler peer="127.0.0.1:8080"
time="2021-01-12T11:30:18+08:00" level=info msg="pipeline in: InHeadContext->decoder->handler" component=EchoClientHandler
time="2021-01-12T11:30:18+08:00" level=info msg="pipeline out: OutHeadContext->encoder->OutTailContext" component=EchoClientHandler
time="2021-01-12T11:30:18+08:00" level=info msg="receive  server:Hello World" component=EchoClientHandler peer="127.0.0.1:8080"
time="2021-01-12T11:30:18+08:00" level=info msg=initialized component=channelId machineId=a0c5895a25a3 pid=960
time="2021-01-12T11:30:19+08:00" level=info msg="receive  server:client say:2021-01-12 11:30:19.5192868 +0800 CST m=+1.046443501" component=EchoClientHandler peer="127.0.0.1:8080"
time="2021-01-12T11:30:20+08:00" level=info msg="receive  server:client say:2021-01-12 11:30:20.5193884 +0800 CST m=+2.046545101" component=EchoClientHandler peer="127.0.0.1:8080"
time="2021-01-12T11:30:21+08:00" level=info msg="receive  server:client say:2021-01-12 11:30:21.5345887 +0800 CST m=+3.061745401" component=EchoClientHandler peer="127.0.0.1:8080"
time="2021-01-12T11:30:22+08:00" level=info msg="receive  server:client say:2021-01-12 11:30:22.5459978 +0800 CST m=+4.073154501" component=EchoClientHandler peer="127.0.0.1:8080"

写在后面
Halia期待您的贡献！

文档地址
仓库地址

内容总结

以上是互联网集市为您收集整理的Golang组件化网络服务器框架Halia指南全部内容，希望文章能够帮你解决Golang组件化网络服务器框架Halia指南所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1012469.html

来源：【匿名】

【上一篇】golang依赖注入工具wire指南【下一篇】php和golang的区别是什么？

更多 ►

【Golang组件化网络服务器框架Halia指南】教程文章相关的互联网学习教程文章

Golang 入门系列（十二）ORM框架gorm【代码】

之前在已经介绍了用的github.com/go-sql-driver/mysql 访问数据库，不太了解的可以看看之前的文章 https://www.cnblogs.com/zhangweizhong/category/1275863.html。实际上，为提高开发效率，一般都会使用一些orm框架，把数据库层屏蔽，用户看到的只有对象而无需我们手动做一些转换，这样在使用的时候就非常方便。这种操作方式基本上已经成了标准做法。golang也有很多优秀的orm框架，今天就来介绍介绍gorm。为什么要使用orm？为什么...

java、python、golang等开发语言如何快速生成二维码？【代码】

免费二维码生成途径非常多！比如比较有名的草料二维码，如果只是简单的使用，用它就足够了。但是如果想大规模的生成，那就不太合适了。再者很多工具都没办法在二维码中加入logo（像微信二维码一样）。接下来，我就说说如何快速的、高质量的生成一个可高度定制的二维码。二维码的编码算法是公开的，这就意味着大部分的开发语言都可以动图生成。但是在二维码应用如此广泛的今天，还自己去造轮子，如果不是傻，那就是正真的技术极客了...

Golang格式化字符串输出

格式化指令含义%%% 字面量%b一个二进制整数，将一个整数格式化为二进制的表达方式%c一个 Unicode 的字符%d十进制数值%o八进制数值%x小写的十六进制数值%X大写的十六进制数值%U一个 Unicode 表示法表示的整形码值，默认是 4 个数字字符%s输出以原生的 UTF-8 字节表示的字符，如果 console 不支持 UTF-8 编码，则会输出乱码%t以 true 或者 false 的方式输出布尔值%v使用默认格式输出值，或者使用类型的 String() 方法输出的自定义值，...

grpc-golang实现账号and密码认证【代码】

// I would recommend to use interceptors:// client grpc.Dial(target, grpc.WithPerRPCCredentials(&loginCreds{Username: "admin",Password: "admin123", }))type loginCreds struct {Username, Password string }func (c *loginCreds) GetRequestMetadata(context.Context, ...string) (map[string]string, error) {return map[string]string{"username": c.Username,"password": c.Password,}, nil }func (c *loginCreds) Re...

Golang（笔记）顺序编程【代码】【图】

package mainimport ("fmt""bufio""io""os""strconv""flag" ) var infile *string=flag.String("i","unsorted.data","File contains values for sorting") var outfile *string=flag.String("o","sorted.data","File to receive sorted values ") var algorithm *string=flag.String("a","qsort","Sort algorithm") func readValues(infile string)(values []int,err error){file,err:=os.Open(infile)if(err!=nil){fmt.Println("F...

paho.mqtt.golang--option.go 源码解析【代码】

broker: 指 mqtt 服务器package mqttimport ("crypto/tls""net/http""net/url""regexp""strings""time" )// 允许在重新连接之前更新用户名和密码。函数应该返回当前的用户名和密码。 type CredentialsProvider func() (username string, password string)// MessageHandler 是一种回调类型， // 可以设置为在发布到订阅了客户端的主题的消息到达时执行。 type MessageHandler func(Client, Message)// ConnectionLostHandler是一种...

在床上手机看完电影让电脑关机休眠 golang源码【代码】

package main import ("io""net/http""log""os/exec""fmt""time" )/* https://www.cnblogs.com/TianFang/p/7912648.html 封装服务看这里http://ip/s 手机上浏览器访问这个url 电脑进入休眠开发者wechat：ipub520 */func HelloServer(w http.ResponseWriter, req *http.Request) {io.WriteString(w, "30秒后电脑进入休眠！\n")time.Sleep(30*time.Second)c := exec.Command("cmd", "/C", "rundll32.exe powrprof.dll,SetSuspendSt...

Golang-基础之基本数据类型【代码】

PS 参考博文，致谢：https://www.liwenzhou.com/posts/Go/02_datatype/Go 语言中有丰富的数据类型，除了基本的整型、浮点型、布尔型、字符串外、还有数组、切片、结构体、函数、map、通道（channel）等，Go语言的基本数据类型和其他语言的大同小异；一、基本数据类型1.1、整型整型分为以下两大类：按长度分为：int8、int16、int32、int64对应的无符号整型：uint8、uint16、uint32、uint64其中uint8 就是byte类型，int16 对应C...

转：windows 下的 eclipse安装goclipse 配置golang开发环境

windows 下的 eclipse安装goclipse 配置golang开发环境windows 下的 eclipse安装goclipse 配置golang开发环境,捎带介绍了LiteIDE golang的配置1. 下载goclipse eclipse pluginshttp://pan.baidu.com/s/1c0weLgO 安装完插件后，重启可以看到eclipse的右上角有个golang logo , 地鼠图标:2. 下载golang，调试tools 下载Golang Windows 版本当前使用 go1.3.3.windows-386.zip ： https://storage.googleapis.com/golang/go1.3.3.window...

golang切片【代码】

目录golang切片内存拷贝耗费时间copy()函数golang切片内存拷贝耗费时间package mainimport ("fmt""time" )func kb() {data := make([]byte, 0)l := 1024for i := 0 ; i < l;i++ {data = append(data, uint8(1))}data2 := make([]byte, l, l)t := time.Now()copy(data2, data)fmt.Println("KB数据耗费时间为: ", time.Since(t).String()) }func mb() {data := make([]byte, 0)l := 1024 * 1024for i := 0 ; i < l;i++ {data = app...

【GoLang】GoLang GOPATH 工程管理最佳实践

参考资料：MAC下 Intellij IDEA GO语言插件安装及简单案例：http://blog.csdn.net/fenglailea/article/details/53054502关于win下intellij idea 与gopath的问题：http://www.golangtc.com/t/55053967421aa9386f0000b1[翻译]十条有用的 GO 技术：http://mikespook.com/2014/07/%E5%8D%81%E6%9D%A1%E6%9C%89%E7%94%A8%E7%9A%84-go-%E6%8A%80%E6%9C%AF/理解Golang包导入：http://www.cnblogs.com/sevenyuan/p/4548748.html关于GOROOT、...

Golang 入门 : 打造开发环境【代码】【图】

工欲善其事，必先利其器！在学习和使用 Golang 时如果有一款得心应手的 IDE，相信一定可以事半功倍。虽然很多 IDE 都提供了对 Golang 的支持，但真正好用的没几个。VSCode 算是不错的一个，但比起收费的 GoLand 还有些差距。本文结合 Golang 和 GoLand 的安装介绍如何构建一个基本的 go 语言开发环境。文中演示用户环境为 Ubuntu 18.04 desktop。安装 Golang从 Golang 的官网下载 Linux 版本的安装包，笔者下载到的最新的稳定版为 ...

Mac下golang开发环境配置【代码】

go语言在开发效率和运行效率中的优势让很多人青睐，所以有倾向打算转向go语言的开发。下面介绍在Mac OS X中golang的开发环境配置。1.安装brewbrew是一个mac下的由ruby开发的包管理系统，其官网是http://brew.sh。你只要在你的终端中执行ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)”便可将其安装完成。安装完之后输入命令brew update即可获得更新并切换到速度最快的源上2.安装gobr...

golang-指针，函数，map【代码】

指针普通类型变量存的就是值，也叫值类型。指针类型存的是地址，即指针的值是一个变量的地址。一个指针只是值所保存的位置，不是所有的值都有地址，但是所有的变量都有。使用指针可以在无需知道变量名字的情况下，间接读取或更新变量的值。获取变量的地址，用&,例如:var a int 获取a的地址:&a，&a(a的地址)这个表达式获取一个指向整型变量的指针，它的类型是整形指针(*int),如果值叫做p,我们说p指向x,或者p包含x的地址，p指向的变量...

golang gbk转utf8【代码】

package ms2mysql import ( "bytes""golang.org/x/text/encoding/simplifiedchinese""golang.org/x/text/transform""io/ioutil" ) func Decode(s []byte) ([]byte, error) { I := bytes.NewReader(s)O := transform.NewReader(I, simplifiedchinese.GBK.NewDecoder())d, e := ioutil.ReadAll(O)if e != nil {return nil, e}return d, nil }win7 64位下试了好几个其他方式，结果都不行，也就这个可以，记录下来原文：http://www.c...

GO - 最热教程

Go语言（Golang）密码加密存储（数据库...Android的APP怎样制作LOGO的尺寸 SQLSERVER中GO的作用详解 goland: 从0到1创建一个hello word工程 go语言学习日记 - go语言环境配置 Golang http.Client设置超时 golang实现mysql数据库备份的操作方法 golang之map的声明交互式编程之Golang基本配置（Jupyter-...Go 字符串——遍历及切片

首页 / GO / Golang组件化网络服务器框架Halia指南

Golang组件化网络服务器框架Halia指南

内容导读

内容图文

内容总结

内容备注

内容手机端

【Golang组件化网络服务器框架Halia指南】教程文章相关的互联网学习教程文章

GO - 最新教程

GO - 最热教程