消息 通讯socket
RocketMQ源码(五)：RocketMQ消息存储流程
在RocketMQ源码(四)：RocketMQ生产者发送消息流程中已经对生产者同步发送消息的源码做了分析，下面继续分析，消息发送到Broker做了哪些处理。 一、Broker处理请求消息的入口 在RocketMQ源码(三)：RocketMQ服务端启动流程中提到，在启动BrokerControler流 ......
【RocketMQ】消息的拉取总结
在上一讲中，介绍了消息的存储，生产者向Broker发送消息之后，数据会写入到CommitLog中，这一讲，就来看一下消费者是如何从Broker拉取消息的。 RocketMQ消息的消费以组为单位，有两种消费模式： 广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。 ......
Jmeter获取Websocket多帧消息的实现方法
由于需要对WebSocket进行压力测试，因此又回归到了JMeter的使用。网络上缺少具体的获取多帧消息的操作，且自己也踩了两个坑，总结一下可行的操作供大家参考。 一、情况说明 被测试的WebSocket会根据客户端发起的信息进行回复，回复帧数不确定。现在需要把所有回复的内容都获取到 二、工具 经过 ......
【1.0】消息队列引入
【一】什么是消息队列 消息队列是一种基于"先进先出"（FIFO）原则的数据结构，用于在分布式系统中进行异步通信和解耦功能模块。 它提供了一种可靠的方式来传递和存储消息，确保消息在发送和接收之间的可靠性和顺序性。 【二】消息队列解决什么问题 【1】应用解耦 通过消息队列，可以将单体应用拆分成多个小功能 ......
【4.0】RabbitMQ使用之消息安全
【一】消息安全之ack ACK是一种确认机制，用于确保消息在消费者接收后被正确处理。 当消费者接收到消息并成功处理时，它发送一个ACK（Acknowledgement）给生产者，表示消息已经处理完毕。 只有在收到ACK之后，生产者才会从队列中删除该消息。 我们使用RabbitMQ作为消息中间件，并通 ......
集线器 SignalR.Core 消息推送实例
SignalR.Core 消息推送实例 public class ChatHub : Hub { private string _className = "ChatHub"; //private System.Threading.Timer timer = null; private System. ......
socket 编程
采用 socket 实现服务端和客户端通信 server.c #include <arpa/inet.h> #include <netinet/in.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys ......
9 UDP 消息发送
没有客户端和服务端这一说法 package Internet; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketExc ......
通讯 --- C# .NET CORE MQTT 心跳服务
MQTT 服务可以自行学习，这里只是记录一下写的结果，粘贴即用。 首先引入包 MQTTnet ，注意 这个包这里的代码 是 4.0一下版本 我用的 3.1.2 版本的 4.以上是另外的写法，该内容中4 不支持我 直接下降版本到3.1.2 可以了。 如果你一定要用4.0以上的包，不用往下看了。 服务端 ......
如何实现每天定时给女友/老婆发消息
> 有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步,认准`https://blog.zysicyj.top` [首发博客地址](https://blog.zysicyj.top/) 开源地址：https://github.com/zysicyj/Vitality-reminde ......
关于 Commerce 启动时遇到的错误消息 failed to initialize connector HTTP 9001
使用命令行 `install.bat -r cx-for-spa start` 启动 commerce 实例时，遇到下列错误消息： > SEVERE: Failed to initialize connector [Connector HTTP/1.1-9001]  Appid , AppSecret 配置: 微信公众平台修改: 授权回调地址域名 ......
python socket编程
python socket编程 server 端： # coding: utf-8 """ 搭建简单服务器 """ import socket HOST = '127.0.0.1' # 获取本地主机名,cmd下用ipconfig命令查看 PORT = 12345 # 设置端口号 ADDR = (HO ......
消息中间件如何避免重复消费消息
常见方法： 消息中间件通常采用一些策略来避免消息的重复消费。这在分布式系统中非常重要，以确保消息被处理一次且仅一次，避免产生错误或重复的结果。以下是一些常见的方法： 消息确认机制：消费者在处理完一条消息后，向消息中间件发送确认消息。如果消息中间件收到确认，就会将该消息标记为已消费，如果没有收到确认， ......
揭秘vivo百亿级厂商消息推送平台的高可用技术实践
本文将要分享的是vivo技术团队针对消息推送系统的高并发、高时效、突发流量等特点，从长连接层容灾、逻辑层容灾、流量容灾、存储容灾等方面入手，如何保证百亿级厂商消息推送平台的高可用性的。 ......
MQTT vs. XMPP，哪一个才是IoT通讯协议的正解
MQTT vs. XMPP，哪一个才是IoT通讯协议的正解 MQTT vs. XMPP，哪一个才是IoT通讯协议的正解 这是个有趣的话题！先来聊几个小故事。 关于我和MQTT 我在人生第一个IoT项目里，第一次接触到MQTT协议。我很快就理解了这个协议。因为，它和企业开发用的MQ产品实在是太像了。在 ......
Win32编程之消息机制(二)
一、Windows的消息概念 1.消息组成： 窗口句柄 消息ID 消息的两个参数(两个附带信息) 消息产生的时间 消息产生时鼠标位置 typedef struct tagMSG { HWND hwnd; UINT message; WPARAM wParam; LPARAM lParam; DWOR ......
消息队列从基础到架构思维导图
本篇思维导图为RabbitMQ从基础知识到进阶知识的梳理，重点讲述了如何保证可靠性传递（消息不丢失），如何保证消息不重复消费，如何保证消息顺序消费，如何保证消息队列的高可用，如何解决消息积压问题，希望对你有帮助！如果需要xmind格式请留言，转发使用请标记来源，感谢！ ......
24.SOCKET编程
# 24.SOCKET编程 传统的进程间通信借助内核提供的IPC机制进行，但是只能限于本机通信，若要跨机通信，就必须使用网络通信。( 本质上借助内核-内核提供了socket伪文件的机制实现通信 实际上是使用文件描述符)，这就需要用到内核提供给用户的socket API函数库。  [MQ系列2：消息中间件的技术选型](https://www.cnblogs.com/wzh2010/p/15311174.htm ......
vue使用socket.io
# Vue 项目使用socket.io 使用library *socket.io-client* 或者 *vue-socket.io* npm install socket.io-client || npm install vue-socket.io ## 使用*socket.io-client* ......
MQTT vs. XMPP，哪一个才是IoT通讯协议的正解
我对MQTT还是非常熟悉的，我用它做过IoT应用，开发过IoT产品。
我对XMPP应该说算是精通了，我写过XMPP基础开发库、XMPP服务器、实现过XMPP的各种标准，并基于XMPP做了了IoT开发平台。
我尝试客观的来评价这两种协议，如果抛开我更擅长XMPP，以及Lithosphere基于XMPP... ......
单片机通讯协议
串口通讯： 特点： 规定了UART帧格式：起始位0 + 5-8位数据位 + 校验位(可有可无) + 停止位 RS232: 特点： 逻辑 "1" 电平 -5v～-15v；逻辑 "0" 电平 +5v～+15v； 缺点： 接口电平高，易损坏接口电路芯片 与TTL电平不兼容，需要用电平转换芯片，增加成本 通 ......
tkinter.messagebox --- Tkinter 消息提示
tkinter.messagebox Tkinter 消息提示 源代码: Lib/tkinter/messagebox.py tkinter.messagebox 模块提供了一个模板基类以及多个常用配置的便捷方法。 消息框为模式窗口并将基于用户的选择返回 (True, False, OK, None ......
Java Socket IO流关闭问题: Exception in thread "main" java.net.SocketException: Socket is closed
## 先说结论 问题: 明明执行的语句在`socket.close`前, 却出现**Exception in thread "main" java.net.SocketException: Socket is closed**报错 结论: 在Java中关闭一个包装流会导致它的底层流也被关闭所以一般使 ......