supervisor(二)event

supervisor的event机制其实，就是一个监控/通知的框架。抛开这个机制实现的过程来说的话，event其实就是一串数据，这串数据里面有head和body两部分。咱们先弄清楚event数据结构，咱们才能做后续的处理。先看看header长啥样的吧


1

ver:3.0 server:supervisor serial:21 pool:listener poolserial:10 eventname:PROCESS_COMMUNICATION_STDOUT len:54

来说说上面的这个header每一项，都是什么？

ver：表示event协议的版本，目前是3.0

server：表示supervisor的标识符，也就是咱们上一篇中[supervisord]块中的identifier选项中的东西

默认为supervisor

serial：这个东西是每个event的序列号，supervisord在运行过程中，发送的第一个event的序列号就是

1，接下来的event依次类推

pool：这个是你的listener的pool的名字，一般你的listener只启动一个进程的的话，其实也就没有         pool的概念了。名字就是[eventlistener:theeventlistenername]这个东西

poolserial：上面的serial是supervisord给每个event的编号。 而poolserial则是，eventpool给发送

到我这个pool过来的event编的号

eventname：这个是event的类型名称，这个后面说。

len：这个长度，表示的是header后面的body部分的长度。header之后，我们会取len长度的内容作为        body。

好，说完了header,咱们就该说说body部分的数据结构了。body的数据结构，其实是和event的具体类型相关的，不同的event的类型，header的结构都一样，但是body的结构大多就不一样了。

关于event类型，咱们就不展开说了，因为太多了，具体大伙可以去参阅一下官网。其实搞会一个，其他也都一个样。

咱们这里说说待会一个要用到的类型就OK了，啥类型呢？

是PROCESS_STATE_EXITED

看着这名字，大伙差不多也就知道它是干什么的了。PROCESS_STATE_EXITED其实就是，当supervisord管理的子进程退出的时候，supervisord就会产生PROCESS_STATE_EXITED这么个event。

来看看PROCESS_STATE_EXITED长啥样吧，header咱们前面说过了，都一样。来看看body部分


1

processname:cat groupname:cat from_state:RUNNING expected:0 pid:2766

来说说具体含义

processname：就是进程名字，这里名字不是我们实际进程的名字，而是咱们[program:x]配置成的名字

groupname：组名，这个一个样

from_state：这个是，我们的进程退出前的状态是什么状态

expected：这个咱们前面也讲过，默认情况下exitcodes是0和2，也就是说0和2是expected。其它的退出

码，也就是unexpected了

pid：这个大伙想必都知道。

OK，说到了这里，我们知道了event的产生，然后给我们的listener这么一种结构的数据。

现在我们有数据了，就看咱们怎么去处理这些数据了，这个过程就仁者见仁，智者见智了。我们可以利用接收的数据，加工后，进行报警，等等操作。

处理数据之前，咱们还得要来了解一下，listener和supervisord之间的通信过程

在这里我们首先要搞清楚，event的发起方和接收方。

event的发起方是supervisord进程，接收方是一个叫listener的东西，listener怎么配置，上一篇参数详解里面已经写的很清楚了，大伙可以去参考下，这里就不赘述了。其实listener和program一样，都是supervisord的子进程。两者的在配置上，很多选项也都一样。

其实，event还有另外一个过程，我们的program也就是我们要管理的进程，也可以发送event，进而和supervisord主动通信。不过program程序一般都是程序员们搞，咱们搞运维的就不管他们的事情了

OK，看看event协议。

协议其实很简单。

  1. 当supervisord启动的时候，如果我们的listener配置为autostart=true的话，listener就会作为supervisor的子进程被启动。
  2. listener被启动之后，会向自己的stdout写一个"READY"的消息,此时父进程也就是supervisord读取到这条消息后，会认为listener处于就绪状态。
  3. listener处于就绪状态后，当supervisord产生的event在listener的配置的可接受的events中时，supervisord就会把该event发送给该listener。
  4. listener接收到event后，我们就可以根据event的head，body里面的数据，做一些列的处理了。我们根据event的内容，判断，提取，报警等等操作。
  5. 该干的活都干完之后，listener需要向自己的stdout写一个消息"RESULT\nOK"，supervisord接受到这条消息后。就知道listener处理event完毕了。

