RabbitMQ简单使用方法,以异步处理日志为例:

在RabbitMQ中异步记录日志的实现可以分为生产者将日志消息发送到队列,以及消费者从队列中取出消息并记录日志。当搭建好消息队列后,需要确保消费者持续运行,以便随时处理新进入的日志消息

步骤一:设置生产者发送日志消息到RabbitMQ

生产者代码(producer.php):详细代码见此
这段代码会将日志消息发送到RabbitMQ队列中。

步骤二:配置消费者从队列中处理日志消息

消费者代码(consumer.php):详细代码见此
这段代码会持续运行,监听队列并处理日志消息。

步骤二:如何持续运行消费者

为了使消费者持续运行并处理日志消息,可以使用以下几种方法:

方法一:使用系统服务(如systemd)

将消费者脚本配置为systemd服务,这样系统会自动处理消费者进程管理,并确保它在崩溃或重启后仍然运行。

创建systemd服务文件:

  1.在/etc/systemd/system目录下创建服务文件,如rabbitmq_log_consumer.service

[Unit]
Description=RabbitMQ Log Consumer Service
After=network.target[Service]
ExecStart=/usr/bin/php /path/to/consumer.php
Restart=always
User=www-data
Group=www-data[Install]
WantedBy=multi-user.target

  2.重新加载systemd配置,启动并启用服务。

sudo systemctl daemon-reload
sudo systemctl start rabbitmq_log_consumer
sudo systemctl enable rabbitmq_log_consumer
方法二:使用Supervisor

Supervisor是一个进程管理工具,可以用来管理消费者进程。

安装Supervisor

在Ubuntu上,可以通过以下命令安装Supervisor:

sudo apt-get install supervisor

配置Supervisor

/etc/supervisor/conf.d目录下创建一个新的配置文件,如log_consumer.conf

[program:log_consumer]
command=php /path/to/consumer.php
autostart=true
autorestart=true
stderr_logfile=/var/log/log_consumer.err.log
stdout_logfile=/var/log/log_consumer.out.log

重新加载和启动Supervisor配置:

sudo supervisorctl reread
sudo supervisorctl update
sudo supervisorctl start log_consumer
方法三:手动在后台运行

使用nohup命令在后台运行消费者进程,并确保其在会话结束后仍然运行。

nohup php /path/to/consumer.php > /dev/null 2>&1 &

测试

  1. 运行生产者脚本php producer.php,将日志消息发送到队列。
  2. 确保消费者在后台运行,并处理队列中的日志消息。

通过上述步骤,您可以实现PHP中使用RabbitMQ进行异步日志记录,并确保消费者可以持续运行,无缝处理日志消息。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/844892.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

vscode操作git详解

基于 VScode 的 git 详细使用指南【保姆级!建议收藏!】_vscode git-CSDN博客

Stable Diffusion AI绘画:从创意词汇到艺术图画的魔法之旅

文章目录 一、Stable Diffusion的工作原理二、从提示词到模型出图的过程三、Stable Diffusion在艺术创作中的应用《Stable Diffusion AI绘画从提示词到模型出图》内容简介作者简介楚天 目录前言/序言本书特色特别提示 获取方式 在科技的飞速发展中,Stable Diffusion…

Java-----Comparable接口和Comparator接口

在Java中&#xff0c;我们会经常使用到自定义类&#xff0c;那我们如何进行自定义类的比较呢? 1.Comparable接口 普通数据的比较 int a10;int b91;System.out.println(a<b); 那自定义类型可不可以这样比较呢&#xff1f;看一下代码 我们发现会报错&#xff0c;因为自定义…

策略模式结合Spring使用

1.抽象策略 /*** 支付方式策略* author Linging* version 1.0.0* since 1.0*/ public interface PayStrategy {void pay(BigDecimal money);}2.具体策略 /*** 支付宝* author Linging* version 1.0.0* since 1.0*/ Component("aliPayStrategy") public class AliPa…

uniapp手机屏幕左滑返回上一页支持APP,H5

核心&#xff1a;touchstart"touchStart" touchend"touchEnd" 代码示例&#xff1a; <template><view class"payPasswordSetting" touchstart"touchStart" touchend"touchEnd"></view> </template&g…

LNMP分布式搭建

一、准备三台主机 192.168.100.11 mysql 192.168.100.12 nginx 192.168.100.13 php 二、关闭防火墙及安全策略 systemctl stop firewalld setenforce 0 三、安装nginx&#xff08;192.168.100.11&#xff09; 1、添加nginx源 vim /etc/yum.repos.d/ng…

618必备好物选购清单有哪些?五款精品好物分享

618将近&#xff0c;很多好物都会在这段时间搞活动&#xff0c;许多朋友会在这个时候置办或者置换家居&#xff0c;那么&#xff0c;2024年的618有哪些值得入手的好物呢&#xff1f;今天&#xff0c;将与大家分享一些精选好物&#xff0c;这些好物在618入手绝对是个不错的选择。…

