【功能模块】使用AT指令创建socket连接，发送1234发送了10次左右 只有1条收到，网络状态很奇怪使用AT+CERGE?调试发现期间NB网络注册状态很奇怪【操作步骤&问题现象】1、2、【截图信息】【日志信息】（可选，上传日志内容或者附件）

在执行脚本的时候遇到此报错。socket.gaierror: [Errno 11001] getaddrinfo failed通过百度可以看到是增加了一些符号如换行符或者空格导致，可以检查脚本传进来的参数是否是合法的。此问题就是网络不通导致的，收发邮件等都会遇到。[2021-11-23 15:19:00,395] [INFO] - com.huawei.antrobot.logging.log_output.log_output(log_output_start_end:111) - start running action: smtp.sendEmail line:17 [email-发送查看邮件提醒] in xingchengka.xml[2021-11-23 15:19:00,964] [WARNING] - com.huawei.antrobot.framework.security_check.digital_certificate_checker.digital_certificate_checker(inner:60) - There are no uploaded certificates in the certificate library directory[2021-11-23 15:19:00,972] [ERROR] - com.huawei.antrobot.dispatch.dispatcher.dispatcher(logout_traceback:130) - Traceback (most recent call last):  File "..com.huawei.antrobot.framework.failure.failure_deal.py", line 100, in inner  File "..com.huawei.antrobot.framework.security_check.allow_list_utils.py", line 223, in inner  File "..com.huawei.antrobot.dispatch.dispatcher.py", line 92, in run  File "..com.huawei.antrobot.drivers.common_driver.py", line 55, in run_action  File "..com.huawei.antrobot.actions.common.base.py", line 64, in order  File "..com.huawei.antrobot.actions.common.base.py", line 109, in run  File "..com.huawei.antrobot.framework.security_check.digital_certificate_checker.py", line 63, in inner  File "..com.huawei.antrobot.framework.security_check.information_limit.py", line 109, in inner  File "..com.huawei.antrobot.actions.wa-mail******mail******mail****** in sendemail  File "..com.huawei.antrobot.actions.wa-mail******mail******mail****** in start_send  File "..com.huawei.antrobot.actions.wa-mail******mail******mail****** in protocol_auth  File "..com.huawei.antrobot.actions.wa-mail******mail******mail****** in get_smtp_obj  File "..com.huawei.antrobot.actions.wa-mail******mail******mail****** in smtp  File "smtplib.py", line 253, in __init__  File "smtplib.py", line 339, in connect  File "smtplib.py", line 308, in _get_socket  File "socket.py", line 787, in create_connection  File "socket.py", line 918, in getaddrinfosocket.gaierror: [Errno 11001] getaddrinfo failed解决方法：检查邮件收发的地址，比如 pop.qq.com  / 10.22.88.33 这些本不应该出现空格的地方出现了空格或者不容易被察觉的换行符等，排查后基本都能解决。

【功能模块】目前MDC版本使用的是105-T，不支持使用的vlp-16激光雷达。我们想通过数据透传功能接收激光雷达数据。【操作步骤&问题现象】1、修改好激光雷达的TP地址和端口，接入2以太网口，登录mdc后可以ping通。2、按照《快速入门指南》中配置激光雷达透传通路，修改了“sensor_lidar_data_dispense_cfg.json”文件。但不知道如何接收激光雷达裸数据，以及解析代码存放位置。【截图信息】【日志信息】（可选，上传日志内容或者附件）

【功能模块】【msdk】【tcp socket】MSDK-COMMON_V200R020C10SPC100，b265版本【操作步骤&问题现象】1、我在尾端搞了两个任务，一个任务实现tcp socket server，一个tcp socket client，如果使用尾端外部呈现的Ip，该问题中使用的ipv6是"fc00::2a4:1ff:fe15:7031"，server是可以接收到数据的，client也可以连接到server, 但是换成in6addr_any参数，就不能使用了，我这边的需求是尾端是服务端，所以尾端要有一个通配地址的。2、在问题1的基础上，尾端使用"fc00::2a4:1ff:fe15:7031"，核心板上容器内客户端连接还是被拒绝，怎么回事？【截图信息】【日志信息】（可选，上传日志内容或者附件）无

【功能模块】arcore 265版本【操作步骤&问题现象】1，使用的是自己编译的容器，其它程序都能正常运行；2，再此基础上，之前是没有的，现在要实现一个tcp socket，核心板作为tcp socket 客户端，尾端作为tcp socket 服务端，目前出现一个问题，客户端连接总是被拒绝，但是目前不论客户端还是服务器的函数都是执行成功的，端口也是使用相同的；3，同样的环境，实现了一个udp socket，核心板作为udp socket服务器，尾端作为udp socket客户端，两边就能正常收发。怎么回事，还是需要什么参数吗？【截图信息】无【日志信息】（可选，上传日志内容或者附件）无

问题背景描述：某局点某Kafka节点文件句柄数很高，导致此节点上Kafka的请求失败，lsof -p kafkapid发现Kafka进程有大量socket泄漏，如下图所示：问题分析步骤：1. 执行ls -l /proc/kafkapid/fd >> fd.txt命令查看Kafka进程的文件描述符2. 执行trace -T -tt -f -F output.txt -p kafkapid命令打出kafka进程的调用信息3. 几分钟后再次执行执行ls -l /proc/kafkapid/fd >> fd1.txt命令查看Kafka进程的文件描述符4. 对比1和3步骤中的文件描述符，查找增加的socket连接，多查找几个增加socket连接，根据socket对应的id号从2步骤中获取的信息中查看对应的id连接调用信息5. 如果查找socket连接对应的客户端，可以通过accept查找，如下图所示此查询查询到对应的socketfd对应的所有的客户端连接，多次查找后可对比客户端连接来进一步确认客户端的范围。6. 通过accept查找的原因是socket通信中accept函数获取客户端的连接：int accept(int sockfd,struct sockaddr * addr,socklen_t * addrlen);sockfd的参数为listen()函数返回的监听套接字；addr是一个传出参数，表示客户端的地址，该参数设置为NULL时，表示不关心客户端的地址。addrlen为一个传入传出参数，传入时为函数调用时提供参数addr的长度，传出时为客户端地址结构体的实际长度；accept的返回值也是一个套接字，该套接字用于与本次通信的客户端进行数据交互。

【功能模块】【操作步骤&问题现象】1、想通过socket直连激光雷达获取激光雷达裸数据，请问有这方面相关的demo吗？2、【截图信息】【日志信息】（可选，上传日志内容或者附件）

服务器错误：爬虫发起抓取，httpcode返回码是5XX访问被拒绝：爬虫发起抓取，httpcode返回码是403找不到页面：爬虫发起抓取，httpcode返回码是404其他错误：爬虫发起抓取，httpcode返回码是4XX，不包括403和404

我们想直接使用socket来接收T-BOX传来的裸数据，有没有demo？

问题：在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）

中移模组研发团队一直秉承“自主研发为主，联合研发为辅”，打造了多款专业的模组产品，团队一直致力于革新技术，改善生产工艺来提升产品的性能、品质以及产能。日前，研发团队攻克了生产治具的难题，大大提升了模组的日产能。中移模组研发团队发现随着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"}}之后，就是消息体的解析了，这里就不再赘述了。