node.js-stream 相关问题


我的插件无法运行使用 Node.js Stream Deck SDK 和 RobotJS 创建的

我想制作一个更高级的键盘和鼠标模拟器来交替内置操作。 从插件模板开始。 没有进行任何更改就构建了它并且它起作用了。 然后安装了robotjs



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

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


npm v9.4.0 不支持 Node.js v14.15.0

npm 的接受版本是什么(Node.js v14.15.0)。给我以下错误: npm WARN cli npm v9.4.0 不支持 Node.js v14。 15.0。您可能应该升级到 npm WARN cli 新版本没有...


“Next.js 应用程序需要 Node.js 版本 >= v18.17.0,但在 Node.js 16.20.2 中遇到错误 - 如何解决?”

当我使用 cli 创建下一个 js 应用程序时,然后我输入 npm 运行开发 我收到这个错误。 您正在使用 Node.js 16.20.2。对于 Next.js,需要 Node.js 版本 >= v18.17.0。 但我的node版本是v...


我在运行node.js 文件时遇到错误

我是 Node.js 新手,我正在尝试通过 Node.js 运行我的测试文件。我只是输入 node 。 ut63.js 但它显示以下错误: 错误:找不到模块 'C:\Users\User11\Desktop\Co...


无法使用 win32-x64 运行时 (Strapi) 加载“sharp”模块

我曾经使用本地安装的 Node.js v16.x 来运行 Strapi,效果很好。 但最近由于另一个项目不得不更新到 Node.js v18.x,所以我安装了 NVM 来管理多个 Node.js


安装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...


如何替换 Node.js 中已弃用的 crypto.createCipher?

