devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

鸿蒙Socket通信示例（TCP通信）

作者：Cpp五条 | 2024-03-14 12:50:31

赞

踩

鸿蒙Socket通信示例（TCP通信）

前言

DevEco Studio版本：4.0.0.600

参考链接：OpenHarmony Socket

效果

TCPSocket

1、bind绑定本地IP地址

  1. private bindTcpSocket() {
  2.    let localAddress = resolveIP(wifi.getIpInfo().ipAddress)
  3.    console.info("111111111  localAddress: " + localAddress);
  4.  
  5.    //bind本地地址
  6.    tcpSocket.bind({ address: localAddress })
  7.       .then(() => {
  8.          console.info("111111111 绑定Tcp成功");
  9.       })
  10.       .catch(err => {
  11.          console.info("111111111 绑定Tcp失败，原因: " + err);
  12.       });
  13. }

2、设置tcpSocket的监听

  1. private tcpSocketListener() {
  2.    tcpSocket.on('connect', () => {
  3.       this.connectMessage = '已连接'
  4.       console.info("111111111  监听： 连接成功");
  5.    });
  6.  
  7.    tcpSocket.on('message', (value: {
  8.       message: ArrayBuffer,
  9.       remoteInfo: socket.SocketRemoteInfo
  10.    }) => {
  11.       this.messageReceive = this.messageReceive + this.resolveArrayBuffer(value.message) + "\n"
  12.       console.info("111111111  接收服务器的数据： " + this.messageReceive);
  13.    });
  14.    tcpSocket.on('close', () => {
  15.       this.connectMessage = '未连接'
  16.       console.info("111111111   监听：关闭连接")
  17.    });
  18. }

3、连接服务器

  1. private tcpSocketConnect() {
  2.    //开始连接
  3.    tcpSocket.connect({
  4.       address: { address: connectAddress.address, port: connectAddress.port, family: connectAddress.family },
  5.       timeout: 6000
  6.    }).then(() => {
  7.       console.info("111111111   tcpSocketConnect：连接成功");
  8.  
  9.       let tcpExtraOptions: socket.TCPExtraOptions = {
  10.          keepAlive: true, //是否保持连接。默认为false
  11.          OOBInline: true, //是否为OOB内联。默认为false
  12.          TCPNoDelay: true, //TCPSocket连接是否无时延。默认为false
  13.          socketLinger: {
  14.             on: true,
  15.             linger: 10
  16.          }, //socket是否继续逗留。- on：是否逗留（true：逗留；false：不逗留）。- linger：逗留时长，单位毫秒（ms），取值范围为0~65535。当入参on设置为true时，才需要设置。
  17.          receiveBufferSize: 1000, //接收缓冲区大小（单位：Byte），默认为0
  18.          sendBufferSize: 1000, //发送缓冲区大小（单位：Byte），默认为0。
  19.          reuseAddress: true, //是否重用地址。默认为false。
  20.          socketTimeout: 3000//套接字超时时间，单位毫秒（ms），默认为0。
  21.       }
  22.       tcpSocket.setExtraOptions(tcpExtraOptions, (err: BusinessError) => {
  23.          if (err) {
  24.             console.log('111111111   setExtraOptions 失败');
  25.             return;
  26.          }
  27.          console.log('111111111  setExtraOptions 成功');
  28.       });
  29.  
  30.    }).catch((error) => {
  31.       console.info("111111111  tcpSocketConnect 连接失败，原因： " + JSON.stringify(error));
  32.    })
  33. }

4、发送数据内容

  1. private sendMessage() {
  2.    tcpSocket.getState().then((data) => {
  3.       console.info("111111111 连接状态： " + JSON.stringify(data))
  4.       //已连接
  5.       if (data.isConnected) {
  6.          //发送消息
  7.          tcpSocket.send({ data: `${this.inputContent}\n`, encoding: 'UTF-8' })
  8.             .then(() => {
  9.                this.messageReceive = this.messageReceive + "发送：" + this.inputContent + "\n"
  10.                console.info("111111111  消息发送成功");
  11.             })
  12.             .catch((error) => {
  13.                console.info("111111111  消息发送失败，原因：" + JSON.stringify(error));
  14.             })
  15.       } else {
  16.          console.info("111111111  没有连接");
  17.          this.connectMessage = '未连接，服务器断了'
  18.       }
  19.    })
  20. }

