zeromq使用注意點滴

1.關於介紹zeromq的就不說了，可以自己去看官方guide很詳細

2.主要說下在使用過程中需要注意的地方

1）使用如果使用c++的接口的時候，在你自己的類中或者apache模塊中

需要將zmq::context_t 對象定義在zmq::socket_t對象的前面，這樣可以保證銷毀的順序

2）使用sub-pub時候，如果sub沒有調用setsockopt設置過濾項(設置NULL則接受所有)，那麼將會接收不到任何的消息，默認會阻塞所有消息

3）如果是後台服務集群使用且zmq需要bind端口的，那麼最好在iptables中進行下過濾，不要讓外部鏈接

連接過來，否則會造成cpu空轉；關於cpu空轉將會在最後說

4）客戶端連接服務器時，每個客戶端中的zmq，每個連接使用一個socket，雖然可以一個socket可以調用connect多次，也就是連接多個server。但是，記住，最好是一個socket只調用一次connect

5）使用zmq的程序，運行一段時間後(可能幾天)，如果你碰到異常退出，並且你使用nohup運行的log

nohup.out中顯示zeromq connection timeout，那麼你可以zeromq/src/tcp_socket.cpp文件中的203行看是write的時候出錯。

1. int zmq::tcp_socket_t::write (const void *data, int size) 
2. { 
3.     ssize_t nbytes = send (s, data, size, 0); 
4.  
5.     //  Several errors are OK. When speculative write is being done we may not  
6.     //  be able to write a single byte to the socket. Also, SIGSTOP issued  
7.     //  by a debugging tool can result in EINTR error.  
8.     if (nbytes == -1 && (errno == EAGAIN || errno == EWOULDBLOCK || 
9.           errno == EINTR)) 
10.         return 0; 
11.  
12.     //  Signalise peer failure.  
13.     if (nbytes == -1 && (errno == ECONNRESET || errno == EPIPE)) 
14.         return -1; 
15.  
16.     errno_assert (nbytes != -1); 
17.     return (size_t) nbytes; 
18. } 

這是由於 errno_assert (nbytes != -1);造成的，但是，真正的原因是nbytes==-1時，errno==ETIMEDOUT ，在前面一行中沒有去添加對這個timeout的判斷，另外，可以參考該文件中對win上的處理。因此，這裡如果你碰到了timeout錯誤，那麼請將errno == ETIMEOUT加入到errno==EPIPE後面，然後重新編譯

6）關於cpu空轉。首先你可以用top 程序名，去看你的程序的cpu使用率是否是100%，而且基本固定不變，那麼這時候，你就需要懷疑是否你的程序的問題，然後通過lsof -p 程序的進程號，去查看是否有文件描述符有can't identify protocol,還要注意下，是否有外網的ip連接到你的zmq的監聽的端口。

然後，你可以在zeromq/src/epoll.cpp中的loop，rm_fd,add_fd函數中打log，看看在監聽到EPOLLERR|EPOLLHUP

的文件描述符是不是lsof -p 查看到的can't identify protocol的文件描述符一致。其實，只要做到前面5點，那麼cpu

空轉基本是不會出現的。

ps:最後，希望碰到問題，大家能自己思考為什麼會出現這樣的問題，該如何解決，對自己的提升會有很大的幫助。