当前位置：首页 > news >正文

【RabbitMQ】实现RPC通信的完整指南

news 来源：原创 2025/6/22 22:59:11

文章目录

- RPC 通信
- 创建相关队列
- 客户端代码
- - 声明队列
  - 发送请求
  - 接收响应
  - 完整代码
- 服务端代码
- - 设置同时只能获取一个消息
  - 接收消息
  - 完整代码
- 运行程序
- - 启动客户端
  - 启动服务端

RPC 通信

RPC (Remote Procedure Call), 即远过程调用。它是一种通过网络从远程计算机上请求服务，而不需要了解底层网络的技术

类似 Http 远程调用

RabbitMQ 实现 RPC 通信的过程，大概是通过两个队列实现一个可回调的过程

注意
- 没有生产者和消费者，取而代之的是客户端和服务器
- reply_to：回调队列的名称
- correlation_id：不能重复，用来确保请求和响应是一对
大概流程：
1. 客户端发送消息到一个指定的队列，并在消息属性中设置 replyTo 字段，这个字段制定了一个回调队列，服务端处理之后，会把响应结果发送到这个队列
2. 服务端收到请求后，处理请求并发送响应到 replyTo 指定的回调队列
3. 客户端再回调队列上等待响应消息，一旦收到响应，客户端会检查消息的 correlationID 属性，以确保它是所期望的响应
  - 等待响应消息，是通过一个阻塞队列来实现
  - 如果没有响应进来，就会一直阻塞。通过一个阻塞队列，来让其等待响应完成
  - 如果阻塞队列里面没有消息，就会一直等待，等到有消息为止

大致流程：

客户端：
1. 发送请求（携带 replyTo、CorrelationID）
2. 接收响应（校验 correlationID）
服务端：
1. 接收请求，进行响应
2. 发送响应（按照客户端指定的 replyTo，设置 correlationID）

创建相关队列

public static final String RPC_REQUEST_QUEUE = "rpc.request.queue";  public static final String RPC_RESPONSE_QUEUE = "rpc.response.queue";

涉及到两个队列
- 请求队列
- 响应队列

客户端代码

客户端代码主要流程如下：

声明两个队列，包含回调队列 RPC_REQUEST_QUEUE，声明本次请求的唯一标志 correlationID
将 RPC_REQUEST_QUEUE 和 correlationID 配置到要发送的消息队列中
使用阻塞队列来阻塞当前进程，监听回调队列中的消息，把请求放到阻塞队列中
使用阻塞队列有消息后，主线程被唤醒，打印返回内容

声明队列

channel.queueDeclare(Constants.RPC_REQUEST_QUEUE, true, false, false, null);  
channel.queueDeclare(Constants.RPC_RESPONSE_QUEUE, true, false, false, null);

发送请求

//发送请求(使用内置交换机)  
String msg = "hello rpc...";  
//设置请求的唯一标识  
String correlationID = UUID.randomUUID().toString();  
//设置请求的相关属性  
AMQP.BasicProperties props = new AMQP.BasicProperties().builder()  .correlationId(correlationID)  .replyTo(Constants.RPC_RESPONSE_QUEUE)  .build();  
channel.basicPublish("", Constants.RPC_REQUEST_QUEUE, props, msg.getBytes());

接收响应

使用阻塞队列，来存储回调结果

// 接收响应  
// 如果不阻塞，就会从上到下执行完了。所以要使用一个阻塞队列，完成同步机制  
final BlockingQueue<String> response = new ArrayBlockingQueue<>(1);  
DefaultConsumer consumer = new DefaultConsumer(channel){  //逻辑是比对 correlationID 是否一致  @Override  public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  String respMsg = new String(body);  System.out.println("接收到回调信息：" + respMsg);  if (correlationID.equals(properties.getCorrelationId())) {  // 如果 correlationID 校验一致，说明就是我们要的响应  response.offer(respMsg);  }  }  
};  
channel.basicConsume(Constants.RPC_RESPONSE_QUEUE, true, consumer);  // 获取回调的结果
String result = response.take(); //阻塞队列一直阻塞到这里，直到 response 有值了  
System.out.println("[RPC Client 响应结果]: " + result);