好，来看看例子吧


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

#!/usr/bin/env python

#coding:utf-8

import sys

import os

import subprocess

#childutils这个模块是supervisor的一个模型，可以方便我们处理event消息。。。当然我们也可以自己按照协议，用任何语言来写listener，只不过用childutils更加简便罢了

from supervisor import childutils

from optparse import OptionParser

import socket

import fcntl

import struct

__doc__ = "\033[32m%s,捕获PROCESS_STATE_EXITED事件类型,当异常退出时触发报警\033[0m" % sys.argv[0]

def write_stdout(s):

    sys.stdout.write(s)

    sys.stdout.flush()

#定义异常，没啥大用其实

class CallError(Exception):

    def __init__(self,value):

        self.value = value

    def __str__(self):

        return repr(self.value)

#定义处理event的类

class ProcessesMonitor():

    def __init__(self):

        self.stdin = sys.stdin

        self.stdout = sys.stdout

    def runforever(self):

        #定义一个无限循环，可以循环处理event，当然也可以不用循环，把listener的autorestart#配置为true，处理完一次event就让该listener退出，然后supervisord重启该listener，这样listen#er就可以处理新的event了

        while 1:

            #下面这个东西，是向stdout发送"READY"，然后就阻塞在这里，一直等到有event发过来

            #headers,payload分别是接收到的header和body的内容

            headers, payload = childutils.listener.wait(self.stdin, self.stdout)

            #判断event是否是咱们需要的，不是的话，向stdout写入"RESULT\NOK"，并跳过当前

            #循环的剩余部分

            if not headers[‘eventname‘] == ‘PROCESS_STATE_EXITED‘:

                childutils.listener.ok(self.stdout)

                continue

            pheaders,pdata = childutils.eventdata(payload+‘\n‘)

            #判读event是否是expected是否是expected的，expected的话为1，否则为0

            #这里的判断是过滤掉expected的event

            if int(pheaders[‘expected‘]):

                childutils.listener.ok(self.stdout)

                continue

            ip = self.get_ip(‘eth0‘)

            #构造报警信息结构

            msg = "[Host:%s][Process:%s][pid:%s][exited unexpectedly fromstate:%s]" % (ip,pheaders[‘processname‘],pheaders[‘pid‘],pheaders[‘from_state‘])

            #调用报警接口，这个接口是我们公司自己开发的，大伙不能用的，要换成自己的接口

            subprocess.call("/usr/local/bin/alert.py -m ‘%s‘" % msg,shell=True)

            #stdout写入"RESULT\nOK"，并进入下一次循环

            childutils.listener.ok(self.stdout)

    ‘‘‘def check_user(self):

        userName = os.environ[‘USER‘]

        if userName != ‘root‘:

            try:

                raise MyError(‘must be run by root!‘)

            except MyError as e:

                write_stderr( "Error occurred,value:%s\n" % e.value)

                sys.exit(255)‘‘‘

    def get_ip(self,ifname):

        s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

        inet = fcntl.ioctl(s.fileno(), 0x8915, struct.pack(‘256s‘, ifname[:15]))

        ret = socket.inet_ntoa(inet[20:24])

        return ret

def main():

    parser = OptionParser()

    if len(sys.argv) == 2:

        if sys.argv[1] == ‘-h‘ or sys.argv[1] == ‘--help‘:

            print __doc__

            sys.exit(0)

    #(options, args) = parser.parse_args()

    #下面这个，表示只有supervisord才能调用该listener，否则退出

    if not ‘SUPERVISOR_SERVER_URL‘ in os.environ:

        try:

            raise CallError("%s must be run as a supervisor event" % sys.argv[0])

        except CallError as e:

            write_stderr("Error occurred,value: %s\n" % e.value)

        return

    prog = ProcessesMonitor()

    prog.runforever()

if __name__ == ‘__main__‘:

    main()

差不多就这些了，其他常用的event类型，已经listener的三种状态，已经怎么转换的。大伙可以去官网上看看

时间： 2025-01-02 18:58:50

supervisor(二)event的相关文章

