提兵百万西湖上，立马吴山第一峰！这篇文章主要讲述#星光计划2.0#Harmonyos网络通信真机Demo演练之TCP聊天室相关的知识，希望能为你提供帮助。
【本文正在参与51CTO HarmonyOS技术社区创作者激励计划-星光计划2.0】
本Demo界面由ArkUI实现，网络逻辑部分由java实现，服务器用容易部署演练的Go实现。java和GO初次实战，本Demo还存在并发数据安全未处理，所以本Demo仅能用于学习。可学习之处有以下几点：
        一、FA与PA采用ACE方式的调用及相互交互、数据流转等。
        二、Harmonyos的事件机制及使用--自定义事件.
        三、异步多线程TCP通信。
@toc
一、效果展示     1，服务器端::: hljs-center

文章图片

:::
    2，客户端::: hljs-center

文章图片

:::
二、设计流程图::: hljs-center

文章图片

:::
三、界面编写     1,界面效果::: hljs-center

文章图片

:::
    2,界面代码HML代码：
```html/xml
< div class=" container" >
< div class=" container1" >
< text class=" title" >
tcp-client test
< /text>
< /div>
< div class=" container2" >
< text class=" text2" > IP:< /text>
< input class=" input2" placeholder=" enter ip" onchange=" onChange2" >
< /input>
< /div>
< div class=" container3" >
< text class=" text3" > Port:< /text>
< input class=" input3" placeholder=" enter port" onchange=" onChange3" >
< /input>
< /div>
< button class=" button1" type=" capsule" onclick=" onConnect" > 连接服务器< /button>
< button class=" button3" type=" capsule" onclick=" onSubResvMsg" > 订阅消息< /button>
< textarea class=" text4" >
outcont
< /textarea>
< div class=" container4" >
< input class=" input5" placeholder=" enter msg" onchange=" onChange4" >
< /input>
< button class=" button2" type=" capsule" onclick=" onSend" > 发送消息< /button>
< /div>
< /div>

JS代码： ```javascript import prompt from @system.prompt; export default data: title: World, outcont: , ip:, port:, msg: ,initConnectAction: function (code,ip,port) var actionData = https://www.songbingjia.com/android/; actionData.ip = ip; actionData.port = port; var action = ; action.bundleName ="com.gane.tcpclient"; action.abilityName = "TcpClientAbility"; action.messageCode = code; action.data = https://www.songbingjia.com/android/actionData; action.abilityType = 1; action.syncOption = 0; return action; ,initAction: function (code) var actionData = ; var action = ; action.bundleName ="com.gane.tcpclient"; action.abilityName = "TcpClientAbility"; action.messageCode = code; action.data = https://www.songbingjia.com/android/actionData; action.abilityType = 1; action.syncOption = 0; return action; ,initAction2: function (code,msg) var actionData = ; actionData.msg = msg; var action = ; action.bundleName ="com.gane.tcpclient"; action.abilityName = "TcpClientAbility"; action.messageCode = code; action.data = https://www.songbingjia.com/android/actionData; action.abilityType = 1; action.syncOption = 0; return action; ,onChange2(e) this.ip = e.value; ,onChange3(e) this.port = e.value; ,onConnect: async function() try var action = this.initConnectAction(1001,this.ip,this.port); var result = await FeatureAbility.callAbility(action); console.info(" result = " + result); this.showToast(result); catch (pluginError) console.error("getBatteryLevel : Plugin Error = " + pluginError); ,onSubResvMsg:async function() try var action = this.initAction(1003); var that = this; var result = await FeatureAbility.subscribeAbilityEvent(action,function (msgdata) console.info(" batteryLevel info is: " + msgdata); var msgRet = JSON.parse(msgdata).data; that.printData(msgRet.msg); that.showToast(" batteryState change: " + msgRet.msg); ); this.showToast(" subscribe result " + result); console.info(" subscribeCommonEvent result = " + result); catch (pluginError) console.error("subscribeCommonEvent error : result= " + result + JSON.stringify(pluginError)); ,onSend: async function() try var action = this.initAction2(1002,this.msg); var result = await FeatureAbility.callAbility(action); console.info("onSend result = " + result); this.showToast(result); catch (pluginError) console.error("getBatteryLevel : Plugin Error = " + pluginError); ,onChange4(e) this.msg = e.value; ,printData(msg) if(this.outcont != null || this.outcont != "") this.outcont = msg + "\\n" + this.outcont; else this.outcont = msg; ,showToast: function (msg) prompt.showToast( message: msg );