完整代码

package rabbitmq.rpc;  import com.rabbitmq.client.*;  
import rabbitmq.constant.Constants;  import java.io.IOException;  
import java.util.UUID;  
import java.util.concurrent.*;  /**  * RPC Client * 1. 发送请求  * 2. 接收响应  */  
public class RpcClient {  public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {  //1. 建立连接  ConnectionFactory connectionFactory = new ConnectionFactory();  connectionFactory.setHost(Constants.HOST);  connectionFactory.setPort(Constants.PORT);  connectionFactory.setUsername(Constants.USER_NAME);  connectionFactory.setPassword(Constants.PASSWORD);  connectionFactory.setVirtualHost(Constants.VIRTUAL_HOST);  Connection connection = connectionFactory.newConnection();  //2. 开启信道  Channel channel = connection.createChannel();  //3. 声明队列  channel.queueDeclare(Constants.RPC_REQUEST_QUEUE, true, false, false, null);  channel.queueDeclare(Constants.RPC_RESPONSE_QUEUE, true, false, false, null);  //4. 发送请求(使用内置交换机)  String msg = "hello rpc...";  //设置请求的唯一标识  String correlationID = UUID.randomUUID().toString();  //设置请求的相关属性  AMQP.BasicProperties props = new AMQP.BasicProperties().builder()  .correlationId(correlationID)  .replyTo(Constants.RPC_RESPONSE_QUEUE)  .build();  channel.basicPublish("", Constants.RPC_REQUEST_QUEUE, props, msg.getBytes());  //5. 接收响应  // 如果不阻塞，就会从上到下执行完了。所以要使用一个阻塞队列，完成同步机制  final BlockingQueue<String> response = new ArrayBlockingQueue<>(1);  DefaultConsumer consumer = new DefaultConsumer(channel){  //逻辑是比对 correlationID 是否一致  @Override  public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  String respMsg = new String(body);  System.out.println("接收到回调信息：" + respMsg);  if (correlationID.equals(properties.getCorrelationId())) {  // 如果 correlationID 校验一致，说明就是我们要的响应  response.offer(respMsg);  }  }  };  channel.basicConsume(Constants.RPC_RESPONSE_QUEUE, true, consumer);  String result = response.take(); //阻塞队列一直阻塞到这里，直到 response 有值了  System.out.println("[RPC Client 响应结果]: " + result);  }  
}

服务端代码

服务端代码主要流程如下：

接收消息
根据消息内容进行相应处理，把应答结果返回到回调队列中

设置同时只能获取一个消息

//设置一次只能接收一条消息  
channel.basicQos(1);

如果不设置 basicQos，RabbitMQ 会使用默认的 Qos 设置，其 prefetchCount 默认值为 0

当 prefetchCount 为 0 时，RabbitMQ 会根据内部实现和当前的网络状况等因素，可能会同时发送多条消息给消费者
这意味着在默认情况下，消费者可能会同时接收到多条消息，但具体数量不是严格保证的，可能会有所波动

在 RPC 模式下，同上期望的是一对一的消息处理，即一个请求对应一个相应。消费者在处理完一个消息并确认之后，才会接收到下一条消息

接收消息

接收消息，并做出相应处理

DefaultConsumer consumer = new DefaultConsumer(channel) {  @Override  public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  String request = new String(body, "UTF-8");  System.out.println("接收到请求：" + request);  String responses = "针对 request：" + request + "，响应成功";  AMQP.BasicProperties basicProperties = new AMQP.BasicProperties().builder()  .correlationId(properties.getCorrelationId())  .build();  channel.basicPublish("", Constants.RPC_RESPONSE_QUEUE, basicProperties, responses.getBytes());  channel.basicAck(envelope.getDeliveryTag(), false);  }  
};  
channel.basicConsume(Constants.RPC_REQUEST_QUEUE, false, consumer);

RabbitMQ 消息确定机制

