node实现socket链接与GPRS进行通信的方法

业务背景

最近接到一个需求，在微信公众号界面设计一个独立界面，界面上有 a 电机进、a 电机退、b 电机进、b 电机退 4 个按钮，点击对应按钮，云平台发送不同的代码给电机本地的控制器，控制电机执行不同的动作，电机本地控制器具备gprs网络功能。服务器与电机本地控制器（客户端）采用 tcp 协议连接，客户端发送心跳包给服务器保持长连接，客户端每次收到服务器下发的代码指令后作出回复主要的实现原理是前端访问后台的接口传输数据。后台采用用socket与gprs模块进链接，暴露出一个ip+port给gprs进行访问即可，实现逻辑比较简单。但是在开发中出现一下比较棘手问题，下面进行一一归纳。

技术栈

主要采用的技术栈前端部分采用vue和weui，后台采用node的koa框架，前端页面是直接写在koa里面，由于页面比较简单，所以没有实现前后的分离。

实现过程

1、前端部分

前端部分实现主要是提供4个按钮，向后台接口请求对应的数据，例如：点击a点击前进，就向后台请求http://xxxx:4000/djxt/move接口并传输数据，可以下载完整项目运行后，通过127.0.0.1:3002/djxt进行访问，页面html代码主要部分如下：

 <div class="wrap">
   <button @click="goa('a1')" class="weui-btn" v-bind:class="{ 'weui-btn_loading': btnstatus.cur == 'a1'&&btnstatus.status==0, 'weui-btn_primary': btnstatus.cur == 'a1'&&btnstatus.status==1, 'weui-btn_plain-primary': btnstatus.cur != 'a1' }">a 前进<i v-show="btnstatus.cur == 'a1'&&btnstatus.status==0" class="weui-loading"></i></button>

   <button @click="backa('a0')" class="weui-btn" v-bind:class="{ 'weui-btn_loading': btnstatus.cur == 'a0'&&btnstatus.status==0, 'weui-btn_primary': btnstatus.cur == 'a0'&&btnstatus.status==1, 'weui-btn_plain-default': btnstatus.cur != 'a0' }">a 后退<i v-show="btnstatus.cur == 'a0'&&btnstatus.status==0" class="weui-loading"></i></button>

   <button @click="gob('b1')" class="weui-btn" v-bind:class="{ 'weui-btn_loading': btnstatus.cur == 'b1'&&btnstatus.status==0, 'weui-btn_primary': btnstatus.cur == 'b1'&&btnstatus.status==1, 'weui-btn_plain-primary': btnstatus.cur != 'b1' }">b 前进<i v-show="btnstatus.cur == 'b1'&&btnstatus.status==0" class="weui-loading"></i></button>
   
   <button @click="backb('b0')" class="weui-btn" v-bind:class="{ 'weui-btn_loading': btnstatus.cur == 'b0'&&btnstatus.status==0, 'weui-btn_primary': btnstatus.cur == 'b0'&&btnstatus.status==1, 'weui-btn_plain-default': btnstatus.cur != 'b0' }">b 后退<i v-show="btnstatus.cur == 'b0'&&btnstatus.status==0" class="weui-loading"></i></button>
  </div>

发送数据给后台部分代码如下：

 // a 前进
     goa (id){
      axios.post('/djxt/move', { id })
      .then( (response)=> {
       console.log(response);
       if( response.data.success ){
        this.alertdialog.content = '操作成功';
        this.alertdialog.status = true;
       }else{
        this.alertdialog.content = '操作失败了';
        this.alertdialog.status = true;
       }
      })
      .catch( (error)=> {
       console.log(error);
        this.alertdialog.content = '操作失败了';
        this.alertdialog.status = true;
      });
     }

2、后台实现

由于用的是node技术栈，当初使用的是scoket.io来进行scoket链接的，但是在后面的开发中发现该方法需要有一个事件去触发提交数据，在客户端也需要有事件进行监听，不适合在与gprs进行通信，最后无奈的放弃了。后面采用了node的net模块进行通信，该模块只要调用write(data)就可以发送绑定端口的数据。相对比较简单。可以参考一下nodejs.org/dist/latest… 看不懂英文可以找中文版的。

net的连接可以写在www文件或是app.js文件，看自己需求。在该项目中暴露出来接口127.0.0.1:3004,代码如下：

//socket
var net = require('net');
// 服务器ip
var host = '127.0.0.1';
// 端口号
var port = 3004;

// 创建一个tcp服务器实例，调用listen函数开始监听指定端口
// 传入net.createserver()的回调函数将作为”connection“事件的处理函数
// 在每一个“connection”事件中，该回调函数接收到的socket对象是唯一的

net.createserver(function(sock) {
// 全局sock，可以在其他地方调用
global.sock = sock
// 获得了一个socket连接，将客户端输出来
console.log('connected: ' +
  sock.remoteaddress + ':' + sock.remoteport);

// 为这个socket实例添加一个"data"事件处理函数，接收客户端数据
sock.on('data', function(data) {
  console.log('data ' + sock.remoteaddress + ': ' + data);
  // 回发该数据，客户端将收到来自服务端的数据，实现echo服务器
  // sock.write('' + data );
});

// 为这个socket实例添加一个"close"事件处理函数
sock.on('close', function(data) {
  console.log('closed: ' +
    sock.remoteaddress + ' ' + sock.remoteport);
});

}).listen(port, host);

代码中的host 是你需要暴露给gprs模块的ip，port是端口。net.createserver创建服务后，它回调里面的sock可以用来做一些监听，例如客户端返回数据sock.on('data', function(data) {})。在开发过程中遇到一个问题就是host在本地是用127.0.0.1是可以进行访问的，但是到了云服务后，会出现端口访问不了。解决办法是把host改为你自己服务器的内网ip即可进行访问。global.sock = sock这个主要是暴露全局的sock，可以在其他需要地方进行调用，切记要暴露出去。

服务端处理前端发送过来的数据，发送到gprs模块。该项目中前端访问的路由为/move，进入这个路由后进行判断，再把值转发给gprs，这里关键点是利用全局的sock的sock.write()来发送到客户端。代码如下

//前端接口
router.post('/move', async (ctx, next) => {
 let params = ctx.request.body;
 
 // console.log('ctx.state： ', global.sock)
 // console.log('ctx.state2222： ', sock)
 console.log('前端接口： ', params)
 if( !sock ){
  ctx.body = {
   data: params,
   success: false,
   msg: 'socket不存在'
  }
 }else{
  sock.write( params.id );

  ctx.body = {
   data: params,
   success: true,
   msg: ''
  }
 }
})

完整的代码可参考github。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。