5、结束释放资源

  1. private tcpSocketRelease() {
  2.    tcpSocket.off("message")
  3.    tcpSocket.off("connect")
  4.    tcpSocket.off("close")
  5.    tcpSocket.close()
  6.    tcpSocket = null
  7. }

6、UI实现

  1. build() {
  2.    Column() {
  3.       TextInput({ placeholder: '请输入用户名', text: '测试数据：Test' })
  4.          .width('100%')
  5.          .margin({ top: 20, bottom: 20 })
  6.          .onChange((value: string) => {
  7.             this.inputContent = value
  8.          })
  9.  
  10.       Button('发送数据')
  11.          .width('100%')
  12.          .margin({ top: 20, bottom: 20 })
  13.          .onClick(() => {
  14.             this.sendMessage()
  15.          })
  16.  
  17.       Text() {
  18.          Span('连接状态：')
  19.          Span(this.connectMessage).fontColor(Color.Red)
  20.       }
  21.  
  22.       Scroll() {
  23.          Column() {
  24.             Text() {
  25.                Span('内容:\n')
  26.                Span(this.messageReceive).fontColor(Color.Pink)
  27.             }
  28.          }.width('100%')
  29.          .alignItems(HorizontalAlign.Start)
  30.       }
  31.       .width("100%")
  32.       .alignSelf(ItemAlign.Start)
  33.       .flexShrink(1)
  34.       .margin({ top: 15 })
  35.    }
  36.    .alignItems(HorizontalAlign.Start)
  37.    .padding({ left: 15, right: 15 })
  38.    .width('100%')
  39.    .height('100%')
  40. }

详细代码

