- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
由于 channel 不是线程安全的,我可以在发布之前同步 channel 实例,也可以在每次需要时创建一个 channel 并关闭它。
但在我看来,由于锁定或创建和销毁 channel 的成本,它们都没有很好的性能。
那么应该如何向高tps的rabbitmq发布消息呢?对此有什么好的赞美吗?
最佳答案
所以,首先要做的是。 channel 不是连接。在 RabbitMQ 中, channel 与应用程序 session 相同,而连接表示与服务器的底层 TCP session 。 This answer很好地解释了其中的一些内容。
TCP session 的创建成本很高,因此它们的生命周期往往在任何特定工作线程的生命周期之外。创建 channel 的成本非常低 - 服务器所做的只是为您的 channel 标识符分配一个整数,然后您就有了一个新 channel 。
RabbitMQ 上的大多数操作在失败时都会关闭 channel 。这样做是因为这样做没有实际后果。他们是否会关闭底层连接,这会给应用程序带来很多问题。
设计指南
如果您确实有大量处理正在进行,则池化适用于连接。关于如何做到这一点的讨论确实超出了我可以在简短回答中提供的范围。
合并绝对不适合 channel 。 channel 是一种轻量级结构,旨在具有短暂的生命周期。如果它持续的时间超过一两次发布,那就太好了。但是你应该预料到每次尝试操作时,它都有可能会失败并关闭 channel 。这不会关闭底层连接,但必须重新建立新 channel 才能对代理执行任何操作。
消费者生命周期与 channel 相关。当 channel 关闭时,附加的消费者也会关闭。将您的消费者对象(工作线程)设计为能够在发生这种情况时获得连接并创建新 channel ,然后重新订阅自己。
避免跨线程共享 channel 。一个线程 = 一个 channel 。
虽然我对 Java 客户端没有任何特别的经验,但我认为锁不是必需的,而且我当然希望实现不会做一些奇怪的事情来使 Channels 除了轻量级。
如果您正在编写自己的协议(protocol)实现库(不是必需的,但如果您需要细粒度控制,这也是一个不错的主意),请分配一个线程来管理每个连接
。不要并行读取和写入 TCP 套接字,否则会破坏协议(protocol)。
关于 Java 客户端,我认为您可以假设 channel 操作(读取和写入等)不是线程安全的,这就是您想要坚持一个线程的原因/一个 channel 范例。我认为您可以假设创建 channel (连接操作)是线程安全的。
关于java - 如何使用高tps、多线程向rabbitmq发布消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48733067/
我正在寻找一种方法来创建根据价格选择我的产品的过滤器(选择下拉菜单)。 我知道这样的查询是完全可能的: SELECT * FROM products ORDER BY price ASC SELECT
函数参数中或显示尺寸时(高度,宽度)的顺序是否有约定? 最佳答案 我不知道大量的语言,但我使用过的语言(宽度,高度)。它更适合沿着 (x, y) 坐标线。 关于language-agnostic -
在我的表单中,我让用户输入房间的长度高度和宽度以获得 m2、m3 和瓦特的计算值。但是用户也应该能够直接输入 height 和 m2 来获取值。我尝试了很多语法,但 if else 不能正常工作。我知
我在 Elasticsearch 中创建了一个索引,看起来像 {"amazingdocs":{"aliases":{},"mappings":{"properties":{"Adj Close":{"
我有以下功能,我需要清除数据库中的所有图片列并移动到文件系统。当我一次性完成这一切时,内存太多并且会崩溃。我切换到递归函数并执行 20 次写入和批量操作。 我需要为大约 6 个表执行此操作。我的 Re
我正在编写一个函数来计算 PI 的值,并将其作为 double 值返回。到目前为止,一切都很好。但是一旦函数到达小数点后14位,它就不能再保存了。我假设这是因为 double 有限。我应该怎么做才能继
2020年是中国CDN行业从98年诞生到今天快速发展的第二十四年,相关数据显示,全国感知网速持续上扬,达到了3.29兆/秒,标志着在宽带中国的政策指导下,中国的网速水平正在大步赶上世界发达国家的水平
在 aerospike 集合中,我们有四个 bin userId、adId、timestamp、eventype,主键是 userId:timestamp。在 userId 上创建二级索引以获取特定用
$('#container').highcharts('Map', { title : { text : 'Highmaps basic demo'
有没有办法显示自定义宽度/高度的YouTube视频? 最佳答案 在YouTube网站上的this link中: You can resize the player by editing the obj
我使用 Highcharts ,我想在 Highcharts 状态下悬停时制作动态不同的颜色。 正如你可以看到不同的颜色,这就是我做的 var usMapChart , data = [] ; va
在所有节点上运行 tpstats 后。我看到很多节点都有大量的 ALL TIME BLOCKED NTR。我们有一个 4 节点集群,NTR ALL TIME BLOCKED 的值为: 节点 1:239
我发现 APC 上存在大量碎片 (>80%),但实际上性能似乎相当不错。我有 read another post这建议在 wordpress/w3tc 中禁用对象缓存,但我想知道减少碎片是否比首先缓存
对于我的脚本类(class),我们必须制作更高/更低的游戏。到目前为止,这是我的代码: import random seedVal = int(input("What seed should be u
我发现 APC 上存在大量碎片 (>80%),但实际上性能似乎相当不错。我有 read another post这建议在 wordpress/w3tc 中禁用对象缓存,但我想知道减少碎片是否比首先缓存
对于我的脚本类(class),我们必须制作更高/更低的游戏。到目前为止,这是我的代码: import random seedVal = int(input("What seed should be u
我已经 seen >2 字节的 unicode 代码点,如 U+10000 可以成对编写,如 \uD800\uDC00。它们似乎以半字节 d 开头,但我只注意到了这一点。 这个 split Actio
有人可以帮我理解为什么我的饼图百分比计算不正确吗?看截图: 根据我的计算,如 RHS 上所示,支出百分比应为 24.73%。传递给 Highcharts 的值如下:- 花费:204827099.36-
我阅读了有关该问题的所有答案,但我还没有找到任何解决方案。 我有一个应用程序,由我的 api 服务器提供。 Wildfly 8.1 和 Mysql 5.6。当查看时间到来时(Wildfly 服务器连接
我正在用选定的项目创建圆形导航。当用户单击任何项目时,它将移动到定义的特定点。一切都很好,除了当你继续点击项目时,当动画表现不同并且项目在 360 度圆中移动并且它被重置直到你重复场景时,我希望它
我是一名优秀的程序员,十分优秀!