我正在使用以下函数来加密/解密 Node.js 中的字符串: var crypto = require('crypto'); var 算法 = 'aes-256-ctr'; 函数加密(文本){ var cipher = crypto.createCipher(


Node.JS 在运行时切换用户

以 root 身份运行的 Node.JS 程序是否可以在运行时降级其权限?这将是它首先要做的事情之一,目的当然是限制 po...


Restful-API node.js 和expressCross-Origin 请求被阻止:同源策略不允许读取远程资源的cat。雕像:(空)

我使用node.js和express创建了Restful API,当我将API和网站移动到服务器计算机时,当我尝试打开网站时,我在控制台中收到错误: Restful-API node.js 和expressCr...


如何解决奇数编号的 Node.js 版本不会进入 LTS 状态且不应用于生产节点:16120 UnhandledPromiseRejectionWarning

我尝试创建一个新的角度应用程序ng新应用程序,但出现此错误 检测到 Node.js 版本 v11.0.0。 奇数编号的 Node.js 版本不会进入 LTS 状态,并且不应用于产品...


Interactive Broker 的 API (IB_sync) 跳过来自 Polygon WebSocket Stream 的订单

我只是想根据实时 Polygon.io 数据流中的特定条件自动化盈透证券中的一些交易(请参见下面的示例)。我在


在 Node.js 应用程序中调用 notFoundHandler() 后,GraphQL 路径无法访问

我在将 GraphQL 集成到 Node.js 应用程序时遇到问题。最初一切正常,但添加 notFoundHandler() 后,位于 localhost:3000/graphql 的 GraphQL 端点不再存在...


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

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


Node.js Solana websocket 程序订阅返回太多事件

我有一个使用Solana的JSON RPC websocket方法programSubscribe的node.js文件。我遇到的问题是我收到了一年前发生的事件。我如何使用过滤器来获得...


如何在Dijkstra中一行使用Java Stream

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


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

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


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

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


node.js + wordpress 返回帖子数据

我正在开发一个node.js服务器来获取外部api数据,然后使用我的客户端从我的节点服务器获取数据,而不是调用api站点。 我正在使用express,axios,...


在 Google Cloud Build 期间在 Google Cloud SQL 上运行 node.js 数据库迁移

我想在 Cloud Build 过程中运行用 node.js 编写的数据库迁移。 目前,正在执行数据库迁移命令,但 Cloud Build 进程似乎正在执行...


Spring-Cloud-Stream serde SerializationException 会阻止消息在被消费和修改后被发布

我的配置如下: 春天: 应用: 名称:交易丰富器应用程序 一体化: 轮询器: 固定延迟:5000 云: 溪流: 卡夫卡: 绑定...


迁移到 CentOS Stream 9

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


使用 Java 8 Stream 在 Writer 对象中写入字符串值

我试图用以下代码中的流替换普通的 for 循环,该循环在 Writer 对象中写入字符串值: 公共无效保存(){ 尝试 (Writer fileWriter = new FileWriter(file)) {...


Node.js 服务器上的 React Native Socket.IO 未连接

我正在构建一个React Native Expo应用程序,需要使用socket.io进行实时通信。我正在本地主机上运行 Node.js 服务器。 这是我的代码 React Native - home.js 从 & 导入 { io }


将 Node.js 后端连接到 AWS RDS MySQL 数据库时出现问题

你好吗? 我在将 Node.js 后端连接到 AWS RDS MySQL 数据库时遇到问题。我从 Digital Ocean 迁移到 AWS,它在 Digital Ocean 中运行得很好。然而,mig之后...


调试器突然停止在 webstorm 项目中工作

我的 webstorm ide 不会再在现有 Node.js 项目中的断点处停止。 当我创建一个新的 webstorm Node.js Express 项目并设置调试点时,它似乎工作正常。 例如,对于...


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

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


多个对象属性Stream的累加和

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


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

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


提高Java/Stream/filter的响应时间

我正在使用流(filter/anyMatch)对两个对象列表进行比较。两个列表的大小最多可达一百万个对象。 我用下面的代码进行了测试。通常t的大小...


我需要使用 Node.js 在网站上有多个联系表单

我正在为一家餐厅创建一个网站,其中会有多个联系表格。 我使用带有 Express 和 Nodemailer 依赖项的 Node.js 来发送表单。我的主要联系表格位于


使用 Node.JS 调用 AWSglue 的 lambda 函数没有 console.log 的原因?

我正在尝试使用 lambda 函数和 node.js 启动 AWS 粘合作业。我可以很好地测试 lambda 函数,但在脚本运行完毕后似乎没有任何反应。我添加了一些


使用tonweb和Node.JS在TON区块链中交易失败

我正在尝试将一笔交易从我的钱包发送到其他地址,金额为 10 NOT。我正在使用 tonweb,我的应用程序位于 node.js 上。 这是代码: const TonWeb = require('tonweb'); 常量吨助记符 =


需要使用 Node.js 压缩整个目录

我需要使用 Node.js 压缩整个目录。我目前正在使用node-zip,每次该进程运行时都会生成一个无效的ZIP 文件(正如您可以从此Github问题中看到的那样)。 有没有...


在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 基本相同的方法 - 只需复制代码和...


需要能够打印在node.js无头浏览器中创建的数据

如何解决问题才能打印出任何数据,例如。在运行无头浏览器的 node.js 中创建的即时字符串、变量等作为 console.log('Text') 将不起作用。 例如是 常量...


node.js https 示例,错误,连接到本地主机的未知 SSL 协议错误

我使用这些链接中的简单示例: a 链接[a 如何在 Node.js 中创建 HTTPS 服务器?] a link[a 如何创建 https 服务器? docs.nodejitsu.com] 但我收到类似的错误 卷曲:(35) 未知 SSL


如何在node.js上运行多个文件?

我正在开发一个学校项目,我计划使用 Node.js 来托管它。问题是,每次我尝试运行它时,它都不会返回任何内容。 我在一个文件中有 4 个 HTML、2 个 CSS 和 2 个 JS 文件...


如何在 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


无服务器框架版本 2 是否支持 Node.js 版本 18 或更高版本

我们收到了来自 AWS 的 lambda 通知:AWS 将在 6 月 24 日之后终止对 Node.js 版本 16 或更低版本的支持生命周期 (EOL)。目前我们的无服务器框架版本:“2”


如何在 Node.js 可执行文件中包含 EJS 模板文件

我正在开发一个 Node.js Web 应用程序,使用 Express 和 EJS 作为视图引擎。我的目标是创建一个可以在我的网络服务器上运行的可执行文件,而无需复制任何额外的


在 Vercel 上部署 Node.js 应用程序时出现配置包问题 - “配置属性未定义”错误

我使用 Node.js 中的配置包来组织我的所有环境变量,它在我的本地环境中完美运行。但是,当我将应用程序部署到 Vercel 时,我遇到了以下情况...


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

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


从Node.js服务器中的Java Android应用程序接收JSON,并将其插入到Mongodb数据库

所以我尝试使用 Node.js 服务器将数据从 Java Andoid 应用程序插入到 Mongodb 数据库。但是我的 JSON 对象是空的(正如我所想的)并且读取值是“未定义”。我正在使用 mongodb


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

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


VSCode 终端未在 Linux (POP_OS 20.10) 中打开

有什么办法可以解决这个问题 VSCode 详细信息 版本:1.55.2 提交:3c4e3df9e89829dce27b7b5c24508306b151f30d 日期:2021-04-13T09:37:02.931Z 电子:11.3.0 铬:87.0.4280.141 Node.js:12.1...


Node.js/fastify 出现错误,不支持的媒体类型:application/x-www-form-urlencoded

考虑: 文件index.js fastify.get("/paynow", (请求, 回复) => { 让数据= { TXN_AMOUNT: '10', // 请求金额 ORDER_ID: 'ORDER_123455', // 任何唯一的订单 ID CUST_ID:'


最新问题
© www.soinside.com 2019 - 2025. All rights reserved.