注意：
    1，这里的交互方法都是用的异步方法，因为这样不会因业务侧而阻塞UI线程，从而阻塞主线程。
    2，仔细看清楚每个initAction(),弄明白action的构造和带参传递的写法。
四、PA编写与交互java类实现方式如下：

public class TcpClientAbility extends AceInternalAbility private static final String TAG = TcpClientAbility.class.getSimpleName(); private static final String BUNDLE_NAME = "com.gane.tcpclient"; private static final String ABILITY_NAME = "TcpClientAbility"; public static final String SELF_SOCKET_MSG = "TCP.CLIENT.MSG"; private static TcpClientAbility instance; private TcpClientAbility() super(BUNDLE_NAME, ABILITY_NAME); /** * ACE注册 */ public void register() this.setInternalAbilityHandler(this::onRemoteRequest); HiLog.error(LABEL_LOG,"socket_register"); /** * ACE取消注册 */ public void deregister() this.setInternalAbilityHandler(null); HiLog.error(LABEL_LOG,"socket_unregister"); /** * ACE事件回调接口 */ public boolean onRemoteRequest(int code, MessageParcel data, MessageParcel reply, MessageOption option) switch (code) return true;

注意：
    1，类必须继承AceInternalAbility，必须实现注册、取消注册、事件回调接口。
    2，register()、deregister()需在合适的位置调用，我是在mainAblity的onstart和onstop中调用的
五、TCP客户端网络网络实现，考虑到要能随时随地的自由发送和接收消息，就将消息的收、发分离，全采用异步进行。根据业务需求选型了AsynchronousSocketChannel作为本次实现的网络基础类型，主要用到了AsynchronousSocketChannel.open()、AsynchronousSocketChannel.setOption()、AsynchronousSocketChannel.connect()、AsynchronousSocketChannel.write()、AsynchronousSocketChannel.read()等接口。
示例代码如下：

socketChannel = AsynchronousSocketChannel.open(); socketChannel.setOption(StandardSocketOptions.TCP_NODELAY,true); socketChannel.setOption(StandardSocketOptions.SO_REUSEADDR, true); socketChannel.connect(new InetSocketAddress(param.getIp(), param.getPort()), null, new CompletionHandler< Void, Object> () @Override public void completed(Void result, Object attachment) ByteBuffer byteBuffer = ByteBuffer.allocate(1024); String intput = "我是："; try intput = intput + socketChannel.getLocalAddress().toString(); catch (IOException e) e.printStackTrace(); try byteBuffer.put(intput.getBytes("UTF-8")); catch (UnsupportedEncodingException e) e.printStackTrace(); socketChannel.write(byteBuffer, 1, TimeUnit.SECONDS, null, new CompletionHandler< Integer, Object> () @Override public void completed(Integer result, Object attachment) public void failed(Throwable exc, Object attachment) ); @Override public void failed(Throwable exc, Object attachment) );

 

if (TcpClientAbility.socketChannel != null & & TcpClientAbility.socketChannel.isOpen()) ByteBuffer byteBuffer = ByteBuffer.allocate(1024); CompletionHandler< Integer, Object> comphandler = new CompletionHandler< Integer, Object> () @Override public void completed(Integer result, Object attachment) byteBuffer.flip(); byte[] byten = new byte[byteBuffer.limit()]; // 可用的字节数量 byteBuffer.get(byten, byteBuffer.position(), byteBuffer.limit()); String ret = new String(byten); TcpClientAbility.socketChannel.read(byteBuffer, -1, TimeUnit.SECONDS, null, this); @Override public void failed(Throwable exc, Object attachment) TcpClientAbility.socketChannel.read(byteBuffer, -1, TimeUnit.SECONDS, null, this); ; TcpClientAbility.socketChannel.read(byteBuffer, -1, TimeUnit.SECONDS, null, comphandler);

