task engine startload cams list error[SERVER] Server initial : IN[VDS_SERVER] Server Initialize malloc socket buffer sucessful !![VDS SERVER] Server Loop Startmaster_Start:run!createGraph success 0[VDS SERVER] Server Controler Start task engine ~TaskEngine[VDS SERVER] close the socket:8请问我在引擎内启动socket通讯，启动后为什么会马上会调用析构函数？见红色标记处host日志？

LiteOS创建一个TCP通信任务，每隔100ms通过 lwip_send 接口往PC 网络调试助手发送一次数据（Hello World）。实际测试发现：1、TCP通信任务能够100ms调度一次；2、但是网络传输出现阻塞现象，200ms的周期发送两帧数据；3、通过 wireshark 抓包来看，确实是200ms的周期才发送数据。请问有什么方式实现网络通信的实时传输？以下为网络调试助手接收到的数据：[2020-04-23 10:07:11.549]# RECV ASCII FROM 192.168.168.99 :52032>Hello WorldHello World[2020-04-23 10:07:11.749]# RECV ASCII FROM 192.168.168.99 :52032>Hello WorldHello World[2020-04-23 10:07:11.949]# RECV ASCII FROM 192.168.168.99 :52032>Hello WorldHello World

问题：在obs上有上千万的图片，要基于这些图片做近似查询，用http连接的话，太慢了。

