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

.NET 8 API 实现websocket，并在前端angular实现调用

news 来源：原创 2025/7/21 3:53:19

.NET 8 API 实现websocket，并在前端angular实现调用。

后端：.NET 8 WebSocket API 实现

在 .NET 8 中，可以通过 Microsoft.AspNetCore.WebSockets 提供的支持来实现 WebSocket 功能。以下是创建一个简单的 WebSocket 控制器的步骤。

安装必要的 NuGet 包
需要确保项目已启用 WebSocket 支持。如果尚未配置，请在项目的依赖项中添加以下包：

dotnet add package Microsoft.AspNetCore.WebSockets

配置中间件支持 WebSocket
在 Program.cs 文件中注册并启用 WebSocket 中间件：

using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.DependencyInjection;var builder = WebApplication.CreateBuilder(args);// 添加服务到容器
builder.Services.AddHttpContextAccessor();
builder.Services.AddControllers();var app = builder.Build();app.Use(async (context, next) =>
{if (context.Request.Path == "/ws") // 设置 WebSocket 终结点路径{if (context.WebSockets.IsWebSocketRequest){using var webSocket = await context.WebSockets.AcceptWebSocketAsync();await HandleWebSocketConnection(webSocket);}else{context.Response.StatusCode = StatusCodes.Status400BadRequest;}}else{await next(context);}
});app.MapControllers();
app.Run();static async Task HandleWebSocketConnection(System.Net.WebSockets.WebSocket socket)
{var buffer = new byte[1024 * 4];WebSocketReceiveResult result = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);while (!result.CloseStatus.HasValue){Console.WriteLine($"Received message: {System.Text.Encoding.UTF8.GetString(buffer)}");await socket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, CancellationToken.None);result = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);}await socket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
}

上述代码实现了基本的 WebSocket 连接逻辑5。它监听 /ws 路径上的请求，并允许客户端通过 WebSocket 协议与其交互。

前端：Angular WebSocket 服务实现

为了在前端调用后端的 WebSocket 接口，可以基于前面提到的 Angular WebSocket 服务模板进行扩展。

创建 WebSocket 服务
创建一个新的服务文件 websocket.service.ts，用于管理 WebSocket 连接和消息传递。

import { Injectable } from '@angular/core';
import { Observable, Subject } from 'rxjs';@Injectable({providedIn: 'root'
})
export class WebsocketService {private socket: WebSocket | null = null;private subject$: Subject<string> = new Subject<string>();constructor() {}public connect(url: string): void {this.socket?.close();this.subject$ = new Subject<string>();this.socket = new WebSocket(url);this.socket.onopen = () => {console.log('WebSocket connection established');};this.socket.onerror = (error) => {console.error('WebSocket error:', error);};this.socket.onmessage = (event) => {this.subject$.next(event.data);};this.socket.onclose = () => {console.warn('WebSocket connection closed');this.subject$.complete();};}public sendMessage(message: string): void {if (this.socket && this.socket.readyState === WebSocket.OPEN) {this.socket.send(message);}}public getMessages(): Observable<string> {return this.subject$.asObservable();}public close(): void {if (this.socket) {this.socket.close();}}
}

此服务提供了连接、发送消息以及接收消息的功能6。

组件中使用 WebSocket 服务
下面是一个简单示例，展示如何在 Angular 组件中初始化 WebSocket 并收发消息。