CraftyJS 学习二 -- Event

Event 事件系统 Crafty 使用 Event 来完成消息传递. 基本思想就是,为实体绑定事件,然后在其他地方触发事件,事件被立即执行. // Create a red squarevar square = Crafty.e("2D, Canvas, Color")         .attr({x:10,y:10, w:30, h:30})         .color("blue");// When a "Blush" event is

salesforce lightning零基础学习(九) Aura Js 浅谈二: Event篇

上一篇介绍了Aura Framework中 Component类的部分方法,本篇将要介绍Event常用的方法. 1. setParam (String key , Object value):设置事件的param,此项设置不会修改已经被触发的事件.我们在创建事件的时候可以同时声明attribute,在我们fire事件以前,可以对这些attribute设置值,其中key为attribute的name,value部分即为attribute的value. 2.setParams (Object con

supervisor 守护进程

一.supervisor 安装 1.yum -y install epel-release 2.yum -y install supervisor 二.supervisor 配置文件详解 三.supervisor EVENT 四.supervisor XML_rpc 原文地址:https://www.cnblogs.com/jiejunwang/p/10276536.html

supervisor：进程管理工具

一,安装(任何一种方式) apt-get install supervisor easy_install supervisor pip install supervisor 二,配置 配置supervisor.conf 添加web控制界面 2.    启动进程配置说明 ; 管理单个进程的配置,可创建多个,下面是所有可能的配置选项 ;[program:theprogramname] ;command=/bin/cat ; 启动进程的命令 使用相对路径,可以加参数 ;process_name=%(p

[数据库] Navicat for MySQL事件Event实现数据每日定期操作

在我们操作数据库过程中,通常会遇到一些某个时间点操作数据库的问题,例如:        (1).每天凌晨12点对数据库进行定时备份,结算和汇总:        (2).每天凌晨2点删除数据库前三天的数据:        (3).插入某个数据超过一定时间改变某个值的状态,比如预警系统.        这里就需要通过Event事件进行简单操作,下面将详细处理.你可能会想到通过触发器实现,但是如果是同一张表Insert插入数据后,但是触发器再进行Update更新操作是不行的,所以需要尝试通过Event

轻松学习JavaScript二十七：DOM编程学习之事件模型

在介绍事件模型之前,我们先来看什么是事件和什么是event对象. 一事件介绍 JavaScript事件是由訪问Web页面的用户引起的一系列操作,使我们有能力创建动态页面.事件是能够被 JavaScript侦測到的行为. 网页中的每一个元素都能够产生某些能够触发JavaScript函数的事件.例如说.我们能够在用 户点击某button时产生一个onclick事件来触发某个函数.事件在HTML页面中定义:事件通常与函数配合使用,当事件 发生时函数才会运行:事件一般用于浏览器和用户操作进行交互. 我们

Centos7 使用 supervisor 管理进程

一.安装 //直接使用pip安装(pip的安装 http://www.cnblogs.com/yxhblogs/p/8971251.html) pip install supervisor 二.配置 //运行echo_supervisord_conf 命令重定向到一个配置文件 echo_supervisord_conf > /etc/supervisord.conf 三.修改配置文件 //创建一个目录 mkdir /etc/supervisor.d //把/etc/supervisord.con

使用supervisor监控mha masterha_manager进程

我们在用mha自带的masterha_manager脚本做mysql主库故障自动切换时,需要考虑如何让masterha_manager监控进程一直处于正常运行的状态.而supervisor可以很好地解决这个问题,它可以将一个普通的命令行进程变为后台daemon,并监控进程状态,异常退出时能自动重启. 这里列一下部署要点和管理命令 一,supervisor 安装: sudo pip install supervisor 二,supervisor配置: mkdir -p /etc/superviso

javascript基础修炼(5)—Event Loop

开发者的javascript造诣取决于对[动态]和[异步]这两个词的理解水平. 一. 一道考察异步知识的面试题 题目是这样的,要求写出下面代码的输出: setTimeout(() => { console.log(1) }, 0) new Promise((resolve, reject) => { console.log(2) for (let i = 0; i < 10000; i++) { i === 9999 && resolve() } console.log(