提兵百万西湖上，立马吴山第一峰！这篇文章主要讲述#星光计划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
文章图片
:::
推荐阅读
- 推荐学Java——Maven初识
- #yyds干货盘点#linux批量杀进程
- #yyds干货盘点#Windows Server之AD域控转移
- 第四周学习作业
- 当你开始向下滚动时，顶部标题图像会抖动/抽搐，为什么（ [关闭]）
- 在此服务器中的WordPress中找不到请求的URL（）
- 主题目录”Divi”不存在
- the_post_thumbnail返回超链接之外
- WP主题动作只勾一次函数