import { Component, OnInit, OnDestroy } from '@angular/core';
import { WebsocketService } from './websocket.service';@Component({selector: 'app-root',template: `<h1>WebSocket Example</h1><button (click)="sendMessage()">Send Message</button><ul><li *ngFor="let msg of messages">{{msg}}</li></ul>`,styleUrls: ['./app.component.css']
})
export class AppComponent implements OnInit, OnDestroy {messages: string[] = [];constructor(private wsService: WebsocketService) {}ngOnInit(): void {this.wsService.connect('ws://localhost:5000/ws'); // 替换为实际的 URLthis.wsService.getMessages().subscribe((msg) => {this.messages.push(msg);});}ngOnDestroy(): void {this.wsService.close();}sendMessage(): void {this.wsService.sendMessage('Hello from client!');}
}

以上代码展示了如何启动 WebSocket 连接，在按钮点击时向服务器发送消息，并实时更新页面显示收到的消息列表7。

数据流说明

整个流程涉及以下几个部分的数据流动：

客户端发起 WebSocket 请求至指定终结点。
服务器接受请求并建立双向通信通道。
双方可通过此通道自由交换 JSON 字符串或其他二进制数据形式的信息8。

.NET 8 API 实现websocket，并在前端angular实现调用

.NET 8 API 实现websocket，并在前端angular实现调用。后端：.NET 8 WebSocket API 实现在 .NET 8 中，可以通过 Microsoft.AspNetCore.WebSockets 提供的支持来实现 WebSocket 功能。以下是创建一个简单的 WebSocket 控制器的步骤。安装必…...

编程日记 2025/7/21 3:53:19

P2P架构

P2P 是 Peer-to-Peer（点对点） 的缩写，是一种去中心化的网络架构，其中每个节点（称为 “对等节点”，Peer）既是 “客户端”，也是 “服务器”，可以直接与其他节点通信、共享…...

编程日记 2025/7/21 3:50:58

菊厂0510面试手撕题目解答

题目输入一个整数数组，返回该数组中最小差出现的次数。示例1：输入：[1,3,7,5,9,12]，输出：4，最小差为2，共出现4次； 示例2：输入：[90,98,90,90,1,1]&#xf…...

编程日记 2025/7/20 18:38:42

【25软考网工】第六章（4）VPN虚拟专用网 L2TP、PPTP、PPP认证方式；IPSec、GRE

博客主页：christine-rr-CSDN博客专栏主页：软考中级网络工程师笔记大家好，我是christine-rr !目前《软考中级网络工程师》专栏已经更新二十多篇文章了，每篇笔记都包含详细的知识点，希望能帮助到你&#xff01…...

编程日记 2025/7/21 3:41:06

C语言：深入理解指针（3）

目录一、数组名的理解二、用指针访问数组三、一维数组传参的本质四、冒泡排序五、二级指针六、指针数组七、指针数组模拟二维数组八、结语一、数组名的理解数组名其实就是首元素的地址 int arr[3] {1,2,3}; printf("arr :%p\n" ,arr); printf(…...

编程日记 2025/7/21 0:28:43

R语言实战第5章（1）

第一部分：数学、统计和字符处理函数数学和统计函数：R提供了丰富的数学和统计函数，用于执行各种计算和分析。这些函数可以帮助用户快速完成复杂的数学运算、统计分析等任务，例如计算均值、方差、相关系数、进行假设检验等。字符处…...

编程日记 2025/7/18 22:47:31

Lodash isEqual 方法源码实现分析

Lodash isEqual 方法源码实现分析 Lodash 的 isEqual 方法用于执行两个值的深度比较，以确定它们是否相等。这个方法能够处理各种 JavaScript 数据类型，包括基本类型、对象、数组、正则表达式、日期对象等，并且能够正确处理循环引用。 1. is…...

编程日记 2025/7/21 3:25:17

探索边缘计算：赋能物联网的未来

摘要随着物联网（IoT）技术的飞速发展，越来越多的设备接入网络，产生了海量的数据。传统的云计算模式在处理这些数据时面临着延迟高、带宽不足等问题，而边缘计算的出现为解决这些问题提供了新的思路。本文将深入探讨边缘…...

编程日记 2025/7/20 1:37:41

Ubuntu中配置【Rust 镜像源】

本篇主要记录Ubuntu中配置Rust编程环境时，所需要做的镜像源相关的配置无法下载 Rust 工具链通过环境变量指定 Rust 的国内镜像源（如中科大或清华源）。方法一：临时设置镜像 export RUSTUP_DIST_SERVERhttps://mirrors.ustc.e…...

编程日记 2025/7/21 0:27:53

netty 客户端发送消息服务端收到消息无法打印，springBoot配合 lombok使用@Slf4j

netty 客户端发送消息服务端收到消息无法打印，springBoot配合 lombok使用Slf4j 服务端代码 Slf4j public class EventLoopServer {public static void main(String[] args) throws InterruptedException {new ServerBootstrap().group(new NioEventLoopGroup()).c…...

编程日记 2025/7/20 23:42:36

学习笔记：黑马程序员JavaWeb开发教程(2025.4.3)

12.1 基础登录功能 EmpService中的login方法，是根据接收到的用户名和密码，查询时emp数据库中的员工信息，会返回一个员工对象。使用了三元运算符来写返回 Login是登录，是一个业务方法，mapper接口是持久层，是…...

编程日记 2025/7/21 3:44:26

Spark SQL 运行架构详解（专业解释+番茄炒蛋例子解读）

1. 整体架构概览 Spark SQL的运行过程可以想象成一个"SQL查询的加工流水线"，从原始SQL语句开始，经过多个阶段的处理和优化，最终变成分布式计算任务执行。主要流程如下： SQL Query → 解析 → 逻辑计划 → 优化 → 物理…...

编程日记 2025/7/20 14:02:03

【时时三省】(C语言基础)字符数组的输入输出

山不在高，有仙则名。水不在深，有龙则灵。 ----CSDN 时时三省字符数组的输入输出可以有两种方法。 ( 1 )逐个字符输入输出。用格式符“% c”输入或输出一个字符. ( 2 )将整个字符串一次输入或输出。用“% s”格式符，意思是对字符串( strin…...

编程日记 2025/7/21 3:24:11

Hive HA配置高可用

Hive的高可用性（HA）通过消除关键组件的单点故障来实现，确保系统在部分故障时仍能正常运行。其基本原理涉及以下核心组件和策略： ‌1. Hive Metastore 的高可用‌ ‌ 多实例部署‌：部署多个Metastore服务实例，每个实例连接到共享的后端数据库（如MySQL、PostgreSQ…...

编程日记 2025/7/21 3:34:41

Python爬虫第20节-使用 Selenium 爬取小米商城空调商品

目录前言一、本文目标二、环境准备 2.1 安装依赖 2.2 配置 ChromeDriver 三、小米商城页面结构分析 3.1 商品列表结构 3.2 分页结构四、Selenium 自动化爬虫实现 4.1 脚本整体结构 4.2 代码实现五、关键技术详解 5.1 Selenium 启动与配置 5.2 页面等待与异…...

编程日记 2025/7/21 3:42:10

重构金融数智化产业版图：中电金信“链主”之道

近日，《商学院》杂志独家专访了中电金信常务副总经理（主持经营工作）冯明刚，围绕“金融科技”“数字底座”“架构转型”“AI驱动”等议题，展开了一场关于未来架构、技术变革与系统创新的深入对话。当下，数字…...

编程日记 2025/7/21 3:27:29

笔记本电脑升级实战手册【扩展篇1】：flash id查询硬盘颗粒

文章目录前言：一、硬盘颗粒介绍1、MLC（Multi-Level Cell）2、TLC（Triple-Level Cell）3、QLC（Quad-Level Cell） 二、硬盘与主控1、主控介绍2、主流主控厂家三、硬盘颗粒查询使用flash id工具查…...

编程日记 2025/7/20 13:34:16

文档外发安全：企业数据防护的最后一道防线

在当今数字化时代，数据已成为企业最宝贵的资产之一。随着网络安全威胁日益增多，企业安装专业加密软件已从"可选"变为"必选"。本文将全面分析企业部署华途加密解决方案后获得的各项战略优势。一、数据安全防护升级核心数据全面保护…...

编程日记 2025/7/21 1:31:31

springboot集成langchain4j实现票务助手实战

前言看此篇的前置知识为langchain4j整合springboot，以及springboot集成langchain4j记忆对话。 Function-Calls介绍 langchain4j 中的 Function Calls（函数调用）是一种让大语言模型（LLM）与外部工具（如 A…...

编程日记 2025/7/20 23:52:23

ZYNQ笔记（二十一）： VDMA HDMI 彩条显示

版本：Vivado2020.2（Vitis） 任务：实现驱动 HDMI 显示彩条图像，同时支持输出给 HDMI 的图像分辨率可调。目录一、介绍二、硬件设计 （1）DVI_Transmitter （2）Clockin…...

编程日记 2025/7/21 3:30:33

常用的maven插件及其使用指南

目录 1.maven官方插件列表2.两种方式调用maven插件3.常用的maven插件总结参考文献 1.maven官方插件列表 groupId为org.apache.maven.pluginshttp://maven.apache.org/plugins/index.html 2.两种方式调用maven插件将插件目标与生命周期阶段绑定，例如maven默认将m…...

编程日记 2025/7/21 1:08:40

Meilisearch 安装

1.环境 rockey linux 9.2 meilisearch-linux-amd64 2.下载访问：https://github.com/meilisearch/meilisearch/releases 下载适合自己系统版本的。注意：我下载的不是最新版本的，因为最新版本的需要GLIBC2.35，我本地系统的是…...

编程日记 2025/7/20 6:01:53

用postman的时候如何区分服务器还是自己的问题？

作为测试人员，在使用Postman进行接口测试时，准确判断问题是出在服务器端还是本地环境非常重要。以下是一些实用的区分方法： 1. 基础检查方法本地问题排查清单： ✅ 检查网络连接是否正常 ✅ 确认Postman版本是否为最新 ✅ 验证请求URL是否正确（特别是环境变量是否被正确…...

编程日记 2025/7/16 7:50:14

【Python算法】最长递增子序列

题目链接方法1： 记忆化搜索 class Solution:def lengthOfLIS(self, nums: List[int]) -> int:cachedef dfs(i):res0 for j in range(i):if nums[j]<nums[i]:res max(res,dfs(j))return res1 # 返回res表示以nums[i]结尾的LIS长度return max(dfs(i) for i…...

编程日记 2025/7/20 7:20:40

springboot-web基础

21.web spring MVC 基于浏览器的 B/S 结构应用十分流行。Spring Boot 非常适合 Web 应用开发。可以使用嵌入式 Tomcat、Jetty、 Undertow 或 Netty 创建一个自包含的 HTTP 服务器。一个 Spring Boot 的 Web 应用能够自己独立运行，不依赖需要安装的 Tomcat&#x…...

编程日记 2025/7/17 22:42:07

解构赋值

【系统学习ES6】本专题旨在对ES6的常用技术点进行系统性梳理，帮助大家对其有更好的掌握，希望大家有所收获。 ES6允许按照一定模式，从数组和对象中提取值，对变量进行赋值，这被称为解构。解构是一种打破数据结构&#x…...

编程日记 2025/7/16 12:14:27

Leetcode-BFS问题

LeetCode-BFS问题 1.Floodfill问题 1.图像渲染问题 [https://leetcode.cn/problems/flood-fill/description/](https://leetcode.cn/problems/flood-fill/description/) class Solution {public int[][] floodFill(int[][] image, int sr, int sc, int color) {//可以借助另一…...

编程日记 2025/7/15 7:34:11

AI 时代 UI 设计的未来范式

在人工智能技术持续突破的浪潮下，UI 设计领域正经历着前所未有的变革。AI 的深度介入不仅重塑了设计流程，更催生了全新的设计范式，为用户带来颠覆式的交互体验。探索 AI 时代 UI 设计的未来范式，是把握行业发展趋势的关键所在。…...

编程日记 2025/7/21 0:20:03

键盘输出希腊字符方法

在不同操作系统中，输出希腊字母的方法有所不同。以下是针对 Windows 和 macOS 系统的详细方法，以及一些通用技巧： 1.Windows 系统 1.1 使用字符映射表字符映射表是一个内置工具，可以方便地找到并插入希腊字母。 • 步骤&#xf…...

编程日记 2025/7/20 23:57:51

[数据结构高阶]并查集初识、手撕、可以解决哪类问题？

标题：[数据结构高阶]并查集初识、手撕、可以解决哪类问题？ 水墨不写bug 文章目录一、认识并查集二、模拟实现并查集三、用并查集解决问题1、[省份的数量](https://leetcode.cn/problems/number-of-provinces/)2、[等式方程的可满足性](https://leetcode…...

编程日记 2025/7/19 10:40:21

BUUCTF——PYWebsite

BUUCTF——PYWebsite 进入靶场看看基本信息没有什么信息扫个目录看看 http://node5.buuoj.cn:28115/.DS_Store http://node5.buuoj.cn:28115/flag.php http://node5.buuoj.cn:28115/index.html访问flag.php 提示保存购买者的IP 抓包看看直接XFF伪造一下 X-Forwarded-F…...

编程日记 2025/7/19 6:39:32

【学习笔记】机器学习(Machine Learning) | 第六章(2)| 过拟合问题

机器学习（Machine Learning） 简要声明基于吴恩达教授(Andrew Ng)课程视频 BiliBili课程资源文章目录机器学习（Machine Learning）简要声明解决过拟合问题一、收集更多训练数据二、选择特征三、正则化四、过拟合解决方法总结过…...

编程日记 2025/7/15 22:11:45

单片机-STM32部分：13-1、编码器

飞书文档https://x509p6c8to.feishu.cn/wiki/BpEywhaX9iqbiLkdqdAcmDnwnab EC旋转编码器在产品开发过程中，需要位置闭环的的产品，类似电机类产品来说，编码器至关重要，它不仅可以使我们对带年纪进行精确的速度闭环，位…...

编程日记 2025/7/21 0:42:05

浅谈大语言模型原理

1.反向传播算法背景反向传播算法是当前深度学习的核心技术。神经网络 x是输入，o是输出，w是需要训练的参数（w有初始值）三层全连接的神经网络：输入层、隐藏层、输出层激活函数 f ( x ) 1 1 x − 1 f(x)\frac…...

编程日记 2025/7/19 16:18:46

设计模式之中介者模式

在我们实际开发中，我们经常会遇到多个对象之间互相依赖、互相调用的场景。如果这些对象之间的耦合度太高，不仅会让系统变得难以维护，还会让扩展变得异常困难。此时，中介者模式(Mediatro)就是一种非常实用的设计方案，它…...

编程日记 2025/7/18 15:55:08

Matlab 空调温度时延模型的模糊pid控制

1、内容简介 Matlab 231-空调温度时延模型的模糊pid控制可以交流、咨询、答疑 2、内容说明略 3、仿真分析略 4、参考论文略中央空调温湿度采用PID控制系统的探讨.pdf 中央空调房间温度智能 PID控制的仿真研究.pdf...

编程日记 2025/7/12 23:31:28

RabbitMQ ③-Spring使用RabbitMQ

Spring使用RabbitMQ 创建 Spring 项目后，引入依赖：  <dependency><groupId>org.springframework.boot</groupId><artifac…...

编程日记 2025/7/21 0:32:44

C++修炼：模板进阶

Hello大家好！很高兴我们又见面啦！给生活添点passion，开始今天的编程之路！ 我的博客：<但凡. 我的专栏：《编程之路》、《数据结构与算法之美》、《题海拾贝》、《C修炼之路》欢迎点赞，关注&am…...

编程日记 2025/7/21 0:52:07

Spring Boot集成RabbitMQ高级篇：可靠性与性能提升

一、环境准备安装 RabbitMQ 在官网上下载对应操作系统的安装包（如 Windows、Linux 等），按照安装向导完成安装。安装完成后，启动 RabbitMQ 服务。在 Windows 系统下，可以在服务列表中找到 RabbitMQ Server 并启动&am…...

编程日记 2025/7/19 4:04:38

Shell脚本编程3（函数+正则表达式）

1.函数 1.1 定义简单来讲，所谓函数就是把完成特定功能，并且多次使用的一组命令或者语句封装在一个固定的结构中，这个结构我们就叫做函数。从本质上讲，函数是将一个函数名与某个代码块进行映射。也就是说，用户在定义了…...

编程日记 2025/7/21 1:30:40

【C++】语言深处的“精灵”：探索内存的奥妙

这里我们要知道，我们编写一个程序，这个程序中的变量是存储在哪个区域的栈一般是用于静态的分配内存的，但也可以动态的分配内存， 堆是用于动态的分配内存的，不能静态的分配内存栈： 通常是向低地址方向…...

编程日记 2025/7/21 0:02:40

c语言第一个小游戏：贪吃蛇小游戏03

我们为贪吃蛇的节点设置为一个结构体，构成贪吃蛇的身子的话我们使用链表，链表的每一个节点是一个结构体显示贪吃蛇身子的一个节点我们这边node就表示一个蛇的身体就是一小节输出结果如下显示贪吃蛇完整身子效果如下代码实现这个hasSnakeNode(…...

编程日记 2025/7/21 0:05:56

51 单片机头文件 reg51.h 和 reg52.h 详解

51 单片机头文件详解 51 单片机的头文件reg51.h和reg52.h是开发中非常重要的文件，它们定义了单片机的特殊功能寄存器 (SFR) 和位地址。以下是对这两个头文件的详细解析： 1. 头文件概述 reg51.h：针对标准 8051 单片机（4KB ROM, 128B RAM） reg52.h：针对增强型 8052 单片…...

编程日记 2025/7/20 15:03:51

让 - 艾里克・德布尔与斯普林格出版公司：科技变革下的出版业探索

在数字化浪潮席卷全球的当下，传统出版行业面临着前所未有的挑战与机遇。《对话 CTO，驾驭高科技浪潮》的第 10 章聚焦于让 - 艾里克・德布尔（Jean - Eric Debeure）及其所在的斯普林格出版公司（Springer Publishing Comp…...

编程日记 2025/7/19 9:31:02

[python] 面向对象的三大特性-封装及新式类

一继承继承是指一个类（子类）可以继承另一个类（父类）的属性和方法，并可以在其基础上进行扩展或修改。子类可以继承父类的属性和方法,包括私有属性和隐藏属性 💡 核心思想： 避免重复代码&…...

编程日记 2025/7/15 23:44:15

winreg查询Windows注册表的一些基本用法

注册表是Windows操作系统中用于存储配置信息的数据库。它包含了关于系统硬件、已安装的应用程序、用户账户设置以及系统设置的信息。特别地，当我们需要某些软件的配置配息时，主要在HKEY_CURRENT_USER和HKEY_LOCAL_MACHINE下的SoftWare内进行查询操作。 …...

编程日记 2025/7/15 14:09:25

DHCP自动分配IP

DHCP自动分配IP 练习1 路由器 Router>en Router#conf t Router(config)#ip dhcp pool ip10 //创建DHCP地址池 Router(dhcp-config)#network 192.168.20.0 255.255.255.0 // 配置网络地址和子网掩码 Router(dhcp-config)#default-router 192.168.20.254 //配置默认网关 Rou…...

编程日记 2025/7/18 12:50:33