1、Index.ets

  1. import socket from '@ohos.net.socket';
  2. import wifi from '@ohos.wifi';
  3. import { BusinessError } from '@ohos.base';
  4. import { resolveIP } from '../utils/IpUtil';
  5. import util from '@ohos.util';
  6.  
  7. //tcp连接对象
  8. let tcpSocket = socket.constructTCPSocketInstance();
  9.  
  10. //连接服务器的地址和端口
  11. let connectAddress = {
  12.    address: '10.65.XX.XX', //要通信的 PC地址，CMD--->ipconfig查看
  13.    family: 1,
  14.    port: 6666
  15. }
  16.  
  17. @Entry
  18. @Component
  19. struct Index {
  20.    @State connectMessage: string = '未连接'
  21.    @State messageReceive: string = ''
  22.    @State inputContent: string = ''
  23.  
  24.    aboutToAppear() {
  25.       this.tcpSocketListener()
  26.       this.bindTcpSocket()
  27.    }
  28.  
  29.    onPageShow() {
  30.       this.tcpSocketConnect()
  31.    }
  32.  
  33.    onPageHide() {
  34.       this.tcpSocketRelease()
  35.    }
  36.  
  37.    build() {
  38.       Column() {
  39.          TextInput({ placeholder: '请输入用户名', text: '测试数据：Test' })
  40.             .width('100%')
  41.             .margin({ top: 20, bottom: 20 })
  42.             .onChange((value: string) => {
  43.                this.inputContent = value
  44.             })
  45.  
  46.          Button('发送数据')
  47.             .width('100%')
  48.             .margin({ top: 20, bottom: 20 })
  49.             .onClick(() => {
  50.                this.sendMessage()
  51.             })
  52.  
  53.          Text() {
  54.             Span('连接状态：')
  55.             Span(this.connectMessage).fontColor(Color.Red)
  56.          }
  57.  
  58.          Scroll() {
  59.             Column() {
  60.                Text() {
  61.                   Span('内容:\n')
  62.                   Span(this.messageReceive).fontColor(Color.Pink)
  63.                }
  64.             }.width('100%')
  65.             .alignItems(HorizontalAlign.Start)
  66.          }
  67.          .width("100%")
  68.          .alignSelf(ItemAlign.Start)
  69.          .flexShrink(1)
  70.          .margin({ top: 15 })
  71.       }
  72.       .alignItems(HorizontalAlign.Start)
  73.       .padding({ left: 15, right: 15 })
  74.       .width('100%')
  75.       .height('100%')
  76.    }
  77.  
  78.    /**
  79.     * tcp连接状态和消息监听
  80.     */
  81.    private tcpSocketListener() {
  82.       tcpSocket.on('connect', () => {
  83.          this.connectMessage = '已连接'
  84.          console.info("111111111  监听： 连接成功");
  85.       });
  86.  
  87.       tcpSocket.on('message', (value: {
  88.          message: ArrayBuffer,
  89.          remoteInfo: socket.SocketRemoteInfo
  90.       }) => {
  91.          this.messageReceive = this.messageReceive + this.resolveArrayBuffer(value.message) + "\n"
  92.          console.info("111111111  接收服务器的数据： " + this.messageReceive);
  93.       });
  94.       tcpSocket.on('close', () => {
  95.          this.connectMessage = '未连接'
  96.          console.info("111111111   监听：关闭连接")
  97.       });
  98.    }
  99.  
  100.    /**
  101.     * 绑定Tcp本地地址
  102.     * bind的IP为'localhost'或'127.0.0.1'时，只允许本地回环接口的连接，即服务端和客户端运行在同一台机器上
  103.     */
  104.    private bindTcpSocket() {
  105.       let localAddress = resolveIP(wifi.getIpInfo().ipAddress)
  106.       console.info("111111111  localAddress: " + localAddress);
  107.  
  108.       //bind本地地址
  109.       tcpSocket.bind({ address: localAddress })
  110.          .then(() => {
  111.             console.info("111111111 绑定Tcp成功");
  112.          })
  113.          .catch(err => {
  114.             console.info("111111111 绑定Tcp失败，原因: " + err);
  115.          });
  116.    }
  117.  
  118.    /**
  119.     * 发送消息数据
  120.     */
  121.    private sendMessage() {
  122.       tcpSocket.getState().then((data) => {
  123.          console.info("111111111 连接状态： " + JSON.stringify(data))
  124.          //已连接
  125.          if (data.isConnected) {
  126.             //发送消息
  127.             tcpSocket.send({ data: `${this.inputContent}\n`, encoding: 'UTF-8' })
  128.                .then(() => {
  129.                   this.messageReceive = this.messageReceive + "发送：" + this.inputContent + "\n"
  130.                   console.info("111111111  消息发送成功");
  131.                })
  132.                .catch((error) => {
  133.                   console.info("111111111  消息发送失败，原因：" + JSON.stringify(error));
  134.                })
  135.          } else {
  136.             console.info("111111111  没有连接");
  137.             this.connectMessage = '未连接，服务器断了'
  138.          }
  139.       })
  140.    }
  141.  
  142.    /**
  143.     * 连接服务器
  144.     */
  145.    private tcpSocketConnect() {
  146.       //开始连接
  147.       tcpSocket.connect({
  148.          address: { address: connectAddress.address, port: connectAddress.port, family: connectAddress.family },
  149.          timeout: 6000
  150.       }).then(() => {
  151.          console.info("111111111   tcpSocketConnect：连接成功");
  152.  
  153.          let tcpExtraOptions: socket.TCPExtraOptions = {
  154.             keepAlive: true, //是否保持连接。默认为false
  155.             OOBInline: true, //是否为OOB内联。默认为false
  156.             TCPNoDelay: true, //TCPSocket连接是否无时延。默认为false
  157.             socketLinger: {
  158.                on: true,
  159.                linger: 10
  160.             }, //socket是否继续逗留。- on：是否逗留（true：逗留；false：不逗留）。- linger：逗留时长，单位毫秒（ms），取值范围为0~65535。当入参on设置为true时，才需要设置。
  161.             receiveBufferSize: 1000, //接收缓冲区大小（单位：Byte），默认为0
  162.             sendBufferSize: 1000, //发送缓冲区大小（单位：Byte），默认为0。
  163.             reuseAddress: true, //是否重用地址。默认为false。
  164.             socketTimeout: 3000//套接字超时时间，单位毫秒（ms），默认为0。
  165.          }
  166.          tcpSocket.setExtraOptions(tcpExtraOptions, (err: BusinessError) => {
  167.             if (err) {
  168.                console.log('111111111   setExtraOptions 失败');
  169.                return;
  170.             }
  171.             console.log('111111111  setExtraOptions 成功');
  172.          });
  173.  
  174.       }).catch((error) => {
  175.          console.info("111111111  tcpSocketConnect 连接失败，原因： " + JSON.stringify(error));
  176.       })
  177.    }
  178.  
  179.    /**
  180.     * 解析ArrayBuffer
  181.     */
  182.    private resolveArrayBuffer(message: ArrayBuffer): string {
  183.       let view = new Uint8Array(message);
  184.       let textDecoder = util.TextDecoder.create()
  185.       let str = textDecoder.decodeWithStream(view);
  186.       console.info("111111111 message 缓存内容: " + str)
  187.       return str;
  188.    }
  189.  
  190.    /**
  191.     * 关闭Socket监听和连接,释放资源
  192.     */
  193.    private tcpSocketRelease() {
  194.       tcpSocket.off("message")
  195.       tcpSocket.off("connect")
  196.       tcpSocket.off("close")
  197.       tcpSocket.close()
  198.       tcpSocket = null
  199.    }
  200. }

