• linkedu视频
  • 平面设计
  • 电脑入门
  • 操作系统
  • 办公应用
  • 电脑硬件
  • 动画设计
  • 3D设计
  • 网页设计
  • CAD设计
  • 影音处理
  • 数据库
  • 程序设计
  • 认证考试
  • 信息管理
  • 信息安全
菜单
linkedu.com
  • 网页制作
  • 数据库
  • 程序设计
  • 操作系统
  • CMS教程
  • 游戏攻略
  • 脚本语言
  • 平面设计
  • 软件教程
  • 网络安全
  • 电脑知识
  • 服务器
  • 视频教程
  • vbs
  • DOS/BAT
  • hta/htc
  • python
  • perl
  • VBA
  • ColdFusion
  • ruby
  • PowerShell
  • Lua
  • Golang
  • linux shell
您的位置:首页 > 脚本语言 >Golang > 服务器端Go程序对长短链接的处理及运行参数的保存

服务器端Go程序对长短链接的处理及运行参数的保存

作者: 字体:[增加 减小] 来源:互联网

通过本文主要向大家介绍了c#服务器端程序,服务器端程序,冰河的服务器端程序为,flat服务器端程序,tcp服务器端程序等相关知识,希望对您有所帮助,也希望大家支持linkedu.com www.linkedu.com

对长、短连接的处理策略(模拟心跳)
作为一个可能会和很多Client进行通讯交互的Server,首先要保证的就是整个Server运行状态的稳定性,因此在和Client建立连接通讯的时候,确保连接的及时断开非常重要,否则一旦和多个客户端建立不关闭的长连接,对于服务器资源的占用是很可怕的。因此,我们需要针对可能出现的短连接和长连接,设定不同的限制策略。
    针对短连接,我们可以使用golang中的net包自带的timeout函数,一共有三个,分别是:
func (*IPConn) SetDeadline 
func (c *IPConn) SetDeadline(t time.Time) error 
 
func (*IPConn) SetReadDeadline 
func (c *IPConn) SetReadDeadline(t time.Time) error 
 
func (*IPConn) SetWriteDeadline 
func (c *IPConn) SetWriteDeadline(t time.Time) error 

</div>

    如果想要给服务器设置短连接的timeout,我们就可以这么写:

