jvm_collector.py 文件源码

def get_socket(self, config):
        def _get_socket():
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            s.connect((self.jstatus_ip, self.jstatus_port))
            s.settimeout(config['timeout'])
            return s
        try:
            self.socket_line_prefix = ''
            self.already_reload = False
            return _get_socket()
        except:
            self.start_jstatus_process(config['java_bin'])
            return _get_socket()