在 RabbitMQ 中，basicConsume 方法的 autoAck 参数用于指定消费者是否应该自动向消息对类确认消息
- 自动确认（autoAck=true）：消息对类在将消息发送给消费者之后，会立即从内存中删除该消息。这意味着，如果消费者处理消息失败，消息将丢失，因为消息队列认为消息已经被成功消费
- 手动确认（autoAck=false）：消息队列在将消息发送给消费者之后，需要消费者显式地调用 basicAck 方法来确认消息。手动确认提供了更高的可靠性，确保消息不会意外丢失，适用于消息处理重要且需要确保每个消息都被正确处理的场景

完整代码

package rabbitmq.rpc;  import com.rabbitmq.client.*;  
import rabbitmq.constant.Constants;  import java.io.IOException;  
import java.util.concurrent.TimeoutException;  /**  * RPC server * 1. 接收请求  * 2. 发送响应  */  
public class RpcServer {  public static void main(String[] args) throws IOException, TimeoutException {  //1. 建立连接  ConnectionFactory connectionFactory = new ConnectionFactory();  connectionFactory.setHost(Constants.HOST);  connectionFactory.setPort(Constants.PORT);  connectionFactory.setUsername(Constants.USER_NAME);  connectionFactory.setPassword(Constants.PASSWORD);  connectionFactory.setVirtualHost(Constants.VIRTUAL_HOST);  Connection connection = connectionFactory.newConnection();  //2. 开启信道  Channel channel = connection.createChannel();  //3. 接收请求  //设置一次只能接收一条消息  channel.basicQos(1);  DefaultConsumer consumer = new DefaultConsumer(channel) {  @Override  public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  String request = new String(body, "UTF-8");  System.out.println("接收到请求：" + request);  String responses = "针对 request：" + request + "，响应成功";  AMQP.BasicProperties basicProperties = new AMQP.BasicProperties().builder()  .correlationId(properties.getCorrelationId())  .build();  channel.basicPublish("", Constants.RPC_RESPONSE_QUEUE, basicProperties, responses.getBytes());  channel.basicAck(envelope.getDeliveryTag(), false);  }  };  channel.basicConsume(Constants.RPC_REQUEST_QUEUE, false, consumer);  }  
}

运行程序

启动客户端

启动服务端

运行服务端

接收到请求：hello rpc...

【RabbitMQ】实现RPC通信的完整指南

文章目录 RPC 通信创建相关队列客户端代码声明队列发送请求接收响应完整代码服务端代码设置同时只能获取一个消息接收消息完整代码运行程序启动客户端启动服务端 RPC 通信 RPC (Remote Procedure Call), 即远过程调用。它是一种通过网络从远程计算机上请求服务，而…...

编程日记 2025/6/22 22:59:11

CK3588下安装linuxdeployqt qt6 arm64

参考资料： Linux —— linuxdeployqt源码编译与打包（含出错解决） linux cp指令报错：cp: -r not specified； cp: omitting directory ‘xxx‘（需要加-r递归拷贝） CMake Error at /usr/lib/x86_64…...

编程日记 2025/6/22 21:58:35

滑动窗口之二(优先队列)

原本滑动窗口的板子用的是数组和双指针模拟，我嫌麻烦还不好懂找了双端队列。但其实还是不太好使，比如今天的这道题就处理起来很麻烦。但是如果用优先队列的话就可以一直保证整个窗口是有序的，只需判断一下是否在窗口内即可。但是！…...

编程日记 2025/6/22 22:31:40

小刚说C语言刷题—1088求两个数M和N的最大公约数

1.题目描述求两个正整数 M 和 N 的最大公约数(M，N都在长整型范围内） .输入输入一行，包括两个正整数。输出输出只有一行，包括1个正整数。样例输入 45 60 输出 15 2.参考代码(C语言版) #include <stdio.h> …...

编程日记 2025/6/22 22:31:41

pytorch训练可视化工具---TensorBoard

一、目的：为什么使用 TensorBoard 调控模型使用 TensorBoard 可以帮我们： 实时查看 loss / acc 曲线 → 判断是否过拟合、欠拟合； 对比不同模型或超参数的效果； 可视化模型结构 → 帮助调试模型设计； 查看权重/梯…...

编程日记 2025/6/22 22:54:18

丝杆升降机限位失灵深度剖析：从故障机理到智能监测方案

在工业自动化与精密机械传动领域，丝杆升降机凭借高精度、大推力的特性，成为产线设备的核心执行部件。然而，限位系统的可靠性直接决定设备安全运行与生产连续性。本文将从技术原理、故障诊断到智能监测方案，系统性解析丝杆升降机限…...

编程日记 2025/6/22 21:06:04

系统集成项目管理工程师学习笔记

第九章项目管理概论 1、项目基本要素项目基础项目是为创造独特的产品、服务或成果而进行的临时性工作。项目具有临时性、独特性、渐进明细的特点。项目的“临时性”是指项目只有明确的起点和终点。“临时性”并一定意味着项目的持续时间短。项目可宣告结束的情况&…...

编程日记 2025/6/22 21:19:29

RDD的自定义分区器-案例

对电商订单数据进行处理，订单数据包含用户 ID 和订单金额，不同地区的用户有不同的 ID 范围。我们会按照地区对订单数据进行分区，这样做能让相同地区的订单数据处于同一分区，便于后续按地区进行统计金额分析。订单数据如下&#x…...

编程日记 2025/6/22 22:42:19

牛客网NC231954:斐波那契数列 (简单的数列问题）

牛客网NC231954:斐波那契数列 (简单的数列问题） 题目描述本题要求我们计算斐波那契数列的第n项，斐波那契数列定义如下： f(1) 1f(2) 1f(n) f(n-1) f(n-2)，当n ≥ 3 给定整数n，求f(n)的值。算法思路斐波那契…...

编程日记 2025/6/22 21:42:23

中国近代史3

辛亥革命 1.同盟会：建立 1905年，东京，第一个全国性的资产阶级革命政党；同盟会纲领“驱除鞑虏，恢复中华，建立民国，平均地权” “民族”“民生”“民权” 2.武昌起义 ①爆发：1911.10…...

编程日记 2025/6/22 21:37:31

晶振的核心参数

目录 1.简介 2.晶振核心参数详解 3.晶振的抖动（jitter） 4.抖动的三种测量方式 5.抖动的其他资料 1.简介再看一些晶振的手册时，经常遇到一些类似或相近的参数，今天借此机会，做一个小姐。 2.晶振核心参数详解 1…...

编程日记 2025/6/22 21:42:24

北京孙河傲云源墅：限量典藏的主城墅居臻品

在限墅令的背景下，北京主城的墅居产品日益稀缺，而傲云源墅作为孙河墅区的杰出之作，凭借其独特的价值，成为了众多高端置业者的理想选择。傲云源墅所处的孙河地区，是北京公认的高价值板块。其地位在 2025 年孙河 2902 …...

编程日记 2025/5/16 12:54:48

驱动-Linux定时-timer_list

了解内核定时相关基础知识文章目录简要介绍timer_list 特点API 函数实验测试程序 - timer_mod.c编译文件-Makefile实验验证注意事项总结简要介绍硬件为内核提供了一个系统定时器来计算流逝的时间（即基于未来时间点的计时方式， 以当前时刻为计时开始…...

编程日记 2025/5/16 12:53:45

从理论到实战：模糊逻辑算法的深度解析与应用实践

从理论到实战：模糊逻辑算法的深度解析与应用实践一、模糊逻辑的核心概念与数学基础模糊逻辑（Fuzzy Logic）是一种处理不确定性的数学工具，其核心思想是将传统布尔逻辑的“非黑即白”扩展为连续的隶属度函数。例如，在…...

编程日记 2025/5/16 12:53:42

涨薪技术|0到1学会性能测试第65课-SQL捕获阻塞事件

前面的推文我们掌握了JVM调优技术。今天给大家分享MS SQL数据库监控与调优技术。后续文章都会系统分享干货，带大家从0到1学会性能测试。 01SQL捕获阻塞事件在SQL Server 2005之前的版本，分析哪些进程产生阻塞以及哪些进程被阻塞，都需要使用脚…...

编程日记 2025/5/16 12:52:40

SQL实战：06交叉日期打折问题求解

文章目录概述题目：交叉打折问题求解题解第一步：使用滑动窗口统计当前活动前的最大结束日期步骤二：拆分出交叉部分步骤三：计算每次活动的持续天数步骤四：分组统计最终结果完整SQL 概述最近刷题时遇到一些比较有意思的…...

编程日记 2025/5/16 12:52:37

Linux云计算训练营笔记day09（MySQL数据库）

Linux云计算训练营笔记day09（MySQL数据库） 目录 Linux云计算训练营笔记day09（MySQL数据库）外键约束数据的导入和导出数据的导出数据的导入 DQL 数据查询语言查指定字段查所有字段where 过滤条件and 和 orin 和 not inbetween...an…...

编程日记 2025/5/16 12:52:36

docker pull nginx docker 将本地nginx快照保存到当前文件夹下 docker save -o nginx.tar nginx:latestdocker 将本地nginx 加载 docker load -i nginx.tar docker运行nginx在80端口 docker run --name dnginx -p 80:80 -d nginxredis启动 docker run --name mr -p 6379:6379 -…...

编程日记 2025/5/16 12:51:33

Kind方式部署k8s单节点集群并创建nginx服务对外访问

资源要求请准备好doker环境，尽量用比较新的版本。我的docker环境如下 docker 环境： Docker version 20.10.21, build 20.10.21-0ubuntu1~18.04.3 安装kind kind表现上就是一个二进制程序，下载对应版本并增加执行权限即可： cu…...

编程日记 2025/5/16 12:51:32

Da14531蓝牙特征值1读没有回调解决

一. 我们调试中发现user_peripheral.c中的回调，一直都没有回调。（大家可以通过打印去排查） void user_catch_rest_hndl(ke_msg_id_t const msgid, void const *param, ke_task_id_t const dest_id, ke_task_id_t const src_id) { //此处省…...

编程日记 2025/5/16 12:51:30

journal of Electronic Imaging(JEI)投稿咨询

研究生投的第二篇论文-CV方向，由于太菜了，到处被拒，最后选择了Journal of Electronic Imaging(JEI) 审稿了三个月，最近突然变了状态，之前催稿说才一个审稿人，这样子是不是要被拒了，有没有知道的…...

编程日记 2025/5/16 12:48:20

upload-labs靶场通关详解：第6-9关

目录第六关：大小写绕过一、分析源代码二、解题思路三、解题步骤第七关：空格绕过一、分析源代码二、解题思路三、解题步骤第八关：点号绕过一、分析源代码二、解题思路三、解题步骤第九关：::$DATA字符串绕…...

编程日记 2025/5/16 12:48:20

算法图表总结：查找、排序与递归（含 Mermaid 图示）

算法图表总结：查找、排序与递归（含 Mermaid 图示） 分类标签：算法、数据结构、Mermaid、技术图表关键词： 算法可视化、Mermaid 图表、数据结构、二分查找、快速排序、递归树摘要： 本文通过 Mermaid 图表…...

编程日记 2025/5/16 12:47:16

在文件检索方面doris和elasticsearch的区别

apache Doris 与 Elasticsearch 在文件检索领域的差异源于技术架构与定位目标的本质区别，以下从核心维度对比分析二者的技术特性：一、 ‌架构设计与定位差异‌ ‌维度‌‌Apache Doris‌‌Elasticsearch‌‌核心架构‌分布式 MPP 列式分析引擎，面向 OLAP 优化分布式倒排索…...

编程日记 2025/5/16 12:45:06

linux系统服务

Linux 系统服务（System Services） 是在后台持续运行的进程（守护进程，即 daemon），用于提供核心功能或支持其他应用程序（如网络管理、日志记录、定时任务等）。它们通常在系统启动时自动…...

编程日记 2025/5/16 12:45:06

大语言模型三大演进方向：记忆增强、工具集成与多模态突破

目录一、方向演进：从通用模型到记忆增强系统 1.1 技术瓶颈分析 1.2 记忆增强技术路径 1.3 企业级应用架构二、工具调用：从语言理解到行动执行 2.1 工具调用协议演进 2.2 工具编排范式比较三、多模态突破：跨模态统一建模 3.1 多模态架构演进 3.2 医学多模态应用…...

编程日记 2025/5/16 12:43:58

嵌入式学习笔记DAY21（双向链表、Makefile)

一、双向链表 1.概念双向链表（Doubly Linked List） 是一种链式数据结构，每个节点包含两个指针（前驱指针 prev 和后继指针 next），分别指向前一个节点和后一个节点，形成双向连接。头节点&…...

编程日记 2025/5/16 12:42:56

Vue 学习随笔系列二十三 -- el-date-picker 组件

el-date-picker 组件文章目录 el-date-picker 组件el-date-picker 只有某些日期可选 el-date-picker 只有某些日期可选 <template><div><el-form ref"form" size"mini":model"form" :rules"rules"label-width"8…...

编程日记 2025/5/16 12:41:46

IEEE出版｜连续多年稳定检索｜第三届信号处理与智能计算国际学术会议(SPIC2025)

【重要信息】会议官网： www.ic-spic.com 会议日期：2025年11月28-30日会议地点：中国广州截稿日期：2025年11月10日接受或拒绝通知日期：提交后7个工作日【征稿主题】人工智能和机器学习计算机系统和架构 …...

编程日记 2025/5/16 12:41:42

用Python代码绘制动态3D爱心效果

引言介绍Python在创意编程中的应用，特别是如何通过简单的代码实现视觉上的美感。引出本文将分享的爱心代码，并简要说明其实现原理。爱心代码的基本实现展示一个简单的Python代码示例，使用字符画的方式在控制台中绘制一个爱心图案。 pr…...

编程日记 2025/5/16 12:40:41

牛客网刷题：NC208813求逆序数

牛客网刷题：NC208813求逆序数问题描述在排序和数据结构分析中，逆序数是一个重要的概念。对于一个数列来说，如果一对数的前后位置与大小顺序相反（即前面的数大于后面的数），那么它们就称为一个逆序对。一个…...

编程日记 2025/5/16 12:40:38

Day 21 训练

Day 21 训练常见的降维算法数据预处理无监督降维PCA（主成分分析）主成分分析（PCA）作用和优势应用场景t-SNE（t-分布随机邻域嵌入）t-SNE（t-分布随机邻域嵌入）为什么 t-SNE 特别适用于高…...

编程日记 2025/5/16 12:40:37

1267, “Illegal mix of collations (latin1_swedish_ci,IMPLICIT

python 执行数据迁移报错 mysql : 1267, "Illegal mix of collations (latin1_swedish_ci,IMPLICIT 解决方法： 替换TABLE 后面的表名为你自己的表名，mysql 黑窗口执行。以下是我的表名，仅作参考 ALTER TABLE book CONVERT TO CHARACTE…...

编程日记 2025/5/16 12:39:34

【C#】Thread.Join()、异步等待和直接join

JogThread.Join() 是 .NET 中 System.Threading.Thread 类的一个方法，用来让当前调用线程暂停执行，直到目标线程（这里是 JogThread）终止为止。以下是它的核心语义和你在 UI 代码里需要注意的几个相关知识点。 1. Thread.Join() 的…...

编程日记 2025/5/16 12:39:33

Malformed input or input contains unmappable characters解决

JDK 17 文件上传编码异常解决方案技术文档 1. 问题背景在 JDK 17 环境下，文件上传过程中可能抛出 Malformed input or input contains unmappable characters 错误。此问题通常由以下原因触发： 文件路径/名称包含非 ASCII 字符（如中文、日…...

编程日记 2025/5/16 12:38:30

PYTHON训练营DAY26

一、函数 （一）不带参数的函数 # 定义一个简单的问候函数 def greet():"""打印一句问候语。"""message "大家好！欢迎学习Python函数定义！"print(message)greet()（二&#x…...

编程日记 2025/5/16 12:38:30

奇变偶不变，符号看象限

三角函数诱导公式口诀详解：奇变偶不变，符号看象限口诀解析 1. 口诀含义奇变偶不变： 奇/偶：指角度加减的是π/2（90）的奇数倍还是偶数倍奇数倍（如π/2, 3π/2）→ 函数名改变&…...

编程日记 2025/5/19 12:47:52

基于SpringBoot的家政服务系统设计与实现(源码+文档+部署讲解）

技术范围：SpringBoot、Vue、SSM、HLMT、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、小程序、安卓app、大数据、物联网、机器学习等设计与开发。主要内容：免费功能设计、开题报告、任务书、中期检查PPT、系统功能实现、代码编写、论文编写和辅导、论文…...

编程日记 2025/5/29 10:35:36

Makefile 在 Go 项目中的实践

在 Go 项目中，Makefile 是一个强大的工具，用于自动化构建、测试和部署流程。它不仅能减少重复命令输入，还能确保团队开发环境的一致性。本文以 CoreDNS（一个高性能 DNS 服务器）的 Makefile 为例，解析其设计…...

编程日记 2025/5/28 16:07:24

关闭所有Nginx进程

要关闭所有Nginx进程，可以使用以下命令。这些命令适用于不同的操作系统。在Linux/Unix系统中在Linux或Unix系统中，可以使用killall命令来关闭所有Nginx进程。 sudo killall nginx 在Windows系统中在Windows系统中，可以使用taskkill命…...

编程日记 2025/5/18 11:14:42

开源模型应用落地-模型上下文协议（MCP）-Resources-资源的使用逻辑

一、前言在大型语言模型与外部世界交互的探索中，如何高效、灵活地接入多样化数据始终是核心命题。MCP（Model Context Protocol）协议中的Resources 机制，正是为这一问题提供了优雅的解决方案。通过URI（统一资源标识符&…...

编程日记 2025/5/29 14:17:05

如何判断一个网站后端是用什么语言写的

判断一个网站的后端是用什么语言写的，可以从以下几个方面入手： 一、通过响应头（HTTP Response Headers） 使用浏览器开发者工具或工具如 curl 查看网站返回的响应头信息，有时可以看到蛛丝马迹： 示例&#…...

编程日记 2025/5/23 19:27:27

CertiK助力以太坊扩展战略，解析Pectra升级的变革与挑战

近期，美国知名金融科技媒体Benzinga发表文章，深入探讨以太坊Pectra升级的变革性影响，并特别引用了CertiK对潜在风险的权威分析，特别是EIP-7702引入的全新信任模型变化。此次升级不仅重新定义了EOA与智能合约的交互方式&#xff0c…...

编程日记 2025/6/2 3:58:55

【C++】Module CPP：模块化编程 Demo

一、C20 模块简介 C20 模块是 C 语言发展史上的重要革新，它从根本上改变了代码组织方式。相比传统的头文件（#include）机制，模块具有以下核心优势： 隔离编译：模块独立编译，避免重复编译头文件符…...

编程日记 2025/5/24 16:08:34

mvc-service引入

什么是业务层 1）Model1（JSP）和Model2（模糊的mvc）: MVC：Model(模型)，View(视图)，Controller（控制器） 视图层：用于数据展示以及用户交互的界…...

编程日记 2025/5/27 4:52:34

Linux线程互斥锁

1. 什么是互斥锁（Mutex）？ 互斥锁（Mutex，Mutual Exclusion） 是一种用于多线程编程的同步机制，用于保护共享资源（如变量、内存、文件等），确保在同一时刻只有一…...

编程日记 2025/5/26 20:07:48

PINN Poisson 1d

📌 一、问题定义我们要求解的微分方程是 d 2 u d x 2 f ( x ) \begin{equation} \frac{d^2 u}{d x^2} f(x) \end{equation} dx2d2uf(x) 其中: f ( x ) − 0.49 s i n ( 0.7 x ) − 2.25 c o s ( 1.5 x ) f(x) -0.49sin(0.7x) - 2.25cos(1.5x) f(x)−…...

编程日记 2025/6/20 16:18:13