鴻蒙嘗試（二）

環(huán)境和其它配置請看（一）

布局部分想到哪里寫到哪里了倦青。祭饭。芜茵。

1，Text 換行顯示

    ohos:multiple_lines="true"

2倡蝙，鴻蒙日志

HiLogLabel label = new HiLogLabel(HiLog.LOG_APP, 0x00201, "TAG");
HiLog.warn(label, "測試", url);

微信截圖_20210719113501.png

3九串，頁面跳轉(zhuǎn) 啟動和傳值

image.png

   Intent intent1 = new Intent();

            Operation operation = new Intent.OperationBuilder()
                    .withAction("action.pay")
                    .withDeviceId("1")
                    .withBundleName("xxx")
                    .withAbilityName("yyy")
                    .build();
            intent1.setOperation(operation);
            intent1.setParam("value", "10");
            present(new MainAbilitySlice(), intent1);

也可以啟動界面
ohos.samples.backgrounddownload 是包名。寺鸥。猪钮。。胆建。烤低。

 Intent intent = new Intent();
        Operation operation = new Intent.OperationBuilder().withDeviceId("")
            .withBundleName("ohos.samples.backgrounddownload")
            .withAbilityName("ohos.samples.backgrounddownload.AnotherAbility")
            .build();
        intent.setOperation(operation);
        startAbility(intent);

4,android 中handler 的使用，在鴻蒙里面EventHandler

private class EventHandler1 extends EventHandler {

        private EventHandler1(EventRunner runner) {
            super(runner);
        }

        @Override
        public void processEvent(InnerEvent event) {
            switch (event.eventId) {
                case 100:
                    /*獲取參數(shù)*/
                    Object object = event.object;
                    Object param = event.param;
                    getUITaskDispatcher().asyncDispatch(() ->{

                    });
                    break;
            }
        }
    }
private void initHandler() {
        EventHandler1 handler1 = new EventHandler1(EventRunner.create("EventHandler1"));
        /*普通發(fā)送*/
        handler1.sendEvent(100);
        InnerEvent normalInnerEvent = InnerEvent.get(EVENT_MESSAGE_NORMAL, 10, "hello");
        /*普通 選擇參數(shù)發(fā)送*/
        handler1.sendEvent(normalInnerEvent, EventHandler.Priority.IMMEDIATE);
        /*延時發(fā)送*/
        handler1.sendEvent(normalInnerEvent, 1000, EventHandler.Priority.IMMEDIATE);

        Runnable task1 = () -> {
            getUITaskDispatcher().asyncDispatch(() -> {
                resultText.setText(stringBuffer.toString());

            });
        };
        /*post 一個runable*/
        handler1.postTask(task1, EventHandler.Priority.IMMEDIATE);
        /*post 延時 發(fā)送一個runable*/
        handler1.postTask(task1, 1000, EventHandler.Priority.IMMEDIATE);

    }

5笆载，異步處理扑馁。
三種情況
1涯呻，globalTaskDispatcher.syncDispatch(() -> stringBuffer.append("Sync task1 run" + System.lineSeparator()));最常見
2，中有添加一個多少時間后處理檐蚜。

globalTaskDispatcher.delayDispatch(() -> {
            stringBuffer.append("DelayDispatch task1 run" + System.lineSeparator());
            final long actualDelayMs = System.currentTimeMillis() - callTime;
            stringBuffer.append("ActualDelayTime >= delayTime : " + (actualDelayMs >= DELAY_TIME));
            handler.postSyncTask(() -> resultText.setText(stringBuffer.toString()));
        }, DELAY_TIME);

 TaskDispatcher dispatcher = createParallelTaskDispatcher("", TaskPriority.DEFAULT);
 Group group = dispatcher.createDispatchGroup();

Group 的使用魄懂。這個可以有多個異步條件進行沿侈。

6闯第，線程池的使用
ThreadPoolExecutor

創(chuàng)建

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) {
        throw new RuntimeException("Stub!");
    }

傳入runable就可以了

private static ThreadPoolExecutor executor = new ThreadPoolExecutor(CORE_COUNT, THREAD_COUNT, KEEP_ALIVE,
        TimeUnit.SECONDS, new ArrayBlockingQueue<>(WORK_QUEUE_SIZE), new CommonThreadFactory());
 
    /**
     * Submit task to execute
     *
     * @param task runnable task
     */
    public static void submit(Runnable task) {
        executor.submit(task);
    }

7，網(wǎng)絡(luò)請求
官方請求方式

