使用http维持socket长连接

项目中有遇到问题如下:

1、旧版的cs服务,因为每个用户和唯一的长连接是在登录后绑定的,并且所有的消息报文均是基于该长连接去发送接收的,所以要求node服务要维持一个长连接,然后根据该用户获取长连接,拿到连接再去发送对应请求,tcp协议顶层是可以使用http传输的,nodejs中http模块内置的agent对象,便可以设置keepalive的方式维持这种长连接,具体方式如下:

module.exports.httpPost = ({ options, ctx }) => {
  return new Promise((resolve, reject) => {
    if (!ctx.users[ctx.query.uid + '']) ctx.users['' + ctx.query.uid] = {}
    let agent = ctx.users['' + ctx.query.uid].agent
    if (!agent) {
      const newAgent = new http.Agent({ keepAlive: true, maxSockets: 1 })
      newAgent.uid = ctx.query.uid      // 人为给agent对象关联uid
      newAgent.createConnection({
        port: config.BC_PORT,
        host: config.BC_SERVER
      }, () => {
        if (!_.isEmpty(newAgent.sockets)) {
          _.forIn(newAgent.sockets, (item, key) => {
            if (item.length) {
              item[0].on('close', () => {
                // 清除当前用户的agent
                ctx.users['' + newAgent.uid].agent = null   // 清除当前用户的agent
                newAgent.destroy()      // 回收agent
              }).on('data', data => {
              })
            }
          })
        }
      })
      agent = newAgent
    }
    const buf = new Buffer(ctx.request.body)
    const httpOptions = {
      headers: {
        'Content-Type': 'text/xml;charset=utf-8',
        'Content-length': buf.length
      },
      host: config.BC_SERVER, port: config.BC_PORT, method: 'POST', agent: agent
    }
    _.merge(httpOptions, options)
    const req = http.request(httpOptions, res => {
      let buffers = ''
      res.on('data', data => {
        buffers += data
      })
      res.on('end', () => {
        // 更新全局用户关联的长连接代理类agent,保证用户和链接一一对应
        ctx.users['' + ctx.query.uid].agent = agent
        resolve(buffers.toString())
      })
    })
    req.write(buf)
    req.end()
    req.on('error', err => {
      reject(err)
    })
  })
}

2、早期的服务是基于xml rpc的,但是浏览器的bs应用直接使用json格式最好不过,所以在请求前后可以进行xml转json的转换,在代码层面只需要加一个中间价即可。

3、早期的cs项目的服务有提供报警模块,采用UDP协议进行点对点发送,浏览器端不可能建立UDP监听吧,为了接收报警数据又不改动原有cs服务的原则,可以在node服务层开启websocket服务,浏览器端负责链接该服务,同时node服务作为udp的client去连接报警的udp服务,获取消息再进行ws转发即可解决。

总结:

1、遇到问题多思考,能通过转发解决的问题就不要通过改写接口去解决(确保旧版服务不变动的原则)

2、socket通讯模块,代码写的时候尽量多考虑一些极端情况,比如链接丢失、用户下线、服务挂了的情况,然后再做相应处理

3、遇到问题还是要多思考

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏C/C++基础

Linux基础知识点

文件(包括目录)权限分为三类别,从左至右依次是:文件所属主的权限、文件所属所在用户组的权限和其他用户的权限。

1442
来自专栏PhpZendo

深度挖掘 Laravel 生命周期

这篇文章我们来聊聊 「Laravel 生命周期」 这个主题。虽然网络上已经有很多关于这个主题的探讨,但这个主题依然值得我们去研究和学习。

1132
来自专栏ytkah

http如何301到https呢?

6994
来自专栏林冠宏的技术文章

关于java连接mysql数据库的几个问题的解决方法。

今天就为了连接下数据库获取信息来提供给ListView使用,搞了足足5小时。 出现的问题有:       第一个是,DriverManager.getConne...

1856
来自专栏前端杂货铺

服务端事件EventSource揭秘

服务端推 服务端推,指的是由服务器主动的向客户端发送消息(响应)。在应用层的HTTP协议实现中,“请求-响应”是一个round trip,它的起点来自客户端,因...

2935
来自专栏FreeBuf

解密攻击者如何利用D-Link路由器构建僵尸网络

在这篇文章中,我们将跟大家讨论我们在几台顶级D-Link路由器中发现的安全漏洞,受影响的路由器型号如下: -DIR890L -DIR885L -DIR895L...

2518
来自专栏菩提树下的杨过

[原创]在msmq3.0中使用http协议发送消息

1.先声明: msmq3.0仅在winxp和win2003以上系统支持,如果windows vista系统,据说已经开始支持msmq4.0了 2.为什么要使...

2428
来自专栏bboysoul

在树莓派上搭建使用gitlab

gitlab是一个代码托管平台,因为我的树莓派系统是安装在128G的u盘上的,用来放电影太小,但是空着就是空着了,所以还不如再搭建一个gitlab服务来存放自己...

1282
来自专栏JAVA高级架构

Rabbitmq---消息队列

有了消息队列,每一次连接不管是生成消息还是消费消息,都有各自的逻辑与其他逻辑无关--通信解耦

793
来自专栏左瞅瞅,右瞅瞅

Linux LVM简明教程

逻辑卷管理LVM是一个多才多艺的硬盘系统工具。无论在Linux或者其他类似的系统,都是非常的好用。传统分区使用固定大小分区,重新调整大小十分麻烦。但是,LVM可...

1911

扫码关注云+社区