2、IpUtil.ets

  1. export function resolveIP(ip: number): string {
  2.   if (ip < 0 || ip > 0xFFFFFFFF) {
  3.     throw ('The number is not normal!');
  4.   }
  5.   return (ip >>> 24) + '.' + (ip >> 16 & 0xFF) + '.' + (ip >> 8 & 0xFF) + '.' + (ip & 0xFF);
  6. }

3、module.json5配置

因为涉及到网络访问，需要配置网络权限，在module.json5中配置

  1. "requestPermissions": [
  2.   {
  3.     "name": "ohos.permission.INTERNET"  //联网
  4.   },
  5.   {
  6.     "name": "ohos.permission.GET_NETWORK_INFO"  //获取网络相关信息
  7.   },
  8.   {
  9.     "name": "ohos.permission.SET_NETWORK_INFO" //设置网络相关信息
  10.   },
  11.   {
  12.     "name": "ohos.permission.GET_WIFI_INFO" //获取wifi相关信息
  13.   }
  14. ]

服务器端Java代码

  1. package org.example;
  2.  
  3. import java.io.*;
  4. import java.net.ServerSocket;
  5. import java.net.Socket;
  6.  
  7. public class SocketService {
  8.     public static void main(String[] args) {
  9.         int port = 6666;
  10.         try {
  11.             // 创建ServerSocket对象，指定监听的端口号
  12.             ServerSocket serverSocket = new ServerSocket(port);
  13.             while (true) {
  14.                 Socket clientSocket = serverSocket.accept();
  15.                 System.out.println("客户端连接: " + clientSocket.getInetAddress().getHostAddress());
  16.  
  17.                 BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
  18.                 PrintWriter writer = new PrintWriter(clientSocket.getOutputStream(), true);
  19.  
  20.                 String message;
  21.                 while ((message = reader.readLine()) != null) {
  22.                     System.out.println("从客户端接收到的消息: " + message);
  23.                     writer.println("回复: " + message);
  24.                 }
  25.  
  26.                 reader.close();
  27.                 writer.close();
  28.                 clientSocket.close();
  29.                 System.out.println("连接断开");
  30.             }
  31.         } catch (Exception e) {
  32.             e.printStackTrace();
  33.         }
  34.     }
  35. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/234558
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号