URL url = new URL(inputText.getText());
                URLConnection urlConnection = url.openConnection();
                if (urlConnection instanceof HttpURLConnection) {
                    HttpURLConnection connection = (HttpURLConnection)urlConnection;
                    connection.connect();
                    if (connection.getResponseCode() == HttpURLConnection.HTTP_OK) {
                        ImageSource.SourceOptions srcOpts = new ImageSource.SourceOptions();
                        ImageSource imageSource = ImageSource.create(connection.getInputStream(), srcOpts);
                        PixelMap pixelMap = imageSource.createPixelmap(null);
                        getUITaskDispatcher().syncDispatch(() -> image.setPixelMap(pixelMap));
                    }
                    connection.disconnect();
                }

這個需要線程里面進行缀拭。

這邊沒有真機咳短，測試機里面是華為內(nèi)部網(wǎng)絡(luò)。
鴻蒙里面多了一個HttpResponseCache蛛淋。
// 初始化時設(shè)置緩存目錄dir及最大緩存空間
HttpResponseCache.install(dir, 10 * 1024 * 1024);

// 訪問URL

// 為確保緩存保存到文件系統(tǒng)可以執(zhí)行flush操作
HttpResponseCache.getInstalled().flush();

// 結(jié)束時關(guān)閉緩存
HttpResponseCache.getInstalled().close();

8咙好，DatagramSocket 這個使用
通過Socket綁定來進行數(shù)據(jù)傳輸
發(fā)送

 private void netRequest(Component component) {
        ThreadPoolUtil.submit(() -> {
            NetManager netManager = NetManager.getInstance(null);
            if (!netManager.hasDefaultNet()) {
                return;
            }
            try (DatagramSocket socket = new DatagramSocket()) {
                NetHandle netHandle = netManager.getDefaultNet();
                InetAddress address = netHandle.getByName(inputText.getText());
                netHandle.bindSocket(socket);
                byte[] buffer = "I'm from Client".getBytes();
                DatagramPacket request = new DatagramPacket(buffer, buffer.length, address, PORT);
                socket.send(request);
            } catch (IOException e) {
                HiLog.error(LABEL_LOG, "%{public}s", "netRequest IOException");
            }
        });
    }

接受。是服務(wù)器端

private void startServer(Component component) {
        ThreadPoolUtil.submit(() -> {
            try (DatagramSocket socket = new DatagramSocket(PORT)) {
                DatagramPacket packet = new DatagramPacket(new byte[255], 255);
                while (true) {
                    socket.receive(packet);
                    getUITaskDispatcher().syncDispatch(() -> {
                        outText.setText(
                            "Receive a message from :" + packet.getAddress().getHostAddress() + System.lineSeparator()
                                + " on port " + packet.getPort() + System.lineSeparator() + "message :" + new String(
                                packet.getData()).substring(0, packet.getLength()));
                    });
                    packet.setLength(255);
                    Thread.sleep(1000);
                }
            } catch (IOException | InterruptedException e) {
                HiLog.error(LABEL_LOG, "%{public}s", "StartServer  IOException | InterruptedException");
            }
        });
    }

9褐荷，鴻蒙里面的服務(wù)勾效。這個和android 就不一樣了。叛甫。

基于 Service 模板的 Ability（以下簡稱 "Service"）主要用于后臺運行任務(wù)（如執(zhí)行音樂播放层宫、文件下載等），但不提供用戶交互界面其监。

Service 可由其他應(yīng)用或 Ability 啟動萌腿，即使用戶切換到其他應(yīng)用，Service 仍將在后臺繼續(xù)運行抖苦。
例如下載毁菱。
方式1.界面啟動了，后臺進行下載锌历，不耽誤你做任何事情贮庞。app 掛了，或界面關(guān)閉了究西，下載停止贸伐。
這種是AbilityConnection 連接，還不適于服務(wù)的一種吧怔揩。

public class DownloadServiceConnection implements IAbilityConnection {
 @Override
    public void onAbilityConnectDone(ElementName elementName, IRemoteObject iRemoteObject, int resultCode) {
        LogUtil.info(TAG, "on Ability Connect Done");
        sendHandlerMessage("service connect done");
        downloadServiceProxy = new DownloadServiceProxy(iRemoteObject);
    }
}
他會有兩個方法捉邢，連接成功和連接失敗兩個方法。
下載方法在代理里面進行

private class DownloadServiceProxy implements IRemoteBroker {
下載方法在這個里面進行

}

通過handle 進行消息發(fā)送商膊，在通過自己寫接口進行回調(diào)伏伐。

鴻蒙里面有個下載接口。還可以多下載進行晕拆。