netListen, err := net.Listen("tcp", Port) 
    Log("Waiting for clients") 
    for { 
        conn, err := netListen.Accept() 
        if err != nil { 
            continue 
        } 
</div> 
        conn.SetReadDeadline(time.Now().Add(time.Duration(10) * time.Second)) 
    这里的三个函数都是用于设置每次socket连接能够维持的最长时间,一旦超过设置的timeout后,便会在Server端自动断开连接。其中SetReadline, SetWriteline设置的是读取和写入的最长持续时间,而SetDeadline则同时包含了 SetReadline, SetWriteline两个函数。
    通过这样设定,每个和Server通讯的Client连接时长最长也不会超过10s了~~

    搞定短连接后,接下来就是针对长连接的处理策略了~~
    作为长连接,由于我们往往很难确定什么时候会中断连接,因此并不能像处理短连接那样简单粗暴的设定一个timeout就可以搞定,而在Golang的net包中,并没有针对长连接的函数,因此需要我们自己设计并实现针对长连接的处理策略啦~
    针对socke长连接,常见的做法是在Server和Socket之间设计通讯机制,当两者之间没有信息交互时,双方便会定时发送数据包(心跳),以维持连接状态。

    这种方法是目前使用相对比较多的做法,但是开销相对也较大,特别是当Server和多个client保持长连接的时候,并发会比较高,考虑到公司的业务需求,我最后选择了逻辑相对简单,开销相对较小的策略:
    当Server每次收到Client发到的信息之后,便会开始心跳计时,如果在心跳计时结束之前没有再次收到Client发来的信息,那么便会断开跟Client的连接。而一旦在设定时间内再次收到Client发来的信息,那么Server便会重置计时器,再次重新进行心跳计时,直到超时断开连接为止。
下面就是实现该计时的代码:
//长连接入口 
func handleConnection(conn net.Conn,timeout int) { 
 
    buffer := make([]byte, 2048) 
    for { 
        n, err := conn.Read(buffer) 
 
        if err != nil { 
            LogErr(conn.RemoteAddr().String(), " connection error: ", err) 
            return 
        } 
        Data :=(buffer[:n]) 
        messnager := make(chan byte) 
        postda :=make(chan byte) 
        //心跳计时 
        go HeartBeating(conn,messnager,timeout) 
        //检测每次Client是否有数据传来 
        go GravelChannel(Data,messnager) 
        Log( "receive data length:",n) 
        Log(conn.RemoteAddr().String(), "receive data string:", string(Data 
 
    } 
} 
 
//心跳计时,根据GravelChannel判断Client是否在设定时间内发来信息 
func HeartBeating(conn net.Conn, readerChannel chan byte,timeout int) { 
        select { 
        case fk := <-readerChannel: 
            Log(conn.RemoteAddr().String(), "receive data string:", string(fk)) 
            conn.SetDeadline(time.Now().Add(time.Duration(timeout) * time.Second)) 
            //conn.SetReadDeadline(time.Now().Add(time.Duration(5) * time.Second)) 
            break 
        case <-time.After(time.Second*5): 
            Log("It's really weird to get Nothing!!!") 
            conn.Close() 
        } 
 
} 
 
func GravelChannel(n []byte,mess chan byte){ 
    for _ , v := range n{ 
        mess <- v 
    } 
    close(mess) 
} 
 
 
func Log(v ...interface{}) { 
    log.Println(v...) 
} 

    这样,就可以成功实现对于长连接的处理了~~,我们可以这么进行测试:

func sender(conn net.Conn) { 
    for i := 0; i <5; i++ { 
        words:= strconv.Itoa(i)+"This is a test for long conn"  
        conn.Write([]byte(words)) 
        time.Sleep(2*time.Second) 
 
    } 
    fmt.Println("send over") 
 
} 
</div>
    可以发现,Sender函数中time.Sleep阻塞的时间设定的比Server中的timeout短的时候,Client端的信息可以自由的发送到循环结束,而当我们设定Sender函数的阻塞时间较长时,就只能发出第一次循环的信息。


将运行参数放入配置文件(XML/YAML)
为了将我们写好的Server发布到服务器上,就要将我们的代码进行build打包,这样如果以后想要修改一些代码的话,需要重新给代码进行编译打包并上传到服务器上。

   显然,这么做过于繁琐。。。因此常见的做法都是将Server运行中可能会频繁变更的变量、数值写

您可能想查找下面的文章:

  • 服务器端Go程序对长短链接的处理及运行参数的保存

相关文章

  • golang操作mongodb的方法
  • Go语言使用sort包对任意类型元素的集合进行排序的方法
  • 利用Go语言追加内容到文件末尾
  • Go语言单链表实现方法
  • 在Visual Studio Code中配置GO开发环境的详细教程
  • GO语言标准错误处理机制error用法实例
  • Go语言并发技术详解
  • golang两种调用rpc的方法
  • Go语言对字符串进行SHA1哈希运算的方法
  • 在Mac OS上安装Go语言编译器的方法

文章分类

  • vbs
  • DOS/BAT
  • hta/htc
  • python
  • perl
  • VBA
  • ColdFusion
  • ruby
  • PowerShell
  • Lua
  • Golang
  • linux shell

最近更新的内容

    • Go语言编程中对文件读写的基本方法整理
    • Go语言多值替换的HTML模板实例分析
    • GO语言利用K近邻算法实现小说鉴黄
    • Go语言的代码组织结构详细介绍
    • Go语言中的内存布局详解
    • Go语言使用组合的方式实现多继承的方法
    • GO语言类型转换和类型断言实例分析
    • Go语言中普通函数与方法的区别分析
    • golang网络socket粘包问题的解决方法
    • Go语言对字符串进行SHA1哈希运算的方法

关于我们 - 联系我们 - 免责声明 - 网站地图

©2020-2025 All Rights Reserved. linkedu.com 版权所有