1

我最近开发了一个 Python 脚本来利用一个工具通过 JMX 从 JVM 中检索指标。父进程 ( p1) 使用以下代码启动另一个进程 ( p2)。

p2 = subprocess.Popen(
    ['java', '-jar', '/path/to/jmxterm-1.0-alpha-4-uber.jar',
     '-l', url, '-u', username, '-p', password],
    stdin = subprocess.PIPE,
    stdout = subprocess.PIPE,
    stderr = subprocess.PIPE)

一旦p2启动并运行，就会p1进入一个很长的循环，在该循环中它会执行以下三件事：

  1. 睡眠 10 秒；
  2. p2通过调用发送查询p2.stdin.write()；
  3. 通过调用读取结果p2.stdout.readline()。

问题：

  1. 我的脚本按预期工作，直到它退出。p1如果我按Ctrl+停止C并返回终端，一切正常。如果我等到p1完成长循环并退出，终端可以正常工作，只是我输入的所有字符都不再可见。例如，如果我输入“ls”，我在屏幕上什么也看不到。但是当我点击 时Return，我仍然可以看到像往常一样列出的文件和子目录。我的问题是，幕后会发生什么？

  2. 如果我删除， jmxtermstderr = subprocess.PIPE打印到的帮助消息将发送到终端。stderr因为他们弄乱了我脚本的输出，所以我试图改变

    ['java', '-jar', '/path/to/jmxterm-1.0-alpha-4-uber.jar', '-l', url,
         '-u', username, '-p', password]

    至

    ['java', '-jar', '/path/to/jmxterm-1.0-alpha-4-uber.jar', '-l', url,
         '-u', username, '-p', password, '2>/dev/null']

    但没有任何改变（帮助消息仍然发送到终端）。然后我添加stderr = subprocess.PIPE回我的脚本并启动一个守护线程来读取stderr并丢弃它读取的任何内容。令我惊讶的是，守护线程从stderr. 我完全迷路了。如果你有线索，请帮帮我。

供您参考，代码粘贴在下面：

from Queue import Queue

class JmxD(Detector):

    def __init__(self, myId, jmxUrl, username, password):
        super(JmxD, self).__init__(myId)

        self.__jmxUrl = jmxUrl
        self.__username = username
        self.__password = password

        # Start JMX terminal
        self.__jmxTerm = subprocess.Popen(
            ['java', '-jar', jmxTermPath,
             '-l', jmxUrl, '-u', username, '-p', password],
            stdin = subprocess.PIPE,
            stdout = subprocess.PIPE,
            stderr = subprocess.PIPE)

        # Start two daemon threads to read from JMX terminal's stdout & stderr
        def _stream2Queue(out, queue):
            for line in iter(out.readline, ''):
                line = line.strip()
                if line:
                    queue.put(line)
            out.close()

        def _stream2Null(out):
            for line in iter(out.readline, ''):
                #print 'A line read from stderr: %s' % line.strip()
                pass
            out.close()

        self.__queue = Queue()
        self.__reader = Thread(target=_stream2Queue,
                               args=(self.__jmxTerm.stdout, self.__queue))
        self.__reader.setDaemon(True) # This thread dies with the program
        self.__reader.start()

        self.__discarder = Thread(target=_stream2Null,
                                  args=(self.__jmxTerm.stderr))
        self.__discarder.setDaemon(True) # This thread dies with the program
        self.__discarder.start()
4

0 回答 0