产品动态
export default function() { ... }），直到压测结束。ws.connect 方法阻塞，直到连接关闭。而在连接建立后的回调函数里（function (socket) {...}），会持续不断地监听和处理异步事件，直到压测结束。ws.connect 方法建立连接，并在其回调函数里定义您的业务逻辑：ws.connect 的必传参数为 URL 和回调函数。ws.Socket 对象传入回调函数。您可在回调函数里，定义您的 WebSocket 请求逻辑。ws.connect 会返回 ws.Response 对象。ws.Socket 对象的常用方法：send：发送文本消息。close：关闭连接。on：监听事件，并用回调函数处理事件。当前 PTS 支持的事件列表如下：事件名 | 事件用途 |
open | 建立连接 |
close | 关闭连接 |
error | 发生错误 |
message | 接收文本消息 |
binaryMessage | 接收二进制消息 |
pong | 接收 pong 消息 |
ping | 接收 ping 消息 |
import ws from 'pts/ws';import { check, sleep } from 'pts';export default function () {const res = ws.connect("ws://localhost:8080/echo", function (socket) {socket.on('open', () => console.log('connected'));socket.on('message', (data) => console.log('Message received: ', data));socket.on('close', () => console.log('disconnected'));socket.send("message");socket.setTimeout(function () {console.log('3 seconds passed, closing the socket');socket.close();}, 3000);socket.setInterval(function () {socket.ping();}, 500);socket.setLoop(function () {sleep(0.1)socket.send("loop message")});});check("status is 101", () => res.status === 101);}
文档反馈