RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。 由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下，实现mq服务端远程访问。
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先入先出，里面存放的内容是message,下面介绍通过在ubuntu+cpolar+rabbitMQ环境下，实现mq服务端远程访问。
本文主要介绍如何在Ubuntu系统环境下，安装RabbitMQ与cpolar内网穿透工具实现无公网IP随时随地远程访问本地部署的MQ服务端。
当你刚刚为公司的一个Web应用实现了一个很棒的注册模块。它看起来简洁、高效。在你沾沾自喜的时候，你的leader对你说，现在咱们需要在注册成功后对用户发送一条短信。过了一段时间后，你的leader又对你说，现在咱们需要在注册成功后对用户发送一条邮件，点击邮件中的激活链接后才算是真正的注册成功。又过了一段时间，你的leader又对你说，现在咱们需要在注册成功后对用户发送一条成功赠送金币的迎新消息。又过了一段时间后…
一、缘起 一切脱离业务的架构设计与新技术引入都是耍流氓。 引入一个技术之前，首先应该解答的问题是，这个技术解决什么问题。 就像微服务分层架构之前，应该首先回答，为什么要引入微服务，微服务究竟解决什么问题（详见《互联网架构为什么要做微服务？》）。 最近分享了几篇MQ相关的文章： 《MQ如何实现延时消息》 《MQ如何实现消息必达》 《MQ如何实现幂等性》 不少网友询问，究竟什么时候使用MQ，MQ究竟适合什么场景，故有了此文。 二、MQ是干嘛的 消息总线（Message Queue），后文称MQ，是一种跨进程的通
一天，阿强接到一个需求，将公网的服务的执行结果通知到内网的服务上。阿强一想，很简单阿，只要在公网搭一个简单的消息服务，给公网系统提供一个存储消息接口；给内网系统提供一个查询消息接口，消息存在 mysql。内网服务跑个定时器，轮询查询接口。他麻溜的搭好服务，实现业务并通过自测。嗯，奈斯。
任何脱离业务的组件引入都是耍流氓。引入一个组件，最先该解答的问题是，此组件解决什么问题。
消息队列（Message Queue），是一种跨进程的通信机制，用于上下游传递消息。
image.png 一般采用“回调网关+MQ”方案来解耦： a、调用方直接跨公网调用微信接口 b、微信返回调用成功，此时并不代表返回成功 c、微信执行完成后，回调统一网关 d、网关将返回结果通知MQ e、请求方收到结果通知
晚上把公司应用的架构结合之前研究的东西梳理了下，整理了一张架构规划图，贴在这里备份 下面是个人理解的做架构的几个要点： 1、系统安全 这是首要考虑的，以这张图为例，网络划分为3个区： a) DMZ区可
秒杀系统的设计是高级职位面试中非常高频的一道题目，它可以较好地考察候选人的知识体系情况。对于我们来说，学习秒杀系统的设计，能够让我们学以致用，设计系统的时候考虑得更加全面。今天就让树哥带你一起来看看怎么设计一个秒杀系统！
消息队列这种技术主要用在分布式设计当中，其实可以说是一种设计模式。是相对同步系统而言的。同步系统是什么呢？ 同步，是当所有的操作都完毕，才会返回结果，比如用户支付，如果是同步的话就是当用户所发起的支付操作，然后只有等支付的这个业务成功然后才给用户返回结果说支付成功，但是分布式的异步就不一样了， 异步的话它并不是等一套操作全部完成才会返回结果。用户发起支付操作，那么这个操作会立马返回给用户您已经支付成功，然后后面具体的支付扣款以及转账数据等等的操作是自己独立完成的。用户发起支付后，我们只要把这个支付的消息告诉后面的操作，说用户支付了，后面的操作逻辑我就不管了，我现在立马给用户返回信息，让用户及时得到反馈。这就是异步。
消息队列这种技术主要用在分布式设计当中，其实可以说是一种设计模式。是相对同步系统而言的。同步系统是什么呢？
前言:JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。
腾讯云中间件 - 微服务团队产品2021年10月简报： API网关：正式发布云原生网关 ，完美兼容开源 Kong 网关，为您幅度降低网关建设成本；支持条件路由插件，支持自定义认证/请求体插件。 微服务引擎 TSE ：发布子产品服务注册中心、配置中心、治理中心。支持一键创建、免运维、高可用、开源增强的组件托管服务。 消息队列 TDMQ： 支持开源RabbitMQ备用交换机能力；支持客户端代码声明功能，原Spring内置客户端使用MQ的客户可以无缝迁移至TDMQ; 支持独占消费、支持集群维度的数据统计
近期，收到学生反馈，说是收到了阿里的offer，还给到了48.8W的年薪，仔细跟学生聊了一下，才知道这位学生大学并非是计算机专业，知道自己与计算机专业学生的区别；
最近有个网友在问腾讯云主机的公网IP总在变为什么不能固定下来。 经过了解此用户是购买腾讯云主机用于测试和临时搭建网站，所以计费方式是“按量计费”和“竞价实例” 当云主机重启时就会出现网友反馈的问题公网IP会变化，那是否有方法让公网IP不变？ 这里推荐两种方式：
nat协议做ip地址映射，实现网段映射，ip/nat打洞技术（hole punching）
Q：我的主机上已经有公网IP了, 为何不能访问Web控制台? A： 因为服务默认只监听内网网卡, 需要更改配置文件来监听公网IP 编辑/etc/goodrain/docker-compose.yaml
Android微信智能心跳方案 http://mp.weixin.qq.com/s?__biz=MzAwNDY1ODY2OQ==&mid=207243549&idx=1&sn=4ebe4beb8123
我们先来看看这张图，首先我们可以思考一下，这个架构中，哪些地方可以做负载均衡，来承载更高的 QPS 呢？
压测是目前科技企业及传统企业进行系统容量评估、容量规划的最佳实践方式，本文将基于京东ForceBot平台在大促(京东618、京东双11)备战中的实践历程，给大家分享平台在压测方面的技术变革。ForceBot平台是一款分布式性能测试平台，能够为全链路压测构造千万量级的压测流量，并结合全域流量录制回放、瞬时发压、智能寻点等能力，为整站容量评估与规划提供一站式的解决方案。
红色 Queue：绑定的是 usa.# ，因此凡是以 usa. 开头的 routing key 都会被匹配到 黄色 Queue：绑定的是 #.news ，因此凡是以 .news 结尾的 routing key 都会被匹配,
这个模式和之前的相比还是有一点的变化，我们还是去官网去看这个模型图。首先是必要的生产者和消费者，中间的X代表交换机，这里我们会用到交换机，然后这里有两个队列，然后在分发给两个消费者。
MQ是消息服务中间件，基于高可用分布式集群技术，是消费模式基于发布订阅模式的消息系统。支持Java，C++以及.NET，PHP，Python，为分布式应用系统提供异步解耦、削峰填谷的能力，具备海量消息堆积、高吞吐、可靠重试等特性。具有消息查询，消息回溯(不是消息撤回，也不支持消息撤回)，消息轨迹查询，堆积监控报警功能。 MQ协议支持接入方式 : TCP、HTTP(RESTful 风格)、MQTT。MQ支持公网访问，但可用性较低。 MQ应用场景 : 分布式事务，物联网应用，实时计算(将产生的数据实时流入到实时计算引擎来实现)，同步大规模缓存。 实时计算引擎一般有 : Spark / Storm / EMR / ARMS / BeamRunner。 MQ拥有管理工具 : Web控制台，Open API，mqadmin命令集。拥有微消息队列(LMQ)，RocketMQ消息队列，Kafka消息队列，跨域中继服务(CRS)等组件。 Web控制台提供消息查询、消息轨迹查询、重置消费位点、资源统计、监控报警等操作。消息查询有三种方式 :** 根据Message ID(精确查询)，Message Key(模糊查询)以及Topic查询(范围查询)，HTTP消息目前只支持Message ID和Topic两种查询方式。** 消息轨迹查询只支持TCP和HTTP协议，可追踪消息从生产者发出到消费者消费的整个链路中各个相关节点的时间地点。 重置消费位点可跳过堆积的消息，即不想消费这部分消息，或者只想消费某个时间点后的消息（这些消息不论之前是否消费过）。 资源报表可对消息发送和消息消费的数据进行统计，暂不支持HTTP消费数据的统计查询。 监控报警一般用在消息堆积数或者延迟时间超过阈值之后，对报警接收人发送短信，如果发现消息堆积很多，可检查阈值是否设置过小导致消息堆积，可调整业务代码或者对消费者进行扩容，可使用jstack查看是否消费线程阻塞。 微消息队列(LMQ)基于MQTT(Message Queuing Telemetry Transport 消息队列遥测传输)协议，标准协议端口为1883，支持加密SSL，WebSocket，Flash接入方式。协议重要部分主要分为 : MQ Core Service(负责底层的消息存储和分发)，MQ私有协议服务器以及MQTT协议网关服务器(负责对客户端提供服务和协议转换)。主要使用场景有 : 直播互动、车联网、金融支付、即时聊天等。协议相关 : QoS(Quality of Service)指代消息传输的服务质量。它包括QoS0(最多分发一次)、QoS1(至少达到一次)和QoS2(仅分发一次)三种级别。cleanSession标识客户端建立TCP连接后是否关心之前状态(true or false)。 MQTT可进行实例管理(查看消息收发TPS、同时在线连接数、订阅关系数等信息，可设置实例报警)，可申请MQTT Topic，可为Topic申请MQTT Group ID(一组逻辑功能完全一致的节点共用的组名，代表一类相同功能的设备，必须拥有Topic的读写权限)。可进行签名计算和签名生成。 MQTT可获取离线消息，可主动拉取离线消息，客户端每次拉取消息数量最多为30条，拉取请求的最大频率限制为5次/秒。离线消息优先级低，对其进行有限和最终能处理即可，要求比较实时。 MQTT可获取客户端上下线事件(上下线事件触发时，会向后端MQ推送一条上下线消息，通过订阅这条消息获取)，上下线事件类型一般放在MQ的Tag中，有三种状态 : connect(客户端上线)，disconnect(客户端主动断开连接)，tcpclean(实际的TCP连接断开)。tcpclean代表客户端网络层连接的真实断开，判断客户端下线请使用tcpclean事件。 MQTT通过Token鉴权服务向客户端提供访问权限。客户端需要采用MQTT控制报文以同步发送模式并且QoS必须为1，来上传Token。客户端应该对Token做好持久化，监听Proxy下推的Token失效的通知消息，Token失效必须重新申请。 LMQ的Topic，ClientId长度最大为64个字符，消息大小最大为64K，消息保存时间最长为3天，单个客户端订阅Topic数量最大为30个(超过该限制数量的Topic会被丢弃)，消息顺序性为上行顺序。 跨域中继服务(CRS，跨域哦，实现服务发布与订阅，实现不同网络的服务互通)提供三种MQ消息发送方式 :可靠同步发送(发出消息响应后才能发下一个消息，应用场景广，如重要通知邮件、报名短信通知、营销短信系统)，可靠异步发送(不需要等待响应即可发下一个消息，应用场景一般是耗时长，对RT响应敏感的业务，如视频上传后通知转码服务，转码后通知推送转码结果)，One Way(单向发送，不需要响应的方式，耗时超短，对可靠性要求不高的场
工作队列模式就是一个生产者，两个消费者。在初步入门的Hello World简单模式里面我们了解到。简单模式就是一个生产者一个消费者，中间通过中间件进行消息通信。
腾讯云中间件 - 微服务团队产品2021年2月简报： 腾讯云微服务引擎 TSE 邀您内测 消息队列 CKafka 支持跨可用区部署；支持实例升配展示进度；专业版全面放开公网路由接入；专业版现已加入免费试用序列邀您开通体验 腾讯微服务观测台 TSW 新版本发布邀您内测，新增接口、实例维度的监控、统计、异常分析能力；新增 SQL/NoSQL 分析能力；新增服务依赖拓扑清爽过滤能力；支持调用链详情展示堆栈 整理 by 中间件小Q妹 产品最新动态 01 腾讯云微服务引擎 TSE ■ 什么是 TSE
Netmaker 是一个用来配置 WireGuard 全互联模式的可视化工具，它的功能非常强大，不仅支持 UDP 打洞、NAT 穿透、多租户，还可以使用 Kubernetes 配置清单来部署，客户端几乎适配了所有平台，包括 Linux, Mac 和 Windows，还可以通过 WireGuard 原生客户端连接 iPhone 和 Android。
最近几年，互联网公司发展迅速，有很多互联网公司本身的基础架构都构建在一些公有云厂商之上，除了节省初期投资之外，另外也是借助于一些大的云厂商本身的网络能力，实现业务更好的覆盖。
本文翻译自 KubeCon+CloudNativeCon Europe 2022 的一篇分享：Better Bandwidth Management with eBPF。
消息队列是在工作中作为服务解耦和消息推送等各种场景的应用中使用的组件，常用的队列组件有
导语 Apache Pulsar是Yahoo开源的MQ解决方案，功能上跟Kafka、RocketMQ、TubeMQ等类似，同时支持多租户、读写分离、跨地域复制等特性。联邦学习作为新一代人工智能基础技术，通过解决数据隐私与数据孤岛问题，重塑金融、医疗、城市安防等领域。本文将介绍Pulsar在Angel PowerFL 联邦学习平台中的应用，探索MQ和联邦学习的跨界合作过程。 01 背 景 Angel PowerFL联邦学习平台及其通信模块要求 Angel PowerFL联邦学习平台构建在Angel之
路由的这种模式和发布订阅的模式相比多了一个路由的环节。要求队列在绑定在绑定到交换机的时候指定到对应的路由。路由的作用是什么呢？作为一种分发的规则。可以按照相应的条件指定和分发。
本文的宗旨在于通过简单干净实践的方式教会读者，使用 Docker 部署 Kafka 以及 Kafka 的管理后台，同时基于 DDD 工程使用 Kafka 消息。这里有一个非常重要的点，就是怎么优雅的在 DDD 工程结构下使用 MQ 消息。
跨公网传输备份文件是运维和DBA们经常干的活，但是未经加密的压缩文件在公网上传输，就好比在亚龙湾裸泳，稍不留神就被拍啊，哈哈！本文主要描述通过openssl结合gzip与tar命令来实现加密，再传输那就安心多了。
创建cvm可以参考官网文档，本文主要演示如果在腾讯云cvm上配置一个主网卡与两个辅助网卡。作者已经购买好cvm和弹性公网ip，这里提前给出规划的ip与网卡对应关系：
最近乱七八糟的忙，没有收获但感觉还挺累的，好操蛋。趁周末介绍几款在办公网扫描的小工具，亲测效果还不错，小巧迅速，功能强大，导出的报告也是干净整洁没什么花里胡哨的的东西，缺点是没怎么隐匿自己的流量，如果碰到蜜罐肯定要栽的，但是相比nmap来讲，他们实在太快太香。
双 11 期间入手了一台云服务器,备案花了一两个星期,这两天终于备案通过了.于是在个人服务器上装了 Docker 容器用于部署项目,准备尽量把所有的服务都打包成容器,方便统一管理运维.
之前我们了解了一些验证码的处理流程，比如图形验证码、滑块验证码、点选验证码等等，但是这些验证码都有一种共同的特点，那就是这些验证码的处理流程通常只需要在 PC 上完成即可，比如图形验证码如果在 PC 上出现，那么在 PC 上直接验证通过就好了，所有的识别、验证输入的流程都是在 PC 上完成的。
博主毕业4年了，最近秋招开始了，每次回想起自己的秋招，都感觉到当时自己特别的可惜（菜是原罪）,自己当时简历上面的项目，只有一个 农资电商平台,当时的秒杀系统还没有那么普及（简历人均秒杀系统）。
Apple App Store ：Apple iOS 客户端 Google Play ：Android 客户端 Apple MacOS (OS X): 客户端 Windows 8/10: 客户端
创建maven项目相信看到这的oscer都会，这里就不赘述，主要贴出一些配置文件(限于篇幅随意贴了点，全部的请看github上)。
LVS，Linux Virtual Server LVS是章文嵩博士发起的自由软件项目，它的官方站点是http://www.linuxvirtualserver.org。LVS工作在内核空间，实现TCP/IP协议群的四层路由，在Linux2.4内核以前，使用LVS时必须要重新编译内核以支持LVS功能模块，但从Linux2.4内核以后已经完全内置了LVS的各个功能模块，无需给内核打任何补丁，可以直接使用LVS提供的各种功能。
煤老板和IT精英相遇，两个人想比比谁更富有，但都不愿告诉对方自己真正拥有多少财富，也不想让第三方掌握原始信息。何解？
Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO replication）、快速扩容、灵活容错等特性。在很多场景下，用户需要通过 MQ 实现消息的重新推送能力，比如超时重推、处理异常时重推等，本文介绍 Apache Pulsar 提供的几种消息重推方案。
运维人员恶意删除核心数据这种操作确实是有可能发生，但是在正常情况下又不应该发生。当然由于管理的不规范、权限的控制等问题依然可能造成某些人员恶意或非恶意的制造出‘删库跑路’事件。
Fedration插件用来在不同的RabbitMQ集群之间复制队列消息，集群可以是内网也可以是公网，而这些对应用来说是透明的，即应用不会感知到，也不需要编写相关代码。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
