从头开始读skynet源码（4）skynet.start服务器启动之后做了什么之monitor(监视者)

痛定思痛。 2022-11-12 00:43 131阅读 0赞

## monitor ##

monitor分为服务器的monitor 和 skynet\_monitor，整个服务器只有一个服务器monitor，每条工作线程绑定一个skynet\_monitor，上面在声明了若干条线程数量后，先做的就是创建服务器monitor。

### 服务器 monitor ###

// 可以把服务退出的消息从框架层抛出来，让上层逻辑可以感知到
    struct monitor { 
    	int count;					// 多少条工作线程
    	struct skynet_monitor ** m; // skynet_monitor
    	pthread_cond_t cond;		// 条件变量
    	pthread_mutex_t mutex;		// 互斥锁
    	int sleep;					
    	int quit;					// 服务器是否退出的标记
    };
    
    start(int thread) { 
    	...
    	struct monitor *m = skynet_malloc(sizeof(*m));
    	memset(m, 0, sizeof(*m));
    	m->count = thread;
    	m->sleep = 0;
    
    	m->m = skynet_malloc(thread * sizeof(struct skynet_monitor *));
    	int i;
    	for (i=0;i<thread;i++) { 
    		m->m[i] = skynet_monitor_new();
    	}
    	if (pthread_mutex_init(&m->mutex, NULL)) { 
    		fprintf(stderr, "Init mutex error");
    		exit(1);
    	}
    	if (pthread_cond_init(&m->cond, NULL)) { 
    		fprintf(stderr, "Init cond error");
    		exit(1);
    	}
    	create_thread(&pid[0], thread_monitor, m);
    	...
    }

### 工作线程监视 skynet\_monitor ###

// skynet_monitor.h
    struct skynet_monitor * skynet_monitor_new();//新建一个监视器
    void skynet_monitor_delete(struct skynet_monitor *);//删除一个监视器
    void skynet_monitor_trigger(struct skynet_monitor *, uint32_t source, uint32_t destination);//通知监视器开始
    void skynet_monitor_check(struct skynet_monitor *);//检查监视器是否陷入死循环
    
    // skynet_monitor.c
    // 主要用于监测skynet服务在处理消息时是否陷入死循环
    struct skynet_monitor { 
    	int version;                // 当前版本
        int check_version;          // 检查版本
        uint32_t source;            // 消息源服务
        uint32_t destination;       // 消息目标服务
    };
    
    truct skynet_monitor * 
    skynet_monitor_new() { 
    	struct skynet_monitor * ret = skynet_malloc(sizeof(*ret));
    	memset(ret, 0, sizeof(*ret));
    	return ret;
    }

### thread\_monitor 线程 ###

// 如果没有正在运行的skynet_context(skynet服务)则break
    #define CHECK_ABORT if (skynet_context_total()==0) break;
    
    // skynet_server.c
    // 设置统一线程内的共享数据
    // 线程内部的各个函数调用都能访问、但其它线程不能访问的变量
    // 处理了进程内静态变量全部线程共享的问题
    void
    skynet_initthread(int m) { 
    	uintptr_t v = (uint32_t)(-m);
    	pthread_setspecific(G_NODE.handle_key, (void *)v);
    }
    
    // skynet_monitor.c
    // 检查服务是否陷入死循环
    void 
    skynet_monitor_check(struct skynet_monitor *sm) { 
    	if (sm->version == sm->check_version) { 
    		// 这说明一个消息处理了5到10秒还没有返回，
    		// 导致sm->version一直没有增长。下一次check发现没有增长，
    		// 就认为它可能发生死循环了。
    		// 处理也只是加一个标记，并打印一条错误日志，没有再做其他处理。
    		if (sm->destination) { 
    			skynet_context_endless(sm->destination);
    			skynet_error(NULL, "A message from [ :%08x ] to [ :%08x ] maybe in an endless loop (version = %d)", sm->source , sm->destination, sm->version);
    		}
    	} else { 
    		// 如果版本不一致，更新检查版本
    		sm->check_version = sm->version;
    	}
    }
    
    static void *
    thread_monitor(void *p) { 
    	struct monitor * m = p;				//拿到服务器monitor
    	int i;
    	int n = m->count;					// 拿到工作线程数
    	
    	// 设置统一线程内的共享数据THREAD_MONITOR，标记为monitor线程
    	skynet_initthread(THREAD_MONITOR); 
    	
    	// 线程死循环
    	for (;;) { 
    		// 定义在上面，检查是否还有skynet服务运行
    		CHECK_ABORT	
    		
    		// 检查每一个工作线程是否陷入死循环
    		for (i=0;i<n;i++) { 
    			skynet_monitor_check(m->m[i]);
    		}
    		// 每秒检查一次是否还有服务在运行
    		// 延迟5s后再进入上面的检查工作线程
    		for (i=0;i<5;i++) { 
    			CHECK_ABORT	
    			sleep(1);
    		}
    	}
    
    	return NULL;
    }

至此，skynet.star大概做了什么，monitor部分功能都做了大概分析。下篇顺着skynet.star分析，thread\_timer(skynet定时器)