我如何获取 MSMQ 队列上的所有可用消息

2024-02-23

处理队列中当前所有消息的最佳方法是什么?

我们有一个包含大量非常小的消息的队列,我想做的是读取所有当前消息,然后将它们发送到线程池进行处理。

我似乎找不到任何好的资源来向我展示如何创建一个简单的方法来返回 IEnumerable 例如

Thanks


虽然我同意Nick https://stackoverflow.com/users/51859/nick队列的目的更多的是用于 FIFO 风格的处理,并且阿尔森市场 https://stackoverflow.com/users/87053/arsenmkrt解决方案将起作用,另一种选择涉及使用消息枚举器 http://msdn.microsoft.com/en-us/library/system.messaging.messageenumerator.aspx并将消息堆积到您的 IEnumerable 中。

var msgEnumerator = queue.GetMessageEnumerator2();
var messages = new List<System.Messaging.Message>();
while (msgEnumerator.MoveNext(new TimeSpan(0, 0, 1)))
{
    var msg = queue.ReceiveById(msgEnumerator.Current.Id, new TimeSpan(0, 0, 1));
    messages.Add(msg);
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

我如何获取 MSMQ 队列上的所有可用消息 的相关文章

  • 为什么基类必须有一个带有 0 个参数的构造函数?

    这不会编译 namespace Constructor0Args class Base public Base int x class Derived Base class Program static void Main string a
  • 获取两个字符串之间的公共部分c# [关闭]

    Closed 这个问题需要多问focused help closed questions 目前不接受答案 我需要的是获取两个单词之间的共同部分并获取差异 例子 场景1 word1 感言 word2 Test 将返回 公共部分Test 不同之
  • 在 OpenCL 中将函数作为参数传递

    是否可以在 OpenCL 1 2 中将函数指针传递给内核 我知道可以用C实现 但不知道如何在OpenCL的C中实现 编辑 我想做这篇文章中描述的同样的事情 在 C 中如何将函数作为参数传递 https stackoverflow com q
  • 捕获 foreach 条件中抛出的异常

    我有一个foreach在 foreach 本身的条件下循环期间中断的循环 有没有办法try catch抛出异常然后继续循环的项 这将运行几次 直到异常发生然后结束 try foreach b in bees exception is in
  • 通信对象 System.ServiceModel.Channels.ServiceChannel 不能用于通信

    通信对象System ServiceModel Channels ServiceChannel 无法用于通信 因为它处于故障状态 这个错误到底是什么意思 我该如何解决它 您收到此错误是因为您让服务器端发生 NET 异常 并且您没有捕获并处理
  • ASP .NET MVC,创建类似路由配置的永久链接

    我需要帮助在 MVC 网站中创建类似 URL 路由的永久链接 Slug 已设置为 www xyz com profile slug 代码为 routes MapRoute name Profile url profile slug defa
  • std::map 和二叉搜索树

    我读过 std map 是使用二叉搜索树数据结构实现的 BST 是一种顺序数据结构 类似于数组中的元素 它将元素存储在 BST 节点中并按其顺序维护元素 例如如果元素小于节点 则将其存储在节点的左侧 如果元素大于节点 则将其存储在节点的右侧
  • 调试内存不足异常

    在修复我制作的小型 ASP NET C Web 应用程序的错误时 我遇到了 OutOfMemoryException 没有关于在哪里查看的提示 因为这是一个编译时错误 如何诊断此异常 我假设这正是内存分析发挥作用的地方 有小费吗 Thank
  • C# 创建数组的数组

    我正在尝试创建一个将使用重复数据的数组数组 如下所示 int list1 new int 4 1 2 3 4 int list2 new int 4 5 6 7 8 int list3 new int 4 1 3 2 1 int list4
  • UWP 无法在两个应用程序之间创建本地主机连接

    我正在尝试在两个 UWP 应用程序之间设置 TCP 连接 当服务器和客户端在同一个应用程序中运行时 它可以正常工作 但是 当我将服务器部分移动到一个应用程序并将客户端部分移动到另一个应用程序时 ConnectAsync 会引发异常 服务器未
  • C# 搜索目录中包含字符串的所有文件,然后返回该字符串

    使用用户在文本框中输入的内容 我想搜索目录中的哪个文件包含该文本 然后我想解析出信息 但我似乎找不到该字符串或至少返回信息 任何帮助将不胜感激 我当前的代码 private void btnSearchSerial Click object
  • 32位PPC rlwinm指令

    我在理解上有点困难rlwinmPPC 汇编指令 旋转左字立即然后与掩码 我正在尝试反转函数的这一部分 rlwinm r3 r3 0 28 28 我已经知道什么了r3 is r3在本例中是一个 4 字节整数 但我不确定这条指令到底是什么rlw
  • gdb查找行号的内存地址

    假设我已将 gdb 附加到一个进程 并且在其内存布局中有一个文件和行号 我想要其内存地址 如何获取文件x中第n行的内存地址 这是在 Linux x86 上 gdb info line test c 56 Line 56 of test c
  • 为什么我使用google'smtp'无法发送电子邮件?

    我有以下程序使用 smtp gmail com 587 发送电子邮件 namespace TestMailServer class Program static void Main string args MailMessage mail
  • 运行代码首先迁移更新数据库时出错

    我在迁移到数据库时遇到问题 并且似乎找不到我遇到的错误的答案 System MissingMethodException Method not found System Data Entity Migrations Builders Tab
  • 同时从多个流中捕获、最佳方法以及如何减少 CPU 使用率

    我目前正在编写一个应用程序 该应用程序将捕获大量 RTSP 流 在我的例子中为 12 个 并将其显示在 QT 小部件上 当我超过大约 6 7 个流时 问题就会出现 CPU 使用率激增并且出现明显的卡顿 我认为它不是 QT 绘制函数的原因是因
  • .NET UI 元素线程限制的原因

    我们知道 除了实例化元素的线程之外 不可能从任何线程执行操作任何 UI 元素属性的代码 我的问题是 为什么 我记得当我们使用 COM 用户界面元素时 在 COM Visual Basic 6 0 时代 所有 UI 元素都是使用 COM 类和
  • 如何打开 Windows 资源管理器窗口并选择特定文件夹

    我有一个 winform 应用程序 这个 winform 应用程序创建了几个文件 我想在我的应用程序中实现 查找目标 功能来显示这些文件 这些文件位于同一文件夹中 看图片 假设我创建了几个文件 C Test 文件夹 该文件夹包含以下文件 C
  • 如何查明CONFIG_FANOTIFY_ACCESS_PERMISSIONS是否启用?

    我想利用fanotify 7 http man7 org linux man pages man7 fanotify 7 html我遇到的问题是在某些内核上CONFIG FANOTIFY ACCESS PERMISSIONS不起作用 虽然C
  • 如何使用 std::array 模拟 C 数组初始化“int arr[] = { e1, e2, e3, ... }”行为?

    注意 这个问题是关于不必指定元素数量并且仍然允许直接初始化嵌套类型 这个问题 https stackoverflow com questions 6111565 now that we have stdarray what uses are

随机推荐

  • 在 phpoffice/phpword 上添加图表

    我知道如何在 PHPExcel 上添加图表 但我还需要在 docx 文件上插入图表 是否可以使用 phpoffice phpword 操作图表 如果不可能 您知道适合这项工作的好库吗 实际上不可能在 PHPWord 文档中添加图表 但该功能
  • 选择范围中的第一个字母 ( PostgreSQL )

    我正在尝试从单词的第一个字母在某个范围内的表中进行选择 例如 a f 我尝试使用这样的 where 子句 WHERE lower substring title from 1 for 1 IN ARRAY a k t 希望我稍后能找到一种动
  • 浏览器和凉亭。规范方法

    我现在使用 npm 中无法开箱即用的软件包的方式是这样的 package json 有 napa angular angular bower angular angular animate angular bower angular ani
  • 这个指针转换是否违反了严格的别名规则?

    这是 Quake III Arena 的快速反平方根实现 float Q rsqrt float number long i float x2 y const float threehalfs 1 5F x2 number 0 5F y n
  • GDB:创建局部变量?

    我正在使用 Xcode 的调试器 当停在断点处时 是否可以在 GDB 命令提示符中键入命令来创建局部变量 如果是这样 怎么办 请举个例子 我知道我可以在代码中完成它 然后重新编译程序 但我正在寻找一种更快的方法 如果您不需要在代码中引用变量
  • ABCpdf 转换 html 锚点以跳转到同一 PDF 中的另一个页面

    我使用 ABCpdf 动态生成 PDF 其中包含一个目录 该目录将链接到同一 PDF 中的其他页面 问题是 HTML 中锚标记的路径更改为临时文件的绝对路径 例如 ABCpdf 将呈现链接的 href a href elementId Li
  • 如何检查整数中的重复序列

    我有一个字母数字字符串 我想检查其中的整数模式重复 而且它们应该是连续的 Example 12341234qwe应该告诉我1234被重复 1234qwe1234 should NOT告诉我1234重复 因为它不连续 12121212应被视为
  • 如何向 select2 放置元素添加特定类?

    我通过 css 定制了 select2 及其通用类和 id 现在 我正在尝试自定义一个特定的类 该类将提供给 select2 然后在 css 中应用到它 我的问题 不是每个说的选择 而是它的删除 带有类的 div选择2拖放 附加到正文 我如
  • 常量之间的区别。指针和引用?

    常量指针和引用有什么区别 常量指针顾名思义是不能再次绑定的 参考的情况也是如此 我想知道在什么样的情况下 其中一种会比另一种更受青睐 他们的 C 标准和实现有何不同 cheers const 指针有 3 种类型 Data that p po
  • 构建 clang 示例时出现致命错误:未找到“type_traits”文件 #include

    我正在尝试建立打印函数名称 http llvm org viewvc llvm project cfe trunk examples PrintFunctionNames PrintFunctionNames cpp view markup
  • 抛出 WebApplicationException 时 Jersey 会产生意外的默认媒体类型

    我正在使用 JAX RS API 开发一个 Web 服务 并以 Jersey 1 17 作为我的实现 我希望客户可以在 JSON 和 XML 之间进行选择 他们使用AcceptHTTP 标头 当客户端不包含以下内容时 我希望 JSON 成为
  • 无法单击元素:Splinter / Selenium 中的 ElementClickInterceptedException

    我正在尝试抓取页面 但有时无法单击链接 按钮 当网页加载时 loadingWhiteBox 将首先出现 然后在几秒钟后消失 但它会保留在HTML代码中 只要该框出现在网站上 我就无法单击该链接 并且得到以下错误消息 selenium com
  • 检索 ImageView 的坐标

    我想知道是否可以获取 ImageView 的左侧和顶部坐标 我在 ScrollView 内的相对布局内有 2 个 ImageView 我尝试检索 ImageView 的矩阵matrix iv getImageMatrix 但这没有帮助Mat
  • 即使按下 cancel() 按钮,Ionic 2 onDidDismiss() 也会保存

    我的 Ionic 2 应用程序出现问题 到目前为止 我已经构建了一个项目列表页面 其中的每个项目都导航到详细信息页面 在详细信息页面 您可以编辑并选择保存或取消任何更改 保存效果很好 问题是onDidDismiss 即使关闭函数不 不应该将
  • 如何复制一个小部件的 GTK 样式并将其应用到另一个小部件?

    我当前的 GTK 弹出窗口如下所示 请注意 它采用深色氛围颜色主题 GTK3 8及以后版本有GTK菜单按钮 https developer gnome org gtk3 3 8 GtkMenuButton html 弹出窗口看起来像这样 请
  • 如何获取 Linux 中进程的进程树跟踪/日志?

    我想知道脚本启动哪些可执行文件以及以什么顺序 并递归地跟踪这些可执行文件 例如 假设我这里有一个 bash 脚本 称为 abc sh bin bash ls gcc 我想使用 trace log 命令 运行此脚本并得到如下内容 abc sh
  • pandas to_dict 具有 python 本机日期时间类型而不是时间戳

    我有一个pandas DataFrame df其中包含Timesatamp列 我希望创建一个行迭代器 通过iter 方法或通过to dict from df哪里的Timesatamp值是 pythondatetime 我试过这样做 for
  • 如何在Azure云上部署Spring Cloud微服务

    我正在使用 Spring Cloud 和 Netflix Eureka 进行微服务开发 现在我想在Azure上部署这些微服务 我试着遵循这个Link https azure microsoft com en in documentation
  • 为什么 gsutil cp 需要在版本化存储桶上进行 storage.objects.delete ?

    我正在使用服务帐户将文件上传到具有版本控制的 Google Cloud Storage 存储桶 我想将服务帐户权限保持在最低限度 它只需要上传文件 所以我不想授予它删除文件的权限 但上传失败 仅在流式传输所有内容之后 说它需要删除权限 难道
  • 我如何获取 MSMQ 队列上的所有可用消息

    处理队列中当前所有消息的最佳方法是什么 我们有一个包含大量非常小的消息的队列 我想做的是读取所有当前消息 然后将它们发送到线程池进行处理 我似乎找不到任何好的资源来向我展示如何创建一个简单的方法来返回 IEnumerable 例如 Than