六、自定义事件由官方提供的CommonEventManager通用事件启发而来，官方提供了harmonyos系统提供了蓝牙、电池、时间、日期等等相关的通用事件，还提供了电池相关的Demo,具体介绍看官方文档。我这里拿CommonEventManager的CommonEventManager.subscribeCommonEvent()订阅事件、CommonEventManager.publishCommonEvent()发布事件给大家看下：

MatchingSkills matchingSkills = new MatchingSkills(); matchingSkills.addEvent(SELF_SOCKET_MSG); IRemoteObject notifier = data.readRemoteObject(); CommonEventSubscribeInfo subscribeInfo = new CommonEventSubscribeInfo(matchingSkills); subscriber = new CommonEventSubscriber(subscribeInfo) @Override public void onReceiveEvent(CommonEventData commonEventData) //HiLog.info(LABEL_LOG,"socket===shijian" + commonEventData.getData() + ret); ; try CommonEventManager.subscribeCommonEvent(subscriber); catch (RemoteException e)

Intent intent = new Intent(); Operation operation = new Intent.OperationBuilder().withAction(TcpClientAbility.SELF_SOCKET_MSG).build(); intent.setOperation(operation); intent.setParam("msg",ret); CommonEventData eventData = https://www.songbingjia.com/android/new CommonEventData(intent); eventData.setData(ret); try CommonEventManager.publishCommonEvent(eventData); catch (RemoteException e) e.printStackTrace();

七、总结大概思路和所用到的重点知识点在上面以分别列出来了，做完了觉得很简单，但实际上用一门或多门不怎么熟悉而且相关开发思路借鉴比较少的开发框架写东西时，确实会在动手前很迷茫。觉得迷茫不要退缩，还是那句话，没有程序解决不了的问题，只有没思路的程序员，只要想做，就要将整体拆解，化整为零，个个击破。
本文虽然实现了简单的多客户端自由聊天，但还有很多不足，如聊天记录保存，跳转页面后回来怎么恢复页面，websocket、UDP、HTTP、蓝牙等通信模式的探索实践等，不足之处后续有空继续探索不上。有啥不足之处欢迎大家留言，助我改进提升。
完整代码链接：https://harmonyos.51cto.com/resource/1567
想了解更多关于鸿蒙的内容，请访问：
51CTO和华为官方合作共建的鸿蒙技术社区
https://harmonyos.51cto.com/#bkwz
【#星光计划2.0#Harmonyos网络通信真机Demo演练之TCP聊天室】::: hljs-center

文章图片

:::

推荐阅读

• 

  前台辞职申请书
• 

  好听的网名简单干净女生 简单的网名 干净女生
• 

  送给男朋友的创意定制礼物
• 

  传统线上电商平台大卖家是什么
• 

  江阴西门子售后服务电话,西门子江阴特约维修电话
• 

  尼康D3100与D7000那个好 尼康d3100与d3200
• 

  React|React Native 在Mac控制台输出日志
• 

  蝙蝠的简笔画 蝙蝠的简笔画怎么画
• 

  秦始皇陵兵马俑的艺术特点
• 

  一般脚本用的哪种语言，脚本是用什么语言编译
• 

  拔牙|白天输液好转，夜晚高烧卷土重来：只因这个细节，60岁患者拔牙差点送了命
• 

  女生觉得多长就够了 怎么让阴茎变长
• 

  睡眠不足对身体有什么害处？
• 

  QQ截图快捷键怎么设置？QQ截屏快捷键如何修改？
• 

  王者荣耀,怎么根据当前局势英雄出装备？
• 

  机芯|伯爵手表偷停的原因
• 

  普通火车和高速上的汽车哪个快 普通火车和高速上的汽车哪个快一些
• 

  免洗手凝露可以托运吗 免洗手凝胶可以托运吗
• 

  python|python 中 lxml 的 etree 标签解析
• 

  陆行鸟的位置在什么地方 陆行鸟的相关知识

• 推荐学Java——Maven初识
• #yyds干货盘点#linux批量杀进程
• #yyds干货盘点#Windows Server之AD域控转移
• 第四周学习作业
• 当你开始向下滚动时，顶部标题图像会抖动/抽搐，为什么（ [关闭]）
• 在此服务器中的WordPress中找不到请求的URL（）
• 主题目录&#8221;Divi&#8221;不存在
• the_post_thumbnail返回超链接之外
• WP主题动作只勾一次函数