From 29b7c2afe5b63814e1cf9c450ff2265e539d6312 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AE=8B=E6=9D=B0?= Date: Tue, 28 Oct 2025 11:13:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=81=E8=A3=85=E4=BA=86=E4=BB=8A=E6=97=A5?= =?UTF-8?q?=E5=B8=82=E5=9C=BA=E6=A6=82=E8=A7=88tcp=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E7=9A=84=E6=96=B9=E6=B3=95=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/tcpConnection.js | 223 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 223 insertions(+) create mode 100644 api/tcpConnection.js diff --git a/api/tcpConnection.js b/api/tcpConnection.js new file mode 100644 index 0000000..6dcc539 --- /dev/null +++ b/api/tcpConnection.js @@ -0,0 +1,223 @@ +/** + * TCP连接工具类 + * 用于处理TCP连接、发送消息和断开连接 + */ + +// 引用TCP插件 +const TCPSocket = uni.requireNativePlugin('Aimer-TCPPlugin'); + +// TCP连接配置 +const TCP_CONFIG = { + ip: '192.168.1.9', + port: '8080', + channel: '1', // 可选 1~20 + charsetname: 'UTF-8' // 默认UTF-8，可选GBK +}; + +/** + * TCP连接管理类 + */ +class TCPConnection { + constructor() { + this.isConnected = false; + this.connectionCallbacks = []; + this.messageCallbacks = []; + } + + /** + * TCP初始化连接 + * @param {Object} config - 连接配置 {ip, port, channel, charsetname} + * @param {Function} callback - 连接状态回调函数 + */ + connect(config = {}, callback = null) { + const connectionConfig = { + channel: config.channel || TCP_CONFIG.channel, + ip: config.ip || TCP_CONFIG.ip, + port: config.port || TCP_CONFIG.port + }; + + // 如果指定了字符集，添加到配置中 + if (config.charsetname || TCP_CONFIG.charsetname) { + connectionConfig.charsetname = config.charsetname || TCP_CONFIG.charsetname; + } + + TCPSocket.connect( + connectionConfig, + result => { + /** + * status : 0 连接成功 + * status : 1 断开连接 + * receivedMsg : 服务器返回字符串(普通的字符串交互) + * receivedHexMsg : 服务器返回字节数组(单片机、智能家居等硬件数据交互) + */ + if (result.status == '0') { + // TCP连接成功 + this.isConnected = true; + console.log('TCP连接成功'); + this._notifyConnectionCallbacks('connected', result); + } else if (result.status == '1') { + // TCP断开连接 + this.isConnected = false; + console.log('TCP断开连接'); + this._notifyConnectionCallbacks('disconnected', result); + } + + if (result.receivedMsg) { + // 服务器返回字符串 + console.log('收到字符串消息:', result.receivedMsg); + this._notifyMessageCallbacks('string', result.receivedMsg); + } + + // if (result.receivedHexMsg) { + // // 硬件服务器返回16进制数据 + // console.log('收到16进制消息:', result.receivedHexMsg); + // let msg = result.receivedHexMsg; + // let sum = msg.length / 2; + // let arr = []; + // for (let k = 0; k < sum; k++) { + // let i = msg.substring(k * 2, k * 2 + 2); + // arr.push(i); + // } + // console.log('解析后的16进制数组:', arr); + // this._notifyMessageCallbacks('hex', result.receivedHexMsg, arr); + // } + + // 执行回调函数 + if (callback && typeof callback === 'function') { + callback(result); + } + } + ); + } + + /** + * TCP发送消息(普通的字符串交互) + * @param {String|Object} message - 要发送的消息，如果是对象会自动转换为JSON字符串 + * @param {Object} config - 发送配置 {channel, charsetname} + */ + send(message, config = {}) { + if (!this.isConnected) { + console.warn('TCP未连接，无法发送消息'); + return false; + } + + // 如果message是对象，转换为JSON字符串 + let messageStr = message; + if (typeof message === 'object') { + messageStr = JSON.stringify(message) + '\n'; + } + + const sendConfig = { + channel: config.channel || '1', // 注意：channel应该是字符串 + message: messageStr + }; + + // 如果指定了字符编码，添加到配置中 + if (config.charsetname) { + sendConfig.charsetname = config.charsetname; + } + + TCPSocket.send(sendConfig); + console.log('js成功发送TCP消息:', messageStr); + return true; + } + + /** + * TCP断开连接 + * @param {Object} config - 断开配置 {channel} + */ + disconnect(config = {}) { + const disconnectConfig = { + channel: config.channel || TCP_CONFIG.channel + }; + + TCPSocket.disconnect(disconnectConfig); + this.isConnected = false; + console.log('TCP连接已断开', disconnectConfig); + } + + /** + * 添加连接状态监听器 + * @param {Function} callback - 回调函数 (status, result) => {} + */ + onConnectionChange(callback) { + if (typeof callback === 'function') { + this.connectionCallbacks.push(callback); + } + } + + /** + * 添加消息监听器 + * @param {Function} callback - 回调函数 (type, message, parsedArray) => {} + */ + onMessage(callback) { + if (typeof callback === 'function') { + this.messageCallbacks.push(callback); + } + } + + /** + * 移除连接状态监听器 + * @param {Function} callback - 要移除的回调函数 + */ + removeConnectionListener(callback) { + const index = this.connectionCallbacks.indexOf(callback); + if (index > -1) { + this.connectionCallbacks.splice(index, 1); + } + } + + /** + * 移除消息监听器 + * @param {Function} callback - 要移除的回调函数 + */ + removeMessageListener(callback) { + const index = this.messageCallbacks.indexOf(callback); + if (index > -1) { + this.messageCallbacks.splice(index, 1); + } + } + + /** + * 获取连接状态 + * @returns {Boolean} 连接状态 + */ + getConnectionStatus() { + return this.isConnected; + } + + /** + * 通知连接状态回调 + * @private + */ + _notifyConnectionCallbacks(status, result) { + this.connectionCallbacks.forEach(callback => { + try { + callback(status, result); + } catch (error) { + console.error('连接状态回调执行错误:', error); + } + }); + } + + /** + * 通知消息回调 + * @private + */ + _notifyMessageCallbacks(type, message, parsedArray = null) { + this.messageCallbacks.forEach(callback => { + try { + callback(type, message, parsedArray); + } catch (error) { + console.error('消息回调执行错误:', error); + } + }); + } +} + +// 创建TCP连接实例 +const tcpConnection = new TCPConnection(); + +// 导出TCP连接实例和类 +export default tcpConnection; +export { TCPConnection, TCP_CONFIG }; \ No newline at end of file