Unity中模拟生成正态分布的一种方式

using System; using System.Collections; using System.Collections.Generic; using Unity.Mathematics; using UnityEngine;public class MathFunction : MonoBehaviour {private void Start(){//key 范围 0-99 表示 0% 到 99%Dictionary<int,uint> m new Dictionary&…

路径规划中的曲线插值

路径规划中的曲线插值是一种数学方法&#xff0c;它通过一系列离散的点生成一条平滑的曲线&#xff0c;这条曲线可以用于机器人导航、自动车辆驾驶、动画制作等领域。以下是一些常见的曲线插值方法&#xff1a; 线性插值&#xff1a; 线性插值是最简单的插值方法&#xff0c;它…

Leetcode:无重复字符的最长子串

普通版本&#xff08;哈希表 滑动窗口&#xff09; 题目链接&#xff1a;3. 无重复字符的最长子串 - 力扣&#xff08;LeetCode&#xff09; //方法一&#xff1a; class Solution { public:int lengthOfLongestSubstring(string s) {unordered_map<char,int> st;int …

【Linux】文件系统和软硬链接

&#x1f466;个人主页&#xff1a;Weraphael ✍&#x1f3fb;作者简介&#xff1a;目前正在学习c和算法 ✈️专栏&#xff1a;Linux &#x1f40b; 希望大家多多支持&#xff0c;咱一起进步&#xff01;&#x1f601; 如果文章有啥瑕疵&#xff0c;希望大佬指点一二 如果文章对…

Java 服务挂掉,服务器异常宕机问题排查

目录 Java 服务挂掉&#xff0c;服务器异常宕机问题排查一、初步排查1. 检查日志文件2. 查看资源使用情况 二、详细排查1. 内存问题2. CPU 问题3. 磁盘和网络 I/O 三、系统性优化和预防1. 配置监控和报警2. 优化 JVM 参数3. 代码优化 四、案例分享案例一&#xff1a;内存泄漏导…

redux相关源码

1、createStore 实现 2、connct实现 3、bindActionCreators实现 4、Provider实现 5. thunk

html+css web前端 多边形

<!DOCTYPE html><html><head><meta charset"UTF-8"><title>多边形</title><style type"text/css">#pentagon_6_1 {position: absolute;top: 0px;height: 0; width: 100; border-left: 100px solid rgb(255, 255…

【记忆化搜索 】2312. 卖木头块

本文涉及知识点 记忆化搜索 LeetCode2312. 卖木头块 给你两个整数 m 和 n &#xff0c;分别表示一块矩形木块的高和宽。同时给你一个二维整数数组 prices &#xff0c;其中 prices[i] [hi, wi, pricei] 表示你可以以 pricei 元的价格卖一块高为 hi 宽为 wi 的矩形木块。 每…

网络四层、七层协议

一、OSI七层模型 物理层&#xff1a;建立、维护、断开物理连接。 数据链路层&#xff1a;逻辑连接、寻找硬件地址——地址解析协议&#xff1a;ARP、PARP 反向地址转换协议 网络层&#xff1a;寻找逻辑地址&#xff0c;实现不同网络之间的路径选择——ICMP(互联网控制信息协议…

Vue前端平台的搭建

文章目录 前端平台搭建(`Vue2.6`,App:`HBulderX`)创建`Vue2.6`项目下载相应插件方便开发路由配置对连接后端进行一些配置(`main.js`文件)导入ElementUI组件[组件 | Element](https://element.eleme.cn/#/zh-CN/component/icon)同步与异步`axios`异步请求框架前端平台搭建(Vue2.…

YoloV8改进策略:卷积篇|基于PConv的二次创新|附结构图|性能和精度得到大幅度提高(独家原创)

摘要 在PConv的基础上做了二次创新,创新后的模型不仅在精度和速度上有了质的提升,还可以支持Stride为2的降采样。 改进方法简单高效,需要发论文的同学不要错过! 论文指导 PConv在论文中的描述 论文: 下面我们展示了可以通过利用特征图的冗余来进一步优化成本。如图3所…

JVM源码探秘:System.gc全面解析

概述 Java虚拟机&#xff08;JVM&#xff09;的垃圾回收&#xff08;GC&#xff09;通常由VM自身根据预设条件触发&#xff0c;但开发者也可通过特定手段人为触发&#xff0c;比如使用System.gc()、Runtime.gc()或JMap操作等。本文将深入探讨System.gc()的底层原理及其背后的故…

windows 在cmd 使用cd命令无法进入指定目录解决方法

目录预览 一、问题描述二、原因分析三、解决方案四、参考链接 一、问题描述 使用cmd命令想要快速进入某个目录&#xff0c;发现没有跳转&#xff0c;如下&#xff1a; 二、原因分析 cmd 切换目录跨磁盘的话&#xff0c;需要先进行磁盘的转换&#xff0c;也就是要进入到另外一…