方式2.
主app 切換其他app 不受影響藐翎。
啟動

 private void startLocalService(String bundleName, String serviceName) {
        Intent localServiceIntent = getLocalServiceIntent(bundleName, serviceName);
        startAbility(localServiceIntent);
    }

    private void startRemoteService(String bundleName, String serviceName) {
        Intent remoteServiceIntent = getRemoteServiceIntent(bundleName, serviceName);
        startAbility(remoteServiceIntent);
    }

    private Intent getLocalServiceIntent(String bundleName, String serviceName) {
        Operation operation = new Intent.OperationBuilder().withDeviceId("")
            .withBundleName(bundleName)
            .withAbilityName(serviceName)
            .build();
        Intent intent = new Intent();
        intent.setOperation(operation);
        return intent;
    }


/**
 * LocalServiceAbility
 */
public class LocalServiceAbility extends Ability {
    private static final String TAG = MainAbilitySlice.class.getSimpleName();
    private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD000F00, TAG);

    @Override
    public void onStart(Intent intent) {
        super.onStart(intent);
        HiLog.info(LABEL_LOG, "%{public}s",  "onStart");
        showTips(this, "LocalService onStart");
    }

    @Override
    public void onCommand(Intent intent, boolean restart, int startId) {
        super.onCommand(intent, restart, startId);
        HiLog.info(LABEL_LOG, "%{public}s",  "onCommand");
        showTips(this, "LocalService onCommand");
    }

    @Override
    public IRemoteObject onConnect(Intent intent) {
        showTips(LocalServiceAbility.this, "LocalService onConnect ");
        return new CurrentRemoteObject();
    }

    @Override
    public void onDisconnect(Intent intent) {
        super.onDisconnect(intent);
        showTips(LocalServiceAbility.this, "LocalService onDisconnect ");
    }

    @Override
    public void onStop() {
        super.onStop();
        showTips(this, "LocalService onStop");
    }

    private class CurrentRemoteObject extends RemoteObject {
        private CurrentRemoteObject() {
            super("CurrentRemoteObject");
        }

        @Override
        public boolean onRemoteRequest(int code, MessageParcel data, MessageParcel reply, MessageOption option) {
            HiLog.info(LABEL_LOG, "%{public}s",  "onRemoteRequest ");
            return true;
        }
    }

    private void showTips(Context context, String msg) {
        new ToastDialog(context).setText(msg).show();
    }
}

獲取

   private IAbilityConnection connection = new IAbilityConnection() {
        @Override
        public void onAbilityConnectDone(ElementName elementName, IRemoteObject iRemoteObject, int resultCode) {
            HiLog.info(LABEL_LOG, "%{public}s", "onAbilityConnectDone resultCode : " + resultCode);
            eventHandler.sendEvent(EVENT_ABILITY_CONNECT_DONE);
            RemoteAgentProxy remoteAgentProxy = new RemoteAgentProxy(iRemoteObject);
            try {
                remoteAgentProxy.setRemoteObject("This param from client");
            } catch (RemoteException e) {
                HiLog.error(LABEL_LOG, "%{public}s", "onAbilityConnectDone RemoteException");
            }
        }

        @Override
        public void onAbilityDisconnectDone(ElementName elementName, int resultCode) {
            HiLog.info(LABEL_LOG, "%{public}s", "onAbilityDisconnectDone resultCode : " + resultCode);
            eventHandler.sendEvent(EVENT_ABILITY_DISCONNECT_DONE);
        }
    };

eventHandler這里顯得就很重要了材蹬。

server需要配置cofig中配置

"abilities": [         
               {    
                   "name": ".ServiceAbility",
                   "type": "service",
                   "visible": true
                   ...
               }
           ]

toast 的使用
new ToastDialog(context).setText(msg).show();

11，也需要權(quán)限申請

private void requestPermission() {
        if (verifySelfPermission(SystemPermission.DISTRIBUTED_DATASYNC) != IBundleManager.PERMISSION_GRANTED) {
            requestPermissionsFromUser(new String[] {SystemPermission.DISTRIBUTED_DATASYNC}, 0);
        }
    }

    @Override
    public void onRequestPermissionsFromUserResult(int requestCode, String[] permissions, int[] grantResults) {
        if (permissions == null || permissions.length == 0 || grantResults == null || grantResults.length == 0) {
            return;
        }
        if (requestCode == 0) {
            if (grantResults[0] == IBundleManager.PERMISSION_DENIED) {
                terminateAbility();
            }
        }
    }

幾種現(xiàn)象吝镣，demo有時候連接不到虛擬機堤器，有時候點擊沒有反應(yīng)。身邊沒有真測試機用末贾。需要重新連接闸溃。需要模擬器，還得實名認(rèn)證拱撵。當(dāng)然打包也需要在華為后臺配置和下載簽名辉川。。拴测。這個就麻煩了乓旗。

鴻蒙嘗試（二）

布局部分 想到哪里寫到哪里了倦青。祭饭。芜茵。

布局部分想到哪里寫到哪里了倦青。祭饭。芜茵。