# ocpp

**Repository Path**: freechful/ocpp

## Basic Information

- **Project Name**: ocpp
- **Description**: this is weixincloud ocpp
- **Primary Language**: Unknown
- **License**: AGPL-3.0
- **Default Branch**: master
- **Homepage**: https://gitee.com/freechful/ocpp
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2023-08-05
- **Last Updated**: 2024-02-01

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# WebSocket+HTTP服务端演示[Node.js+Express]

## 项目介绍

本项目为Node.js语言，使用[express-ws](https://www.npmjs.com/package/express-ws)完成了一个简单的websocket服务。

小程序可以向此服务发起ws连接，连接后将用户信息保存在本机中，可以通过另一个http接口查询当前连接的所有用户。

并且项目还针对同一个微信用户多次连接有限制，多次连接将被拒绝。

你可以参考此项目，结合自己的业务需求开发。

**需要注意，项目中用户信息保存直接保存在容器中，如果是多个容器则无法做到全局唯一性，建议正式项目将信息保存转移到公共的数据库或者存储中。**

## 项目部署

1. 将此项目作为文件夹上传到微信云托管建立服务，名称可以随意，在这里为`ws`。
2. 在小程序中页面js里，可以粘贴下面代码，注意修改环境ID以及服务名称

``` js
Page({
    async onLoad() {
        wx.cloud.init()
        await websocketTest(1)
        await websocketTest(2) // 故意多发起一次链接
    }
})

async function callcontainer() {
    const info = await wx.cloud.callContainer({
        config: {
            env: '微信云托管环境ID'
        },
        path: '/query',
        header: {
            "X-WX-SERVICE": 'ws', // 替换自己的服务名
            "content-type": 'application/json'
        },
        method: "POST"
    })
    return info.data
}

async function websocketTest(flag) {
    const { socketTask } = await wx.cloud.connectContainer({
        config: {
            env: '微信云托管环境ID',
        },
        service: 'ws', // 替换自己的服务名
        path: '/ws'
    })
    socketTask.onMessage(function (res) {
        console.log(flag, '【WEBSOCKET】', res.data)
    })
    socketTask.onOpen(async function (res) {
        console.log(flag,'【WEBSOCKET】', '链接成功！')
        console.log(flag,'当前链接',await callcontainer())
        socketTask.send({
            data: '这是小程序消息'
        })
    })
    socketTask.onClose(async function () {
        console.log(flag,'【WEBSOCKET】链接关闭！')
        console.log(flag,'当前链接',await callcontainer())
    })
    return socketTask
}
```

## 项目作者

- zirali