nodejs-stream 相关问题



Laravel9 response()->stream() 使用 fwrite() 得到空结果

我需要将大量数据导出为 CSV 字符串。 所以我尝试将 fopen('php://stdout', w) 与 fwrite($file, $data) 一起使用。 但 Laravel response()->stream() 不会返回任何内容,也不会出现错误。 我...


安装node npm 不断出现错误消息

我正在安装这些 npm 软件包: npm 我表达 body-parser bcrypt cors dotenv gridfs-stream multer multer-gridfs-storage 头盔 morgan jsonwebtoken mongoose 但是,当...


来自具有阻塞操作的迭代器的 Akka 源代码

Source.fromIterator 上的 Akka 文档 (https://doc.akka.io/docs/akka/current/stream/operators/Source/fromIterator.html) 说: 如果迭代器执行阻塞操作,请确保 r...


无法将非 ASCII 文件名从 NodeJS 传递到 C++ 模块

我想将文件路径信息从NodeJS发送到我自己的模块(C++使用node-addon-api)。每一方独立工作(即我可以在 NodeJS 和 C++ 中检查/打开文件)。但是,如果想要的话,它就会失败...


VSCode NodeJS 调试器说已附加,但它仅适用于我的 NodeJS 文件之一

我一直在使用附加调试器,直到昨天它都工作正常,但它似乎只适用于我的一个 Nodejs 文件。当我连接调试器时,它说它已连接,然后我可以看到...


NodeJS 将 Dto 映射到 TypeORM 实体

我有一个运行nestjs框架的nodejs REST API后端,使用typeORM作为我的实体的ORM。 来自 C#/Entity Framework 背景,我非常习惯将 Dtos 映射到数据...


如何访问NodeJS中的FetchError类

NodeJS 18 对 fetch 提供了实验性支持 https://nodejs.org/dist/latest-v18.x/docs/api/globals.html fetch 函数抛出 FetchError 实例,我需要在 try-catch 中使用 insta 对其进行分析...


无法在 centos 7 上下载存储库“pgdg-common”的元数据

当我尝试在 CentOS Stream 8 上安装或更新软件包时,会出现此错误 [root@e2e-101-138 \~\]# sudo yum update RHEL / Rocky 8 的 PostgreSQL 通用 RPM - x86_64 ...


内容安全策略不适用于 html

我已经在nodejs中设置了内容安全策略(CSP),并且它正在应用于node。但是,对于根 html 页面,未应用 CSP。如何借助nodejs应用在html上......


如何在nodejs中用koa获取“HTTP_REFERER”?

如何从请求对象中获取引用者?变量 this.request.headers['referer'] 为空。


如何在Dijkstra中一行使用Java Stream

我正在尝试实现 Dijkstra 并且也在学习流。我无法使用流实现以下代码片段。我正在尝试使用流来迭代地图,过滤关键基础...


使用 Java 8 Stream API 从对象列表中收集列表

我有一堂这样的课 公共类示例{ 私人列表 ID; 公共 getIds() { 返回这个.ids; } } 如果我有一个此类的对象列表,如下所示 ...


删除 Firestore 到 BigQuery 扩展的更改日志中的旧行

我正在使用 Firebase Extension Stream Firestore to BigQuery 将数据导出到 BQ。 它工作得很好,我已经使用它好几年了。 然而,桌子的大小正在开始......


在 NodeJs 中并行化

我是 NodeJS/JS 的菜鸟,我对我的代码有疑问。 我正在编写一个函数来从 DynamoDB 表中获取元素,我的第一个版本是这样的 版本1 常量参数 = { 表名:p...


迁移到 CentOS Stream 9

据我们所知,CentOS 7 将于 6 月 24 日停产。我目前在我的网络中安装了 7.9 核心,但是由于 EOL 和其他安全风险,我想知道我的最佳选择是什么。


Java Stream 中多个对象属性的累积和

我有一个按月年字符串属性排序的对象列表。 我的对象类定义如下: 公共类 Obj { 字符串年份; 会员数量长; 长期非会员人数; 双


多个对象属性Stream的累加和

我有一个按月年字符串属性排序的对象列表。 我的对象类定义看起来像 公共类Obj{ 字符串年份; 会员数量长; 长期非会员人数; 双


Java 和 Xerces:找不到属性 XMLConstants.ACCESS_EXTERNAL_DTD

我在这个博客上查找了类似的帖子,但找不到我的问题的答案,所以我决定寻求帮助。 我用 Java 编写了这个简单的函数: public void open(InputStream stream) 抛出


如何防止在nodejs中通过eval动态加载代码?

有什么办法可以防止在nodejs代码中使用eval和friends吗?它已被至少几个 npm 恶意包使用,我没有理由在我当前的项目中使用它......


使用nodejs和java进行AES-GCM 256加解密

在应用程序中,我希望java前端应该从nodejs获取加密文本并提供固定的SECRET_KEY,它应该能够对其进行解码,反之亦然。任何帮助都是appriced。 我是


根据我的测试,为什么 NodeJS 编码 Varint 比 Rust 快得多?

我使用以下两段代码对 Varint 进行编码,NodeJS 大约需要 900ms,而 Rust 大约需要 2700ms。为什么性能差距这么大? 看来分配内存更省时间-


JavaScript StructuredClone 在 Chrome/Edge 中遇到“非法调用”,但在 NodeJS 中没有遇到问题

在浏览器中运行以下代码: ({ 克隆: StructuredClone }).clone(1); 会得到 Uncaught TypeError: Illegal incalling,在 Chrome/Edge 中测试。 不过在 NodeJS 中运行代码没问题,测试一下...


Docker 容器中的 NodeJS SocketIO 服务器的 ERR_SSL_VERSION_OR_CIPHER_MISMATCH

所以我在docker容器内有一个nodejs socketio服务器。服务器使用与站点相同的 URL(仅在端口 3001 上)以及相同的证书和密钥。但是,我收到此错误,但我不能


在Java中将流转换为字符串

我想将 Map<> 的流转换为字符串,并将其附加到文本区域。我尝试了一些方法,最后一个使用 StringBuilder,但它们不起作用。 公开 我想将 Map<> 的流转换为字符串,并将其附加到文本区域。我尝试了一些方法,最后一个使用 StringBuilder,但它们不起作用。 public <K, V extends Comparable<? super V>> String sortByAscendentValue(Map<K, V> map, int maxSize) { StringBuilder sBuilder = new StringBuilder(); Stream<Map.Entry<K,V>> sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())); BufferedReader br = new BufferedReader(new InputStreamReader((InputStream) sorted)); String read; try { while ((read=br.readLine()) != null) { //System.out.println(read); sBuilder.append(read); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } sorted.limit(maxSize).forEach(System.out::println); return sBuilder.toString(); } 您可以将条目收集到一个String中,如下所示: String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(e-> e.getKey().toString() + "=" + e.getValue().toString()) .collect(Collectors.joining (",")); 考虑对 @Eran 的代码进行轻微更改,因为 HashMap.Entry.toString() 已经通过 = 为您加入了: String sorted = map.entrySet().stream() .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())) .map(Objects::toString) .collect(Collectors.joining(",")); 这很容易做到,您可以使用 Steams API 来做到这一点。首先,将映射中的每个条目映射到单个字符串 - 键和值的连接字符串。一旦你有了这个,你就可以简单地使用 reduce() 方法或 collect() 方法来做到这一点。 使用“reduce()”方法的代码片段将如下所示: Map<String, String> map = new HashMap<>(); map.put("sam1", "sam1"); map.put("sam2", "sam2"); String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .reduce("", (str1,str2) -> str1 + " , " + str2).substring(3); System.out.println(concatString); 这将为您提供以下输出: sam2 : sam2 , sam1 : sam1 您还可以使用 collect()' method instead ofreduce()` 方法。它看起来像这样: String concatString = map.entrySet() .stream() .map(element-> element.getKey().toString() + " : " + element.getValue().toString()) .collect(Collectors.reducing("", (str1,str2) -> str1 + " , " + str2)).substring(3); 两种方法给出相同的输出。


HttpMediaTypeNotSupportedException:从 AWS Lambda 运行 SpringBoot REST 应用程序时不支持内容类型“application/octet-stream”

我正在尝试在 AWS Lambda 中运行 Spring Boot 应用程序(例如,各种示例使用与 https://www.baeldung.com/spring-boot-aws-lambda 基本相同的方法 - 只需复制代码和...


针对不同的合并项目使用不同的 MongoDB 集合

我有 2 个 NodeJs 项目,最近将它们合并到一个 NodeJs 服务器中,同时将控制器、服务和 mongoDB 模型保留在两个项目的单独文件夹中。问题是,合并后...


如何在 C++/WinRT (WinUI3) 中将图像从内存读取到 ImageSource?

[1] 我想在 XAML 中显示 Image 控件的图像,但该图像来自字节数组。 我应该怎么办?图像格式可以是JPG、BMP或PNG之一。 [1] 我想在 XAML 中显示 Image 控件的图像,但该图像来自字节数组。 我该怎么办?图像格式可以是 JPG、BMP 或 PNG 之一。 <Image x:Name="img"/> void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data img().Source(???); // what should I do? } [2] 我尝试了InMemoryRandomAccessStream,但没有成功。 我知道在C#中使用MemoryStream很方便,但是如何在C++中实现它? 另一个问题是这个方法是否也适用于JPG和PNG格式的图像? void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; winrt::Windows::Storage::Streams::InMemoryRandomAccessStream stream; // How to read data from stream? bmp.SetSource(stream); img().Source(bmp); } [3] 现在功能已经实现了,但是还有两个问题 IAsyncAction MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; winrt::Windows::Storage::Streams::InMemoryRandomAccessStream stream; winrt::Windows::Storage::Streams::DataWriter dw(st.GetOutputStreamAt(0ULL)); dw.WriteBytes({ buf, size }); // This is very inefficient! co_await dw.StoreAsync(); dw.Close(); bmp.SetSource(stream); img().Source(bmp); stream.Close(); } 首先,我发现DataWriter::WriteBytes()确实是在复制数据。但我认为ImageSource只需要从我的buf中读取即可,不需要在读取之前将整个图像完全复制到流中。也许是类似MemoryView的东西,我这样想是不是错了? 其次,DataWriter和InMemoryRandomAccessStream的Close()应该在哪里调用? BitmapImage需要释放内存吗?这里有一个异步函数,我不知道应该写在哪里 [4] 根据IInspectable,我尝试了SHCreatMemStream并搜索了大量信息以提出另一个解决方案。目前的问题是,与方法[3]同样可行,但仍然会出现内存分配问题。 #include "Shlwapi.h" #include "shcore.h" #pragma comment(lib, "shlwapi.lib") void MainWindow::myButton_Click(IInspectable const&, RoutedEventArgs const&) { unsigned long long size; // iamge data size const unsigned char* buf; // image data winrt::Microsoft::UI::Xaml::Media::Imaging::BitmapImage bmp; IStream* stream{ SHCreateMemStream(buf, size) }; // Copying takes a lot of time static const GUID guidIRandomAccessStream = { 0x905a0fe1, 0xbc53, 0x11df, { 0x8c, 0x49, 0x00, 0x1e, 0x4f, 0xc6, 0x86, 0xda } }; winrt::Windows::Storage::Streams::IRandomAccessStream pRas{ }; CreateRandomAccessStreamOverStream(stream, BSOS_OPTIONS::BSOS_DEFAULT, guidIRandomAccessStream, (void**)&pRas); bmp.SetSource(stream); img().Source(bmp); } 通过性能测试,发现CreateRandomAccessStreamOverStream的时间是一致的,但是SHCreateMemStream消耗的时间与图像大小成正比。可以得出,SHCreateMemStream中创建流的过程也涉及到内存的复制。 我对Windows编程中的Stream不是特别熟悉。创建流的过程一定会涉及到内存复制吗?从内存加载图像可以避免额外的开销吗?还有没有类似MemoryStreamView的结构来替代吗? 还有一个问题,我知道新的图像肯定需要内存存储。 BitmapImage设置Stream为Source会接管Stream占用的内存吗? Image控件设置BitmapImage作为Source会接管BitmapImage占用的内存吗? 如果是这样的话,我可以接受Stream分配新的内存,否则仍然是一个效率问题。 谢谢!!!!!!! 使用Stream已经彻底解决了这个问题。如前四期所述。 至于附加问题: ★1 使用 CreatStreamOnHGlobal 而不是 SHCreatMemStream。 因为SHCreatMemStream在调用过程中会对传入的内存块参数进行另一次内存复制。 CreatStreamOnHGlobal 创建流后不执行内存复制。您可以先通过GlobalAlloc分配内存,写入所需的图像数据,然后调用CreatStreamOnHGlobal,无需任何时间开销。另外,可以将CreatStreamOnHGlobal的第二个参数设置为true,自动释放GlobalAlloc分配的内存。 通过进程内存监控,我发现对于同一个程序,使用CreatStreamOnHGlobal的速度是SHCreatMemStream的两倍,并且不会导致内存泄漏。 ★2 创建的Stream需要调用Release方法减少一个引用。 IRandomAccessStream作为局部变量,会自动析构,无需主动释放。 并且BitmapImage还管理一部分引用,这些引用在离开作用域后被释放。 通过测试COM对象上Release方法的返回值,发现整个程序结束后引用计数又回到了0


通过libcurl和NodeJS的数据交换问题

我有一个用 C 语言编写的 Windows x64 客户端,需要将文本发送到 NodeJS 服务器,所以我使用 libcurl 来实现这一点,但它不起作用,数据似乎没有到达服务器。 这是客户


AWS 使用 Cloudformation 为 Kinesis Firehose 放置订阅筛选器 - 检查给定的 Firehose 流是否处于活动状态

按照本指南创建 Kinesis Firehose Stream。 我已按照指南进行操作,当我开始创建订阅过滤器(步骤 12)时,我在尝试发送到 S3 时遇到此错误: 一个


docker中npm start启动node应用程序的问题

我阅读了一些 Docker 和 Node.js 最佳实践文章,例如https://github.com/nodejs/docker-node/blob/main/docs/BestPractices.md 或使用


NodeJS - 子进程 - Exec VS Powershell ISE |为什么结果不同?为什么无法创建 PSCredential?

我的PS脚本: $admin =“测试” $Password = ConvertTo-SecureString "Test12345" -AsPlainText -Force $Credential = [PSCredential]::new( $admin, $Password) if ($Credential -is [系统.


使用 qr-image 生成 Wi-Fi QRCode

npm 模块 qr-image 允许使用 NodeJS 生成 QRCode,如下所示: 从“qr-image”导入 qr; 从 'fs' 导入 fs; qr.image('https://google.com/search?q=hello%20world!', {type:'...


NodeJS 我当前的 Google Cloud 函数名称是什么?

我想使用当前Google Cloud Function的名称来驱动一些逻辑。如何确定我的 Google Cloud Function 名称是什么?


HubspotClient - 通过电子邮件 ID 更新联系人不起作用

在 NodeJS 中,我使用的是“@hubspot/api-client”:“^7.1.2”。 使用accessToken创建hubspot客户端如下 const hubSpotClient = new hubspot.Client({ accessToken }); 当我尝试


如何让新的 Angular 17 项目运行?

全新安装 Nodejs (20.10.0) 和 Angular (17.0.8)。新项目(“ng new Default”),没有文件更改。 “ngserve”没有错误,但浏览器控制台显示: main.ts:5 错误


mongodb和nodejs中的promise待处理错误

我已经编写了node.js代码,用于使用mongodb数据库获取一些数字。这是我的代码 MongoClient.connect('mongodb://localhost:27017/mongomart', 函数(err, db) { 断言....


Nodejs 事件循环?

所以客户端javascript中的异步编程是setTimeOut在浏览器API中运行,因此它不会阻塞javascript单线程。由于我们在 Node 中没有浏览器 API,谁...


Nodemailer 不会发送电子邮件

我有一个与 Nodemailer v. 6.9.3 相关的错误。当我启动 nodeJS localhost 时,会出现以下内容: 错误:连接ECONNREFUSED 127.0.0.1:465 在 TCPConnectWrap.afterConnect [作为未完成](节点:ne...


使用 MSSQL 将 SQL Server 与 Nodejs 连接时出现 SQL Server 错误“[ConnectionError: Login failed for user '****'.]”

我遇到以下错误 [连接错误:用户“****”登录失败。] name: '连接错误', message: '用户\'****\'登录失败。', 代码:'E...


NodeJS WebSocket 在连接打开后直接关闭

这是我的 websocket 服务器端代码: wss = 新的 WebSocketServer({ 服务器:服务器, 路径:'/聊天' }); console.log('Web Socket 服务器已创建'); wss.on('连接', 函数 (ws, 请求...


redis:net.connect 不是一个函数

我需要将Redis添加到nodejs 但无法顺利执行 使用redis版本,相同的代码,但出现此错误: 我的代码: 从 'redis' 导入 { createClient } 导出常量客户端 =


nodeJS google-protobuf 中的描述符

你好,我是 gRPC 和 ProtoBuf 的新手 我正在尝试通过 grpc 从用 Go 编写的微服务进行通信。 在某些操作中,要发送请求,我需要设置在


如何使用nodejs创建http服务器来提供一些html文件?

因为我收到一些错误,例如:node:events:498 throw er; // 未处理的“错误”事件错误:getaddrinfo ENOTFOUND /about 在 GetAddrInfoReqWrap.onlookup [未完成](节点:dns:71:26) 发出“错误...


Webpack 模式更改 Heroku 暂存 URL

我最近启动了带有临时和生产环境的 Heroku 管道。我的应用程序是使用 React、NodeJS 和 Webpack 构建的。 当我部署到 staging 时,我的 baseURL 是生产 url,但它...


在 NodeJs Express 中让 SocketIO 在 HTTPS 上工作

大家好, 将我的 NodedJs 应用程序推送到我的 ubuntu 服务器(使用 https 在 nginx 中提供站点)后,我遇到了问题。在我使用 localhost 的本地环境中,连接是


NodeJS 叉平衡器

我很久以前读过一篇关于在单独的子进程中解决高内存使用任务的文章。根据这篇文章,我已经实现了相同的并且延迟已经减少。但目前


Bootstrap 模式仅显示 MongoDB 集合中的第一条记录

我正在使用 NodeJS、Handlebars 和 Bootstrap 构建一个简单的 Web 应用程序。它应该循环遍历模拟产品的 MongoDB 集合并显示其字段。 我正在“产品...


成本管理器去除税收nodejs

当我检查该月的最后一天时,我发现成本浏览器中的成本比平常高,我相信这是税。 因此我想取消最后一天的税。 我试过了,但不行...


TypeScript:错误:使用路径时找不到模块

我有一个包含后端(NodeJS)、前端(Angular)和共享目录(前端和后端共享的容器模型)的 monorepo。 预先同意单声道/ 预先同意-api/ 预先同意应用程序/...


© www.soinside.com 2019 - 2024. All rights reserved.