salt 源码之 salt-minion启动过程

opiuytr1

1.在scripts.py文件中salt_minion()函数如下代码：

1 2	minion = salt.cli.daemons.Minion() minion.start()

2.在daemons.py文件中类Minion的start执行如下代码

1 2 3 4 5 6 7 8 9 10 11

class Minion(parsers.MinionOptionParser, DaemonsMixin)     .... 1.解析命令行参数及配置文件 2.执行start方法前先执行prepare()方法，检查启动的必须项是否配置，并且必须的环境目录是否存在 self.minion = salt.minion.Minion(self.config) self.minion.tune_in()

3.在minion.py文件中的tune_in()方法中执行如下代码

1	self.sync_connect_master()

4.在minion.py中sync_connect_master()方法如下

1 2 3 4 5

sync_connect_master()方法会一直阻塞，直到连接master为止 代码如下： self._connect_master_future = self.connect_master() 该方法调用self.connect_master()方法

5.connect_master方法如下：

1 2	master, self.pub_channel = yield self.eval_master(self.opts, self.timeout, self.safe) yield self._post_master_init(master)

6.self.eval_master(）方法如下：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

pub_channel = salt.transport.client.AsyncPubChannel.factory(self.opts, **factory_kwargs) yield pub_channel.connect() #AsyncPubChannel类用于生成一个类来创建到master的Publisher的一个订阅通道 该类的factory方法会返回return salt.transport.zeromq.AsyncZeroMQPubChannel(opts, **kwargs) salt.transport.zeromq.AsyncZeroMQPubChannel类在实例化时操作如下： self.auth = salt.crypt.AsyncAuth(self.opts, io_loop=self.io_loop) self.serial = salt.payload.Serial(self.opts) self.context = zmq.Context() self._socket = self.context.socket(zmq.SUB) 最终先调用AsyncZeroMQPubChannel.connect()方法 connect方法中的代码如下： if not self.auth.authenticated:     yield self.auth.authenticate() self.publish_port = self.auth.creds['publish_port'] self._socket.connect(self.master_pub) #可以看出在连接之前的操作是进行认证操作

7.salt-minion的认证流程如下：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

self.pub_path = os.path.join(self.opts['pki_dir'], 'minion.pub') self.rsa_path = os.path.join(self.opts['pki_dir'], 'minion.pem') self.mpub = 'minion_master.pub' #先检查minion的公钥和私钥文件是否存在，如果不存在，便创建；同时指定保存master的公钥的文件名 是minion_master.pub channel = salt.transport.client.ReqChannel.factory(self.opts, crypt='clear') creds = self.sign_in(channel=channel) 向master发送签名认证 auth['master_uri'] = tcp://192.168.56.101:4506 认证时是向master的4506端口发送消息 sign_in_payload = self.minion_sign_in_payload() sign_in_payload是发送的具体消息内容及格式 minion_sign_in_payload()方法生成了向master发送认证消息的内容 代码如下： payload = {} payload['cmd'] = '_auth' payload['id'] = self.opts['id']