TCP的Java支持     协议相当于相互通信的程序间达成的一种约定，它规定了分组报文的结构、交换方式、包含的意义以及怎样对报文所包含的信息进行解析，TCP/IP协议族有IP协议、TCP协议和UDP协议。现在TCP/IP协议族中的主要socket类型为流套接字（使用TCP协议）和数据报套接字（使用UDP协议）。    TCP协议提供面向连接的服务，通过它建立的是可靠地连接。Java为TCP协议提供了两个类：Socket类和ServerSocket类。一个Socket实例代表了TCP连接的一个客户端，而一个ServerSocket实例代表了TCP连接的一个服务器端，一般在TCP Socket编程中，客户端有多个，而服务器端只有一个，客户端TCP向服务器端TCP发送连接请求，服务器端的ServerSocket实例则**来自客户端的TCP连接请求，并为每个请求创建新的Socket实例，由于服务端在调用accept（）等待客户端的连接请求时会阻塞，直到收到客户端发送的连接请求才会继续往下执行代码，因此要为每个Socket连接开启一个线程。服务器端要同时处理ServerSocket实例和Socket实例，而客户端只需要使用Socket实例。另外，每个Socket实例会关联一个InputStream和OutputStream对象，我们通过将字节写入套接字的OutputStream来发送数据，并通过从InputStream来接收数据。 TCP连接的建立步骤  客户端向服务器端发送连接请求后，就被动地等待服务器的响应。典型的TCP客户端要经过下面三步操作：     1、创建一个Socket实例：构造函数向指定的远程主机和端口建立一个TCP连接；   2.通过套接字的I/O流与服务端通信；   3、使用Socket类的close方法关闭连接。   服务端的工作是建立一个通信终端，并被动地等待客户端的连接。典型的TCP服务端执行如下两步操作：     1、创建一个ServerSocket实例并指定本地端口，用来**客户端在该端口发送的TCP连接请求；     2、重复执行：           1）调用ServerSocket的accept（）方法以获取客户端连接，并通过其返回值创建一个Socket实例；           2）为返回的Socket实例开启新的线程，并使用返回的Socket实例的I/O流与客户端通信；           3）通信完成后，使用Socket类的close（）方法关闭该客户端的套接字连接。 TCP Socket Demo     下面给出一个客户端服务端TCP通信的Demo，该客户端在20006端口请求与服务端建立TCP连接，客户端不断接收键盘输入，并将其发送到服务端，服务端在接收到的数据前面加上“echo”字符串，并将组合后的字符串发回给客户端，如此循环，直到客户端接收到键盘输入“bye”为止。     客户端代码如下：  package zyb.org.client; import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.Socket;import java.net.SocketTimeoutException; public class Client1 {        public static void main(String[] args) throws IOException {               //客户端请求与本机在20006端口建立TCP连接               Socket client = new Socket("127.0.0.1", 20006);               client.setSoTimeout(10000);               //获取键盘输入               BufferedReader input = new BufferedReader(new InputStreamReader(System.in));               //获取Socket的输出流，用来发送数据到服务端               PrintStream out = new PrintStream(client.getOutputStream());               //获取Socket的输入流，用来接收从服务端发送过来的数据               BufferedReader buf =  new BufferedReader(new InputStreamReader(client.getInputStream()));               boolean flag = true;               while(flag){                       System.out.print("输入信息：");                       String str = input.readLine();                       //发送数据到服务端                       out.println(str);                       if("bye".equals(str)){                               flag = false;                       }else{                               try{                                      //从服务器端接收数据有个时间限制（系统自设，也可以自己设置），超过了这个时间，便会抛出该异常                                      String echo = buf.readLine();                                      System.out.println(echo);                               }catch(SocketTimeoutException e){                                      System.out.println("Time out, No response");                               }                       }               }               input.close();               if(client != null){                //如果构造函数建立起了连接，则关闭套接字，如果没有建立起连接，自然不用关闭                       client.close(); //只关闭socket，其关联的输入输出流也会被关闭               }        }}     服务端需要用到多线程，这里单独写了一个多线程类，代码如下： package zyb.org.server; import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.Socket; /** * 该类为多线程类，用于服务端 */public class ServerThread implements Runnable {         private Socket client = null;        public ServerThread(Socket client){               this.client = client;        }                @Override        public void run() {               try{                       //获取Socket的输出流，用来向客户端发送数据                       PrintStream out = new PrintStream(client.getOutputStream());                       //获取Socket的输入流，用来接收从客户端发送过来的数据                       BufferedReader buf = new BufferedReader(new InputStreamReader(client.getInputStream()));                       boolean flag =true;                       while(flag){                               //接收从客户端发送过来的数据                               String str =  buf.readLine();                               if(str == null || "".equals(str)){                                       flag = false;                               }else{                                      if("bye".equals(str)){                                              flag = false;                                      }else{                                              //将接收到的字符串前面加上echo，发送到对应的客户端                                              out.println("echo:" + str);                                      }                               }                       }                       out.close();                       client.close();               }catch(Exception e){                       e.printStackTrace();               }        } }    服务端处理TCP连接请求的代码如下：package zyb.org.server; import java.net.ServerSocket;import java.net.Socket; public class Server1 {        public static void main(String[] args) throws Exception{               //服务端在20006端口**客户端请求的TCP连接               ServerSocket server = new ServerSocket(20006);               Socket client = null;               boolean f = true;               while(f){                       //等待客户端的连接，如果没有获取连接                       client = server.accept();                       System.out.println("与客户端连接成功！");                       //为每个客户端连接开启一个线程                       new Thread(new ServerThread(client)).start();               }               server.close();        }}     执行结果截图如下：（转载自http://3ms.huawei.com/km/blogs/details/6038177）

想自己使用nodejs写一个对战用的socket程序

【问题现象】执行运行脚本运行时，报如下错误：mindstudio@ascend-HP-ProDesk-600-G4-PCI-MT:~/test0512/sample-facedetection-master$ bash run_facedetectionapp.sh 192.168.1.2 video Channel-2 &[1] 7920mindstudio@ascend-HP-ProDesk-600-G4-PCI-MT:~/test0512/sample-facedetection-master$ Prepare app configuration...Finish to prepare facedetectionapp params.[Step] run 192.168.1.2:ascend_facedetectionapp...22118ERROR: excute 192.168.1.2:./HIAI_PROJECTS/ascend_workspace/facedetectionapp/out/ascend_facedetectionapp failed, please check /var/log/syslog and board running log from IDE Log Module for details.然后查看syslog，发现如下错误：May 13 08:23:44 ascend-HP-ProDesk-600-G4-PCI-MT IDE-daemon-client: [IDE-daemon-client] [INFO]toolchain/ide/ide-daemon/IDE-daemon-client/../hdc-common/ide_daemon_sock.cc:463 >>> getpkt finishedMay 13 08:23:44 ascend-HP-ProDesk-600-G4-PCI-MT IDE-daemon-client: [IDE-daemon-client] [INFO]toolchain/ide/ide-daemon/IDE-daemon-client/../hdc-common/ide_daemon_sock.cc:406 >>> getpkt_1 succ, remote socket is close

中移模组研发团队一直秉承“自主研发为主，联合研发为辅”，打造了多款专业的模组产品，团队一直致力于革新技术，改善生产工艺来提升产品的性能、品质以及产能。日前，研发团队攻克了生产治具的难题，大大提升了模组的日产能。中移模组研发团队发现随着NB模组销量的持续增长，NB模组的日产能是保证交付的关键，随着日产能的提升，传统治具暴露的问题也越来越多，已经成为产能提升的重大阻力。模组研发团队为了提高产线直通率，减少误测，保证模组品质，决定舍弃传统治具，采用SOCKET屏蔽测试治具。SOCKET屏蔽测试治具外框采用全铝并导电处理加工，各个结合部分采用导电泡棉粘贴，确保治具接地屏蔽良好；模组托盘采用 PEEK 材料防型制作，耐磨系数是普通电木 FR4 的 10 倍以上，确保使用寿命及使用精度；模组与 EVB 板接触采用 3.4mm进口镀金高频双头探针，此探针无线损，接触稳定，使用寿命可达 10 万次以上，确保最小损耗和最低误测率。图为SOCKET屏蔽测试治具通过NB模组产线的验证，SOCKET治具校准综测直通率可达95%—97%，远高于传统治具（70%—80%）。不同于传统治具每天有30%的治具需要下线维护，SOCKET治具工作稳定，只需在双头探针达到使用寿命时进行更换即可，同时SOCKET治具校准综测的模组射频一致性远远优于传统治具生产的模组，功率误差从2.7dB减小至低于1dB，既提高了模组日产能也保证了模组的品质。目前产线正在大批量推广SOCKET屏蔽测试治具，突破产能瓶颈，实现模组日产能的快速提升。中移模组当前具备各项品质管控流程及规范12项，拥有短名单代工厂多家，具备年产3000万片模组能力。产品累计取得各项认证证书60余项。在社会各界的支持和信任下，中移自研NB模组销量持续增长，模组研发团队将继续致力于革新技术，提高模组的性能，提升模组的产能和品质，保障NB模组的质量和生产交付。万物互联孕育百亿级的连接量，催生万亿元级行业规模，物联网市场正迅速扩大，迎来发展的风口。通信模组作为物联网连接的重要桥梁，需要不断突破创新，提升产能跟上物联网发展的步伐。中移模组将持续研发的投入，与众多合作伙伴携手推进通信模组的产业发展，为早日实现行业百亿级连

本文为该系列第五篇，重点讲解订阅接口的使用。何为订阅：北向应用除了通过RESTful类型的数据查询接口，获取设备的当前数据和历史数据外，还可以通过消息订阅的方式来获取实时数据。当南向设备上报数据到达平台时，平台将检索是否有订阅存在，如果存在，则向对应的callbackUrl推送POST消息。消息订阅除了可以订阅消息外，还可以订阅设备绑定消息、设备删除消息、规则时间、命令响应等。订阅方式：订阅接口的格式非常简单，只有两个参数：notifyType：订阅的消息类型，有bindDevice、deviceDataChanged、deviceDeleted、commandRsp、ruleEvent等。callbackurl：消息发送的地址，支持HTTP和HTTPS（如果选择HTTPS，则需要上传应用服务器的证书到平台）。【Note】callbackurl包含IP和端口两部分，不可缺失。例如:http://xxx.xxx.xxx.xxx:8080平台目前不提供DNS解析服务，所以只能接受IP+Port的形式。消息接收方式：首先，接收消息的应用服务器需要有一个公网IP（当然，如果是有公网IP的路由器将端口进行映射也可以）。而后应用服务器端就可以跑一个端口的监控程序，等待客户端的socket连接。可以考虑使用ServerSocket来实现。ServerSocket ss = new ServerSocket(8080, 10, InetAddress.getByName("xxx.xxx.xxx.xxx"));accept()将阻塞，直到客户端发起socket连接请求，并完成连接。连接建立后，就可以从socket中读取到消息体。InputStreamReader input = new InputStreamReader(socket.getInputStream());消息体：（以一个deviceDataChanged类型的消息为例）POST / HTTP/1.1Content-Type: application/jsonContent-Length:313Host:xxx.xxx.xxx.xxx:8080Connection: Keep-AliveUser-Agent: Apache-HttpClient/4.4.1 (JAVA/1.8.0_101)Accept-Encoding: gzip, deflate{"notifyType":"deviceDataChanged","deviceId":"xxxxxxxx",“gatewayId”:"xxxxxxx","requestId":null,"service":{    "serviceId":"Humidity",    "serviceType":"Humidity",    "data":{        "Humidity":17,        "HumidityMinToday":17,        "HumidityMaxToday":18    },    "eventTime":"20170405T151308Z"}}之后，就是消息体的解析了，这里就不再赘述了。