当前位置: 首页 > news >正文

周口网站建设费用贵金属如何用网站开发客户

周口网站建设费用,贵金属如何用网站开发客户,如何用网络营销推广,网站 用什么语言前言 服务端消息推送SSE是常用的服务器消息通信手段#xff0c;适用于服务器主动给客户端发送消息的场景#xff0c;例如私信通知#xff0c;扫描登录等都可以使用SSE实现。SSE的底层原理是客户端与服务端建立 HTTP 长链接。 Nestjs 框架内置了对SSE的支持#xff0c;本文…前言 服务端消息推送SSE是常用的服务器消息通信手段适用于服务器主动给客户端发送消息的场景例如私信通知扫描登录等都可以使用SSE实现。SSE的底层原理是客户端与服务端建立 HTTP 长链接。 Nestjs 框架内置了对SSE的支持本文详细介绍Nestjs服务端推送服务的实战步骤。 使用步骤 一、创建 SSE 接口服务 跟普通的 HTTP 方法相同在 nestjs/common 中引入 Sse 装饰器在处理服务器推送的方法上使用 See装饰器。 import { Controller, Param, Sse } from nestjs/common; import { ApiTags } from nestjs/swagger; import { Observable, interval, map } from rxjs;export interface MessageEvent {message: string; }Controller({ path: /admin/message }) export class AdminMessageController {Sse(sse)sendServerMessage(Param() params): ObservableMessageEvent {return interval(5000).pipe(map((_) ({ message: 你好乐闻 })));} }上面的程序目的是服务器每5s向客户端发送一次消息。 二、使用 Postman 调试服务端推送接口 由于SSE本质就是 HTTP 连接在Postman中使用get请求发起请求即可。 会发现每 5s收到一条「你好乐闻」的消息。 三、浏览器前端建立链接 SSE 是客户端和服务端之间的单向通行即服务端向客户端发送信息。客户端使用 EventSource 发送连接。 以 React 为例实现前端页面与服务端建立SSE连接。服务端推送过来的消息会触发 EventSource的 onmessage回调事件所以我们可以在 onmessage中自定义业务逻辑。 useEffect(() {const eventSource new EventSource(http://localhost:8822/admin/message/sse,);eventSource.onmessage ({ data }) {console.log(New message, JSON.parse(data));};}, []);当我触发了自定义消息推送接口后发现在浏览器的控制台可以看到日志输出 进阶使用 如何自定义推送的内容 由于 Nestjs 底层是依赖 rxjs 实现数据流Nest 的 SSE 方法返回的是 Observable ,在SSE服务长链接时希望在中途能够通知 Observable 返回不同的数据。 基于 rxjs的 Subject可以实现上述形式的数据推送。 安装相关依赖 npm install nestjs/event-emitternestjs 注册发布订阅模块 import { Module } from nestjs/common; import { EventEmitterModule } from nestjs/event-emitter;Module({imports: [EventEmitterModule.forRoot()], }) export class AppModule {}实现SSE自定义消息逻辑以及发送自定义内容 import { Controller, Inject, Get, Sse } from nestjs/common; import { ApiTags } from nestjs/swagger; import { EventEmitter2 } from nestjs/event-emitter; import { Observable, Subject, map } from rxjs;export interface MessageEventData {userId: number;message: Recordstring, string; }export interface MessageEvent {message: MessageEventData; }Controller({ path: /admin/message }) export class AdminMessageController {Inject(EventEmitter2)private readonly eventEmitterService: EventEmitter2;Sse(sse)sendServerEvent(): ObservableMessageEvent {const subject new Subject();// 监听CUSTOM_MESSAGE事件this.eventEmitterService.on(CUSTOM_MESSAGE, (data) {// subject 处理事件subject.next(data);});return subject.pipe(map((data: MessageEventData): MessageEvent ({ message: data })),);}// 发送自定义发送消息Get(send)emitMessage() {const messageEventData: MessageEventData {userId: 123456,message: { hi: 你好乐闻 },};// 发送 CUSTOM_MESSAGE 事件this.eventEmitterService.emit(CUSTOM_MESSAGE, messageEventData);} }Postman 调试效果 总结 服务端推送SSE在业务开发中经常使用到的通信手段Nestjs 是目前比较流行通用的node框架Nestjs 支持了SSE本文也大致介绍了使用步骤希望能够对有需要的同学有所帮助。
http://www.sadfv.cn/news/172312/

相关文章:

  • 个人网站 备案 名称营销策略ppt模板
  • 苏中建设集团网站官网建设银行招聘官网网站
  • 手机建网站模板动漫制作好找工作吗
  • dw制作网站网页模板ps网站怎么做超链接
  • 河南住房城乡建设部网站企业门户网站建设方案书
  • 中小学教师兼职做网站网络营销平台有哪些
  • 小企业网站建设多少钱苏州知名高端网站建设机构
  • 做外贸面料的网站隆昌移动网站建设
  • 专业网站设计报价黄山旅游攻略ppt
  • 做红k线网站网站关键字怎么分割
  • 建设设计院网站做网站加盟
  • php网站建设视频教程重庆网站开发工资
  • 深圳专业集团网站建设蓝杉互动网站建设
  • 做网站算经商吗武进建设银行网站首页
  • 行业网站名录wordpress安装插件502
  • 专业手机网站建设价格网站广告图片在线制作
  • 网站开发公司 logowordpress 无刷新分页
  • 在静安正规的设计公司网站怎么给自己的网站做模版
  • 上虞网站建设公司高端网站设计百家号
  • 做好网站建设对企业有什么作用网站开发项目企划书
  • 常州网站建设培训wordpress播放本地视频
  • 西安企业网站建设公司手机网站织梦模板
  • 做网站公司长沙学平面设计哪个学校好
  • 网站跟软件有什么区别是什么图片网站seo
  • 建设局网站安全自查情况报告建设厅网站装修合同模板
  • wordpress怎么不出付费阅读企业网站seo模板
  • 郑州市网站建设哪家公司好谷歌网页版登录入口
  • 家用电器销售的网站开发网站页面优化怎么做
  • 可以免费建手机网站wordpress 仿花瓣
  • 网站制作 电子商城杂多县网站建设公司