socketio.connect

最近更新时间:2024-06-24 11:46:11

我的收藏
socketio.connect 根据指定参数建立 socketio 连接,并执行用户定义的逻辑,返回 Response 对象。
connect(url: string, callback: (socketIO: SocketIO) => void, option?: Option): Response

参数

参数
类型
描述
url
string
请求连接的地址。
callback
function
回调函数,在完成连接后将 socketio 对象传入该回调函数,用户可以在该函数中定义请求逻辑。
option
Option
可选,配置参数。

返回

类型
描述
Response
object,包含 ws.connect 返回的响应结果。

样例

发起 socketio connect 请求。
import socketio from 'pts/socketio';
import { check, sleep } from 'pts';
import util from 'pts/util';

export default function () {
const res = socketio.connect('http://localhost:8080', function (socket) {
socket.on('open', () => console.log('connected'));
socket.on('message', (data) => console.log('message received: ', data));
socket.on('binaryMessage', (data) => console.log('binaryMessage received: ', data));
socket.on('close', () => console.log('disconnected'));
socket.on('error', (e) => console.log('error happened', e.error()));
socket.setTimeout(function () {
console.log('3 seconds passed, closing the socket');
socket.close();
}, 3000);
socket.setInterval(function () {
socket.emit('message', 'interval message');
socket.emit('binaryMessage', util.base64Decoding('aGVsbG8=', 'std', 'b'));
socket.emit('ackMessage', 'ack message', function (msg) {
console.log('received ackMessage: ', msg)
})
}, 500);
}, {
headers: {
token: 'VR23EQ2R',
},
transport: 'webscoket'
});
check('status is 200', () => res.status === 200);
};