首页
学习
活动
专区
圈层
工具
发布

【已解决】RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic

RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic xxx 错误提示是说,没有xxx这个topic....可能原因:Broker模块不支持自动创建topic,并且xxxtopic也没有被手动创建多 第二种:borker模块没有正确连接到NAMESRV 第三种:发送者没有连接到NAMESRV 知道了产生原因,...第二种情况出现的概率极低。可以采用以下两种方式确认 1. 查看broker的日志,出现如下内容,说明连接成功。...在mq的安装目录执行如下命令 mqadmin clusterList -n localhost:9876 出现如下内容说明连接成功,没有问题 第三种情况出现的最大可能是发送者和mq服务器之间的网络或端口不通...如果ping或者telnet连接不通,需要联系运维工程师开通网络或端口权限 凯哥遇到的是第一种情况,topic确实不存在,是通过手动创建topic解决的

4.8K20
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    捋明白 RabbitMQ 中的权限系统,再也不担心消息发送失败了!

    这里涉及到三种不同的权限: 读:和消息消费有关的所有操作,包括清除整个队列的消息。 写:发布消息。 配置:消息队列、交换机等的创建和删除。 这是 RabbitMQ 权限系统的一个简单介绍。 2....操作和权限的对应关系 接下来,下图展示了操作和权限的对应关系: 执行什么命令,需要什么权限,这张图描述的一清二楚了。 3....vhost 名称,如果不写默认为 /。...*":这个表示匹配名字以 javaboy- 开头的交换机和队列。 "":这个表示不匹配任何队列与交换机(如果想撤销用户的权限可以使用这个)。...如果用户不设置的话,相应的 topic exchange 也总是有权限的。 5. 小结 好啦,这就是关于 RabbitMQ 权限管理的一点点小知识~感兴趣的小伙伴可以去试试啦~

    1.5K10

    feeds流系统设计概述

    又叫做收件箱,每个用户能看到的消息都会被存储到收件箱中 个人页Timeline 展示自己发送过的Feed消息的页面,比如微信中的相册,微博的个人页等 又叫做发件箱,自己发布的消息都会被记录到自己的发件箱中...而后翻页的时候,需要用这些write_last_id往后拉取新的一定量(比如page_size个)的数据。再用这些数据组成的新收件箱列表,筛选 page_size 条返回前端。...而且,如果真的是删除了数据,可能会影响Feeds流的分页功能) 这种情况, 我们可以采用软删除+懒删除机制: 软删除是指消息内容不进行实际删除,而是将消息置为删除状态即可,不扩散出去。...如此一来,用户在自己的读取收件箱中消息的时候,是先获取了消息 Id 后,再去数据库查出消息内容,而后判断状态进行过滤,把已经删除的状态剔除,不返回给前端。此时也需要重新进行捞数据,填充分页内容。...扩展信息 用于业务扩展需求, 存储 json sender_id 发送人 create_at 发送时间 modify_at 修改时间 收/发件箱使用 redis zset 存储, 以收件箱为例

    1.7K30

    如何设计一个消息中心

    发件箱维护了官方想给用户的通知,每次打开消息中心时,用户都会主动来系统「拉取」官方最新的消息,并和用户自己的「收件箱」里的官方通知进行比较,以确认是否已读该条通知。...每当有一个用户点赞该大 V 时,都会将索引信息(一般为内容 ID、类型、发表时间等索引数据)写到用户的收件箱中。 优点:读很轻。仅需要读取消息列表即可。 缺点:写很重。...系统只需维护一个属于自己的消息列表即可。 缺点:读很重,计算量大。假设可以发送官方通知的生产者较多(例如淘宝里的一系列官方业务),则每次都需要从这些消息生产者里拉取最新的内容。...官方运营发送通知到「发件箱」中,「发件箱」中保留所有在线的通知列表。用户查看通知列表时,从官方「发件箱」中获取到未读通知,从自己的「收件箱」中查询历史通知。...用户查看通知列表时,若为第一页,需要从官方发件箱队列查看是否有未读的通知。 若有未读通知,则和历史通知第一页合并,返回给用户。同时异步写入用户的收件箱中。

    2.9K22

    B站即时通讯IM消息系统的新架构升级实践

    4)收件箱:将一次发送的时序位置映射到发送内容唯一id的kv存储,可以让服务端按时间序读取一批发送内容唯一id。5)私信内容:一个包括发送内容唯一id、原始输入内容、消息状态的原子概念。...批量私信把同一个发送内容唯一id写入每个收信人的收件箱里。...6)timeline模型:时间轴的抽象模型,模型包括消息体、已读位点、最大位点、生产者、消费者等基本模块,可以用于基于时间轴的数据同步、存储和索引。...群聊有另一个不一样的特点,就是当群成员发送消息后,需要通过长链接通知其他群成员的在线设备,以及发送人其他的在线设备,这是一个写扩散的技术模型,但是这个写扩散是通知后即时销毁的,并且具有过期时间,所以仅临时占用资源...、服务拆分等[16] 从新手到专家:如何设计一套亿级消息量的分布式IM系统[17] 企业微信的IM架构设计揭秘:消息模型、万人群、已读回执、消息撤回等[18] 融云技术分享:全面揭秘亿级IM消息的可靠投递机制

    34610

    【原创】开源OpenIM:高性能、可伸缩、易扩展的即时通讯架构

    IM系统技术挑战 可靠性 IM消息系统的可靠性,通常就是指消息投递的可靠性,即我们经常听到的“消息必达”,通常用消息的不丢失和不重复两个技术指标来表示。确保消息被发送后,能被接收者收到。...由于网络环境的复杂性,以及用户在线的不确定性,消息的可靠性(不丢失、不重复)无疑是IM系统的核心指标,也是IM系统实现中的难点之一。...userId:用户Id:注册使用IM的用户Id,从消息的发送和接收来看有两个身份:发送者和接收者 sendId:消息发送者Id receiverId :消息接收者Id msg:消息是指用户之间的沟通内容...同时也包括用户看不见的各种指令和通知,包括但不限于进群退群通知、好友添加通知等 inbox:用户收件箱,给某人发送消息,实际上是往接收者“信箱”写入消息,这个信箱就是收件箱 seq:用户收件箱中消息序列号...(1)负责用户连接管理,保持长连接,存储uid->conn映射关系; (2)负责消息接收落地,成功写入MQ后给客户端返回成功; (3)负责把消息推送给在线状态的接收者; 下图是客户端发送消息流程 消息发送时序图

    3K30

    周末小技 | 开发一个Feeds流系统——写扩散模式

    又叫做收件箱,每个用户能看到的消息都会被存储到收件箱中 个人页Timeline 展示自己发送过的Feed消息的页面,比如微信中的相册,微博的个人页等 又叫做发件箱,自己发布的消息都会被记录到自己的发件箱中...具体来说就是:大v用户发布消息,消息写扩散到活跃用户收件箱。而不活跃用户在登录的时候,会去主动拉取大v用户的发件箱,完成自身收件箱的更新。...而后翻页的时候,需要用这些write_last_id往后拉取新的一定量(比如page_size个)的数据。再用这些数据组成的新收件箱列表,筛选page_size条返回前端。...如此一来,用户在自己的读取收件箱中消息的时候,是先获取了消息Id后,再去数据库查出消息内容,而后判断状态进行过滤,把已经删除的状态剔除,不返回给前端。此时也需要重新进行捞数据,填充分页内容。...(写扩散) 取消关注他人时,用户的收件箱如何刷新:这里可以采用过滤的方式:我们从收件箱中获取到了消息id,而后需要进行回查,但是回查前,判断该id的所属发送人是否还在自己关注列表中。

    2K20

    Feed 流系统的架构设计方案

    又叫做收件箱,每个用户能看到的消息都会被存储到收件箱中 个人页Timeline 展示自己发送过的Feed消息的页面,比如微信中的相册,微博的个人页等 又叫做发件箱,自己发布的消息都会被记录到自己的发件箱中...具体来说就是:大 v 用户发布消息,消息写扩散到活跃用户收件箱。而不活跃用户在登录的时候,会去主动拉取大 v 用户的发件箱,完成自身收件箱的更新。...采用软删除+懒删除机制 软删除是指:消息内容不进行实际删除,而是将消息置为删除状态即可,不扩散出去。...如此一来,用户在自己的读取收件箱中消息的时候,是先获取了消息 id 后,再去数据库查出消息内容,而后判断状态进行过滤,把已经删除的状态剔除,不返回给前端。此时也需要重新进行捞数据,填充分页内容。...(写扩散) 取消关注他人时,用户的收件箱如何刷新:这里可以采用过滤的方式:我们从收件箱中获取到了消息 id,而后需要进行回查,但是回查前,判断该 id 的所属发送人是否还在自己关注列表中。

    1.6K10

    网络安全机构检测出三种新的恶意病毒

    网络安全机构宣称,已检测出了三种新的恶意病毒,并采取了相应的隔离措施。据悉,这些病毒已感染了数千名中国移动(微博)用户。...它通常伪装成金融应用程序,窃取用户的账号和密码、拦截或上传用户的短信信息、发送诈骗信息以及拦截拨入电话。 2....Group Scammer(privacy.Cckun.a):在用户点击短信中的恶意链接后,他们的移动设备就会感染病毒,从而被黑客远程控制,用来通过群消息发送恶意病毒。...与此同时,黑客会在用户手机上安装第三方应用程序,在无须经过用户允许的情况下,就开始发送付费信息,从而导致用户产生额外的资费。 3....Fee Server(payment.ZooTiger.a):这种病毒会传输多个恶意载荷,将用户个人通讯录上传到服务器,向用户收件箱发送他们不希望看到的广告以及通过SMS和WAP连接某些付费服务,从而给用户增加意想不到的资费

    68040

    Microsoft Exchange - 权限提升

    NTLM哈希值也泄露,可用于通过NTLM中继与Exchange Web服务进行身份验证,泄漏的NTLM哈希值。零日活动博客已涵盖该漏洞的技术细节。...该serverHTTP_relayNTLM.py脚本需要已检索,交易所的IP地址的目标端口和已经受损,是在红队的控制的电子邮件帐户管理员的SID。 ?...中继管理员NTLM到Exchange 电子邮件将被发送到目标帐户的邮箱(管理员)将自动转发到红队控制下的邮箱。 ? 电邮至目标帐户 电子邮件将在Red Team控制的帐户的收件箱中转发。 ?...电子邮件自动转发 已通过使用NTLM中继对Exchange进行身份验证,为目标帐户创建了一条规则,该规则将所有电子邮件转发到另一个收件箱。这可以通过检查目标帐户的收件箱规则来验证。 ?...特权升级脚本 脚本完成后,将显示一条消息,通知用户可以通过Outlook或Outlook Web Access门户显示目标帐户的邮箱。 ?

    4.1K30

    基于微软 Entra B2B 邀请机制的 TOAD 钓鱼攻击分析与防御策略

    通过官方域名发送高可信度邮件,并在自定义消息字段中嵌入社会工程诱导内容,引导受害者拨打伪造客服电话。...区别于传统钓鱼研究聚焦于邮件内容或 URL 检测,本文强调从身份平台治理视角重构安全策略,确保在不牺牲协作效率的前提下阻断攻击入口。...常见入口包括:社会工程获取内部员工凭据;利用配置宽松的“Guest Inviter”角色;通过已入侵的合作伙伴账户横向移动。...因此,该邮件极可能直达用户收件箱,甚至进入“优先收件箱”等高信任区域。3.3 社会工程路径攻击成功的关键在于心理操控。...结果:租户 A:攻击者成功发送 10 封含虚假电话的邀请邮件,全部通过 Defender for Office 365 检测;租户 B:攻击者尝试发送邀请时返回错误:“User is not allowed

    19000

    【转】Feed流的系统设计

    因此根据以上特点,存储库有几个问题是设计的关键:如何能支持100 TB,甚至PB级数据量?数据量与成本成正比,如何能降低成本?如何保证Feed不丢失?...使用表格存储后,系统的架构如图所示:同步方案选择Feed消息的同步主要有读扩散和写扩散两种方案:读扩散(拉模式):用户发送消息时存入自己的发信箱,并不主动推送给其他用户。...当其他用户获取Feed流时,系统需要去各个用户的发信箱中主动拉取。写扩散(推模式):用户发送消息时存入自己的发信箱,同时会主动推动给其他用户,写入他们的收件箱。...当其他用户获取Feed流时,系统只需按顺序读取收件箱中的消息即可。拉模式和推模式在很多方面完全相反,并且对Feed流产品的用户而言,刷新Feed流(读取)时的延迟敏感度要远远大于发布(写入)。...例如某个大V突然发了一个很有话题性的Feed,那么就有可能导致整个Feed产品中的所有用户都没法读取新内容。以粉丝读取流程为例:大V发送Feed消息。大V使用拉模式。

    29510

    网藤能力中心 | 深入Exchange Server在网络渗透下的利用方法

    统一消息服务器(unified messaging server):将专用交换机(private branch exchange/PBX) 和Exchange Server集成在一起,以允许邮箱用户可以在邮件中发送存储语音消息和传真消息...(如Exchange服务器的IMAP/POP等部分服务默认是不启动的,但其SPN名称同样存在)。...因此,当已拥有合法邮箱凭证的前提下,可以利用该功能,为邮箱用户设置收件箱主页URL属性,将其指向包含恶意代码的页面,当用户在Outlook中浏览刷新收件箱时,将触发加载恶意页面,执行恶意脚本代码,形成远程命令执行...随后,用户通过Outlook浏览收件箱,empire将接收到反弹shell,该过程Outlook收件箱可能会提示已阻止不安全的ActiveX控件,实际上命令已经执行完成。...关于NTLM中继攻击的安全研究及相关工具已有很多,也有各种新玩法层出不穷,有兴趣的可以自行查阅研究,有时间再另作文章讨论。

    5.8K20

    Spark内核详解 (2) | Spark之间的通讯架构

    Endpoint 对应一个 OutBox),Endpoint 接收到的消息被写入 InBox,发送出去的消息写入 OutBox 并被发送到其他 Endpoint 的 InBox 中。...Dispatcher:消息分发器 RPC 端点需要发送消息或者从远程 RPC 端点接收到的消息,分发至对应的指令收件箱/发件箱。...Inbox:指令消息收件箱。 一个本地 RpcEndpoint 对应一个收件箱 5. RpcEndpointRef:RpcEndpointRef 是对远程 RpcEndpoint 的一个引用。   ...当我们需要向一个具体的 RpcEndpoint 发送消息时,一般我们需要获取到该RpcEndpoint 的引用,然后通过该引用发送消息。 6. OutBox:指令消息发件箱。   ...TransportServer:Netty 通信服务端   一个 RpcEndpoint 对应一个 TransportServer,接受远程消息后调用 Dispatcher 分发消息至自己的收件箱,或者对应的发件箱

    1.6K20

    图解:消息传输的架构模式

    第二部分是“路由”,涵盖了用于在发送方和接收方之间传递消息的逻辑。 消息交换架构 本节描述与在发送方和接收方之间传输消息的机制相关的消息传输模式。...发布-订阅 发布-订阅(Pub-Sub)模式指的是发布者将消息发送到消息代理(broker)上的主题(topic)。你可以将主题视为一个收件箱。这个收件箱的概念根据实现技术而有不同的名称。...例如,RabbitMQ 将收件箱称为 Exchange,而 Kafka 将收件箱称为 Topic。订户绑定到主题,并以异步方式从主题接收消息。...然后,当一条消息发送到该主题时,所有订阅者都将收到发送到该主题的消息的副本。该消息被“分发出去”。...在单向流模式中,发送方连续向接收方发送数据 或者,发送方可能连接到某种代理技术,代理又通过某种主题/收件箱机制转发流,如下图 4 所示。绑定到代理“收件箱”上的接收方这样就能接收连续的消息流。

    80120

    如何在Ubuntu 16.04上安装和配置Postfix

    :为此,我们将选择Internet Site,因为这符合我们的基础架构需求。 系统邮件名称:这是用于在仅给出地址的帐户部分时构造有效电子邮件地址的基本域。...:不 本地网络:127.0.0.0/8 [::ffff:127.0.0.0]/104 [:: 1] / 128 邮箱大小限制:0 本地地址扩展字符:+ 要使用的Internet协议:全部 如果您需要返回以重新调整这些设置...,我们可以用d删除它: d 退出输入q返回终端: q 与客户端发送邮件 您可以通过在文本编辑器中输入消息来测试发送邮件: nano ~/test_message 在里面,输入一些你想要发送电子邮件的文字...使用该cat命令,我们可以将消息传递给mail进程。默认情况下,这将以Linux用户身份发送消息。...您可以在mail客户端中查看已发送的消息。输入以下内容再次启动交互式客户端 mail 然后,输入以下内容查看已发送的邮件: file +sent 您可以用传入邮件的相同命令来管理已发送邮件。

    3.9K10
    领券