基于uni-app和Node.js实现app更新功能

npm install express cors

// app更新
const express = require('express'); // 导入 express 模块
const cors = require('cors'); // 导入 cors 模块，用于处理跨域请求
const fs = require('node:fs'); // node内置模块，用于文件系统操作。
const path = require('node:path');//node内置模块，用于处理文件路径。

const app = express(); // 创建 express 应用实例。

app.use(cors()); // 使用 cors 中间件解决跨越请求。

// 配置静态文件服务，使得/public路径下的文件可以直接访问，如果没有请手动创建。
app.use('/public', express.static(path.join(__dirname, 'public')));

// 存放app版本的文件夹，如果没有请手动创建。
const appdir = path.join(__dirname, 'public/apps');

// 服务器的地址 类似于：http://localhost:3000
let serveraddress = ''

/**
 * 根据客户端提供的版本号检查是否有新版本。
 */
app.get('/checkforupdate/:version', async (req, res) => {

  // uniapp当前版本号
  const appcurrentversion = req.params.version
  // uniapp最新版本号
  let applatestversion = ''

  try {
    // 读取存放app目录下的所有文件
    const files = fs.readdirsync(appdir);

    // 过滤出以app开头的文件
    const appfiles = files.filter(file => path.basename(file).startswith('app'));

    // 对文件列表进行排序，按照版本号从小到大排序
    const sortedfiles = appfiles.sort((a, b) => {
      const aparts = a.split('.').map(number);
      const bparts = b.split('.').map(number);

      for (let i = 0; i < math.max(aparts.length, bparts.length); i++) {
        if (aparts[i] > bparts[i]) return 1;
        if (aparts[i] < bparts[i]) return -1;
      }

      return 0;
    });

    // 数组中最后一项版本就是最大最新的版本
    applatestversion = sortedfiles.pop()

    // 再对当前文件进行处理 ,将 app1.0.3.wgt => '1.0.3'
    applatestversion = applatestversion.replace(/^app/, '').replace(/\.wgt$/, '')

  } catch (error) {
    throw new error('error reading public directory:' + error)
  }

  // 如果请求的版本小于最新版本，则提供下载链接
  if (applatestversion > appcurrentversion) {
    res.send({
      version: applatestversion, // 当前最新版本
      url: `${serveraddress}/downloadapp/${applatestversion}`, // 更新下载地址
      update: true, // 是否更新
      mandatoryupdate:true // 强制更新
    })
  } else {
    res.send({
      version: '',
      url: '',
      update: false,
      mandatoryupdate:false
    })
  }
})

/**
 * 提供文件下载
 */
app.get('/downloadapp/:version', async (req, res) => {
  // 要下载的 app 版本号
  const version = req.params.version
  const appname = `app${version}.wgt`
  // app 存放路径
  const appfilepath = `${appdir}/${appname}`

  // 检查文件是否存在
  fs.stat(appfilepath, (err, stats) => {
    if (err) {
      throw new error(`未找到 app${version}版本下载地址`)
    }

    // 设置响应头
    // 指示浏览器以下载的方式处理文件，并设置文件名。
    res.setheader('content-disposition', `attachment; filename=${appname}`);
    // 表示文件类型未知或二进制文件。
    res.setheader('content-type', 'application/octet-stream');

    // 创建文件流
    const filestream = fs.createreadstream(appfilepath);

    // 当文件流结束时，关闭响应
    filestream.on('end', () => {
      console.log('file download completed.');
    });

    // 如果发生错误，处理错误
    filestream.on('error', (error) => {
      throw new error('error downloading the file.:' + error)
    });

    // 将文件流管道发送到客户端
    filestream.pipe(res);
  });
})

const port = 3000; // 设置应用监听的端口号
// 启动服务器并监听端口
const server = app.listen(port, () => {
  // 获取服务器绑定的地址信息
  const addressinfo = server.address();
  const host = addressinfo.address === '::' ? 'localhost' : addressinfo.address;
  const port = addressinfo.port;
  serveraddress = `http://${host}:${port}`
  console.log(`server is running at http://${host}:${port}`);
});

node server.js

<template>
	<text class="title" style="text-align: center;">
		当前app资源版本为：{{appwgtversion}}
	</text>
</template>

<script setup>
import { ref } from 'vue'
import { onload } from '@dcloudio/uni-app'
const appwgtversion = ref('')

// 在页面加载时调用checkforupdate方法检查是否有新版本。
onload(() => {
	checkforupdate()
})

/**
 * 检查是否需要更新app
 */
function checkforupdate() {
	// 只在 app 中才会执行以下代码
	// #ifdef app-plus
	// 获取手机系统信息
	const systeminfo = uni.getsysteminfosync()
	// 获取到 app 资源包版本
	appwgtversion.value = systeminfo.appwgtversion
	// 向 node.js 后端发送请求检查是否需要更新
	uni.request({
		url: 'http://192.168.43.245:3000/checkforupdate/' + appwgtversion.value,
		success: (res) => {
			console.log('request-res', res);
			if (res.data && res.data.update) {
				uni.showmodal({
					title: '新版本发布',
					content: '检查到当前有新版本,需要更新吗？',
					showcancel: true,
					confirmtext: '立即更新',
					canceltext: '暂不更新',
					// 接口调用成功
					success: (modalres) => {
						if (modalres.confirm) {
							// 立即更新app操作
							uni.showloading({
								title: '正在下载'
							})
							console.log('res.data.url',res.data.url);
							// 开始下载任务
							const downloadtask = uni.downloadfile({
								url: res.data.url,
								success: (downloadres) => {
									if (downloadres.statuscode === 200) {
										uni.showloading({
											title: '正在安装更新...'
										});
										plus.runtime.install(downloadres.tempfilepath, {
											force: true
										}, () => {
											console.log('install success...');
											uni.hideloading()
											plus.runtime.restart();
										}, (e) => {
											console.log('install fail...', e);
											uni.hideloading()
											uni.showtoast({
												title: '安装失败:' + json.stringify(e),
												icon: 'fail',
												duration: 1500
											});
										});
										settimeout(() => {
											uni.hideloading();
											uni.showtoast({
												title: '安装成功！',
												icon: 'none'
											});
										}, 3000);
									}
								},
								// 接口调用失败
								fail: (fail) => {
									console.log('网络错误，下载失败！', fail);
									uni.hideloading();
								},
								// 接口调用结束
								complete: () => {
									console.log('----------------complete----------------:', downloadtask)
									downloadtask.offprogressupdate(); //取消监听加载进度
								}
							});
							//监听下载进度
							downloadtask.onprogressupdate(res => {
								// console.log('下载进度百分比:' + res.progress); // 下载进度百分比
								// console.log('已经下载的数据长度:' + res.totalbyteswritten); // 已经下载的数据长度，单位 bytes
								// console.log('预期需要下载的数据总长度:' + res.totalbytesexpectedtowrite); // 预期需要下载的数据总长度，单位 bytes
							});
						} else {
							// 暂不更新app操作
							// 如果是你的发布需要强制更新的话,不更新app可以直接退出 app 不让使用
							if(res.data.mandatoryupdate){
								if (systeminfo.platform === 'android') {
									// 安卓退出app
									plus.runtime.quit();
								} else {
									// 判断为ios的手机，退出app
									plus.ios.import("uiapplication").sharedapplication().performselector("exit");
								}
							}
						}
					}
				});
			}
		},
		fail: (fail) => {
			console.log('检查更新请求失败！', fail);
		}
	});
	// #endif
}
</script>