在Python中通過stdin/stdout/pipes進行通信的預定義協議？

Question

我有一個創建了它需要在Python 2.5〜coummunicate若干子過程的過程。我使用子進程模塊來啓動進程，將stdin和stdout設置爲subprocess.PIPE。到現在爲止還挺好。

在一個循環，我然後運行select.select（）每個subproccess的標準輸出流等着他們告訴我，他們已經準備好。然後，我寫信給他們的stdin，讓他們工作並重復這個過程。

目前，我只是用stdin.write和stdout.readline瓶坯的通信。但是，我希望能夠在流程之間傳遞複雜的消息。簡單的換行符終止的消息是不夠的（除非我以某種方式大步跨越消息中的新行）。我想我可以在字節長度前綴的所有信息，這樣我的消息看起來像：

6:foobar 

但是，這使我想到我的問題：沒有這樣的事情存在？我真的不想在這裏重新發明輪子。我想要一個圖書館，告訴我什麼時候有一個完整的信息準備好，然後交給我。還有很多其他協議以各種方式執行此類操作（TCP，Message Queue Server，HTTP等），但它們對我的用例來說都是過度的。在Python中的進程間傳遞消息的正確方法是什麼？

Answer 1

您可以使用json或pickle對包含該消息的數據結構進行編碼，然後在另一側使用相同的名稱來讀取該消息。

Answer 2

有框架，真正幫助您解決這種功能的。如果您想發送更復雜的消息而不打擾同步問題。真的好框架的一些例子：

• 0mq或
• PYthon Remote Objects（焦）

這些框架，主要是，在TCP/IP之上的工作。對你的東西稍微不同的方法。但是，也許你應該考慮一些事情。