Ionic WebSocket 使用

Ionic WebSocket 使用

Ionic WebSocket 使用

编写写一个工具类

import { Injectable } from '@angular/core';import { Observable } from "rxjs/Observable";import {observable} from "rxjs/symbol/observable"; @Injectable()export class WebSocketService { ws:WebSocket constructor(){ } createObservableSocket(url:string ):Observable{ this.ws = new WebSocket(url); return new Observable( observable =>{ this.ws.onmessage = (event)=> observable.next(event.data); this.ws.onerror = (event)=>observable.error(event); this.ws.onclose = (event)=>observable.complete(); } ) } sendMessage(message:string){ this.ws.send(message); }}

当然 rxjs 需要自己安装一下

npm install rxjs

如果是高版本的话可能会说找不到，需要改一下导入的包：

import { Observable} from 'rxjs';import {observable} from 'rxjs';

改完之后就没问题了应该。

组件中引用

import {WebSocketService} from "../service/websocket.service";

Component里配置

@Component({ selector: 'app-home', templateUrl: 'home.page.html', styleUrls: ['home.page.scss'], providers: [WebSocketService]})

constructor( private wsService:WebSocketService) {}

使用

连接接受消息

init(){ this.wsService.createObservableSocket('ws://121.40.165.18:8800').subscribe(rep =>{ console.log(rep) },error=>{ console.log("出错") }); console.log('已连接 ws://121.40.165.18:8800')}

发送消息

sendMessage(){ this.wsService.sendMessage("123")}

【重要说明】本文为本人的学习记录，论点和观点仅代表个人而不代表当时技术的真理，目的是自我学习和有幸成为可以向他人分享的经验，因此有错误会虚心接受改正，但不代表此刻博文无误！

​

【Gitee地址】秦浩铖：​​https://gitee.com/wjw1014​​

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。