harmony_car/subject-two
harmony_car/subject-two
4
0
Fork 3
Code Issues Pull Requests Packages Projects 1 Releases 45 Wiki Activity

tcp代理服务

Browse Source
This commit is contained in:
lixiao 2025-03-05 19:27:15 +08:00
parent f61665a59f
commit 69f22de4ff
5 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
entry/src/main/ets/IdlServiceExt/idl_service_ext_impl.ts
View File

@ -2,7 +2,7 @@ import IdlServiceExtStub from './idl_service_ext_stub';
import hilog from '@ohos.hilog'; import hilog from '@ohos.hilog';
import type { insertDataToMapCallback } from './i_idl_service_ext'; import type { insertDataToMapCallback } from './i_idl_service_ext';
import type { processDataCallback } from './i_idl_service_ext'; import type { processDataCallback } from './i_idl_service_ext';
import request from '../common/utils/request'; import request, { tcpRequest } from '../common/utils/request';
import pasteboard from '@ohos.pasteboard'; import pasteboard from '@ohos.pasteboard';
const ERR_OK = 0; const ERR_OK = 0;
@ -18,7 +18,7 @@ export default class ServiceExtImpl extends IdlServiceExtStub {
pasteboard.getSystemPasteboard().getData().then((res) => { pasteboard.getSystemPasteboard().getData().then((res) => {
let pasteData = res.getPrimaryText() let pasteData = res.getPrimaryText()
console.log("lixiao receive paste", pasteData) console.log("lixiao receive paste", pasteData)
request(JSON.parse(pasteData)).then(response => { tcpRequest(JSON.parse(pasteData)).then(response => {
console.log("lixiao success", JSON.stringify(response)) console.log("lixiao success", JSON.stringify(response))
callback(0, JSON.stringify({ callback(0, JSON.stringify({
code: 0, code: 0,

8
entry/src/main/ets/ServiceExtAbility/ServiceExtAbility.ets
View File

@ -2,7 +2,8 @@ import ServiceExtension from '@ohos.app.ability.ServiceExtensionAbility'
// import { ServiceExtensionAbility, Want } from '@kit.AbilityKit'; // import { ServiceExtensionAbility, Want } from '@kit.AbilityKit';
// import { rpc } from '@kit.IPCKit'; // import { rpc } from '@kit.IPCKit';
import hilog from '@ohos.hilog'; import hilog from '@ohos.hilog';
import { tcpUtil } from '../common/utils/TcpRequest';
import ServiceExtImpl from '../IdlServiceExt/idl_service_ext_impl'; import ServiceExtImpl from '../IdlServiceExt/idl_service_ext_impl';
const TAG: string = '[ServiceExtAbility]'; const TAG: string = '[ServiceExtAbility]';
@ -11,8 +12,9 @@ const DOMAIN_NUMBER: number = 0xFF00;
export default class ServiceExtAbility extends ServiceExtension { export default class ServiceExtAbility extends ServiceExtension {
serviceExtImpl: ServiceExtImpl = new ServiceExtImpl('ExtImpl', this.context); serviceExtImpl: ServiceExtImpl = new ServiceExtImpl('ExtImpl', this.context);
onCreate(want): void { async onCreate(want): Promise<void> {
// let serviceExtensionContext = this.context; // tcp创建连接
await tcpUtil.init()
hilog.info(DOMAIN_NUMBER, TAG, `js-test ServiceExtensionAbility-- onCreate, want: ${want.abilityName}`); hilog.info(DOMAIN_NUMBER, TAG, `js-test ServiceExtensionAbility-- onCreate, want: ${want.abilityName}`);
}; };

3
entry/src/main/ets/common/utils/TcpRequest.ts
View File

@ -181,7 +181,8 @@ class TcpUtils {
await this.socket.send({ data: "#$" }) await this.socket.send({ data: "#$" })
console.log(tag, 'send success') console.log(tag, 'send success')
} catch (err) { } catch (err) {
console.log("tcp request send failed", this.requestMap.get(key).url) console.log("tcp request send failed url:", this.requestMap.get(key).url)
console.log("tcp request send failed error:", JSON.stringify(err))
this.requestMap.get(key).reject({ this.requestMap.get(key).reject({
message: "tcp request send failed", message: "tcp request send failed",
code: 2300007 code: 2300007

2
entry/src/main/ets/common/utils/request.ts
View File

@ -5,7 +5,7 @@ import { tcpUtil } from './TcpRequest';
import Prompt from '@system.prompt'; import Prompt from '@system.prompt';
import tempRequest from './tempRequest'; import tempRequest from './tempRequest';
function tcpRequest<T>(req: any): Promise<T> { export function tcpRequest<T>(req: any): Promise<T> {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
let {url,params = {},data = {},xml,method = 'get',host,isNewCenter = false, timeout} = req; let {url,params = {},data = {},xml,method = 'get',host,isNewCenter = false, timeout} = req;
try { try {

3
entry/src/main/ets/entryability/EntryAbility.ets
View File

@ -77,7 +77,8 @@ export default class EntryAbility extends UIAbility {
// this.requestPermission(this.context) // this.requestPermission(this.context)
// this.featureAbilityAuth() // this.featureAbilityAuth()
TempLogger.init() TempLogger.init()
await tcpUtil.init() // tcp创建连接
// await tcpUtil.init()
const windowClass = await windowStage.getMainWindow(); const windowClass = await windowStage.getMainWindow();
globalThis.windowClass = windowClass globalThis.windowClass = windowClass