使用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 条评论
登录 后参与评论

相关文章

来自专栏程序工场

apache和tomcat区别

经常在用apache和tomcat等这些服务器,可是总感觉还是不清楚他们之间有什么关系,在用tomcat的时候总出现apache,总感到迷惑,到底谁是主谁是次,...

582
来自专栏Java技术栈

Spring Boot Redis Cluster 实战干货

尝试往redis写数据的时候,报不能获取连接异常,跟踪了半天代码,发现连接的是127.0.0.1,而不是配置的192.168.1.8,这就奇怪了,继续跟踪代码发...

1454
来自专栏小狼的世界

Apache日志中的处理时间

Apache的日志有很多可以自己定义的项目,其中一个 %T 能够显示出服务器处理请求所用的时间。我就是对这个的定义发生了疑问,所以做了一些考证。

801
来自专栏java达人

防止表单重复提交的思路和方法

作为一个软件开发者,绝不能奢望你的用户会规规矩矩地使用你的软件,他们一般都是缺乏耐心,“胡作非为”的。比如当他点击提交表单时,服务器处理比较慢, 页面上没有任何...

1878
来自专栏

使用redis构建可靠分布式锁

关于分布式锁的概念,具体实现方式,直接参阅下面两个帖子,这里就不多介绍了。 分布式锁的多种实现方式 分布式锁总结 对于分布式锁的几种实现方式的优劣,这里再列举下...

2537
来自专栏郭少华

Spring Boot 日志(八)

Spring Boot在所有内部日志中使用Commons Logging,但是默认配置也提供了对常用日志的支持,如:Java Util Logging,Log4...

1264
来自专栏Java工程师日常干货

【SpringBoot专题】Java平台下日志的那些事前言日志框架漫谈看SpringBoot如何对日志进行统一处理SpringBoot日志使用结束语

本篇是【SpringBoot专题】系列的第三篇,将介绍SpringBoot对日志的支持,讲解Java平台下日志的那些事,彻底揭开日志框架在使用过程中的那些坑~

864
来自专栏码匠的流水账

nginx proxy cache配置参数解读

本文主要解析一下nginx ngx_http_proxy_module中的cache相关配置参数。

701
来自专栏developerHaoz 的安卓之旅

Android 一起来看看 HttpURLConnection 和 HttpClient 的区别

大部分需要联网的 Android 应用程序都会使用 HTTP 去发送和接收数据。Android 中包括两种方式来进行 HTTP 的请求:HttpURLConne...

723
来自专栏Android知识点总结

3--安卓网络编程之Socket编程

733

扫码关注云+社区