zeromq-4.1.4.tar.gz

【实例简介】
ZeroMQ是一个网络通讯库，其主要用来为分布式应用程序开发提供进程间通信（此处的进程既可以是同一台机器上的两个进程也可以是不同机器上的两个进程）。ZeroMQ的特点在于灵活的通信手段和丰富的连接模型，并且它可以在Linux Mac OS X,Windows等多种操作系统上工作，也支持由多种语言进行访问。
【实例截图】
【核心代码】
zeromq-4.1.4.tar
└── zeromq-4.1.4
├── acinclude.m4
├── aclocal.m4
├── AUTHORS
├── autogen.sh
├── builds
│   ├── msvc
│   │   ├── errno.cpp
│   │   ├── errno.hpp
│   │   ├── Makefile.am
│   │   ├── Makefile.in
│   │   ├── platform.hpp
│   │   ├── properties
│   │   │   ├── Common.props
│   │   │   ├── DebugDEXE.props
│   │   │   ├── DebugDLL.props
│   │   │   ├── DebugLEXE.props
│   │   │   ├── DebugLIB.props
│   │   │   ├── DebugLTCG.props
│   │   │   ├── Debug.props
│   │   │   ├── DebugSEXE.props
│   │   │   ├── DLL.props
│   │   │   ├── EXE.props
│   │   │   ├── LIB.props
│   │   │   ├── Link.props
│   │   │   ├── LTCG.props
│   │   │   ├── Messages.props
│   │   │   ├── Output.props
│   │   │   ├── ReleaseDEXE.props
│   │   │   ├── ReleaseDLL.props
│   │   │   ├── ReleaseLEXE.props
│   │   │   ├── ReleaseLIB.props
│   │   │   ├── ReleaseLTCG.props
│   │   │   ├── Release.props
│   │   │   ├── ReleaseSEXE.props
│   │   │   ├── Win32.props
│   │   │   └── x64.props
│   │   ├── resource.h
│   │   ├── resource.rc
│   │   ├── vs2008
│   │   │   ├── inproc_lat
│   │   │   │   └── inproc_lat.vcproj
│   │   │   ├── inproc_thr
│   │   │   │   └── inproc_thr.vcproj
│   │   │   ├── libzmq
│   │   │   │   └── libzmq.vcproj
│   │   │   ├── libzmq.sln
│   │   │   ├── local_lat
│   │   │   │   └── local_lat.vcproj
│   │   │   ├── local_thr
│   │   │   │   └── local_thr.vcproj
│   │   │   ├── remote_lat
│   │   │   │   └── remote_lat.vcproj
│   │   │   └── remote_thr
│   │   │   └── remote_thr.vcproj
│   │   ├── vs2010
│   │   │   ├── inproc_lat
│   │   │   │   ├── inproc_lat.props
│   │   │   │   └── inproc_lat.vcxproj
│   │   │   ├── inproc_thr
│   │   │   │   ├── inproc_thr.props
│   │   │   │   └── inproc_thr.vcxproj
│   │   │   ├── libsodium.import.props
│   │   │   ├── libsodium.import.xml
│   │   │   ├── libzmq
│   │   │   │   ├── libzmq.props
│   │   │   │   ├── libzmq.vcxproj
│   │   │   │   ├── libzmq.vcxproj.filters
│   │   │   │   └── libzmq.xml
│   │   │   ├── libzmq.import.props
│   │   │   ├── libzmq.import.xml
│   │   │   ├── libzmq.sln
│   │   │   ├── local_lat
│   │   │   │   ├── local_lat.props
│   │   │   │   └── local_lat.vcxproj
│   │   │   ├── local_thr
│   │   │   │   ├── local_thr.props
│   │   │   │   └── local_thr.vcxproj
│   │   │   ├── remote_lat
│   │   │   │   ├── remote_lat.props
│   │   │   │   └── remote_lat.vcxproj
│   │   │   └── remote_thr
│   │   │   ├── remote_thr.props
│   │   │   └── remote_thr.vcxproj
│   │   ├── vs2012
│   │   │   ├── inproc_lat
│   │   │   │   ├── inproc_lat.props
│   │   │   │   └── inproc_lat.vcxproj
│   │   │   ├── inproc_thr
│   │   │   │   ├── inproc_thr.props
│   │   │   │   └── inproc_thr.vcxproj
│   │   │   ├── libsodium.import.props
│   │   │   ├── libsodium.import.xml
│   │   │   ├── libzmq
│   │   │   │   ├── libzmq.props
│   │   │   │   ├── libzmq.vcxproj
│   │   │   │   ├── libzmq.vcxproj.filters
│   │   │   │   └── libzmq.xml
│   │   │   ├── libzmq.import.props
│   │   │   ├── libzmq.import.xml
│   │   │   ├── libzmq.sln
│   │   │   ├── local_lat
│   │   │   │   ├── local_lat.props
│   │   │   │   └── local_lat.vcxproj
│   │   │   ├── local_thr
│   │   │   │   ├── local_thr.props
│   │   │   │   └── local_thr.vcxproj
│   │   │   ├── remote_lat
│   │   │   │   ├── remote_lat.props
│   │   │   │   └── remote_lat.vcxproj
│   │   │   └── remote_thr
│   │   │   ├── remote_thr.props
│   │   │   └── remote_thr.vcxproj
│   │   └── vs2013
│   │   ├── inproc_lat
│   │   │   ├── inproc_lat.props
│   │   │   └── inproc_lat.vcxproj
│   │   ├── inproc_thr
│   │   │   ├── inproc_thr.props
│   │   │   └── inproc_thr.vcxproj
│   │   ├── libsodium.import.props
│   │   ├── libsodium.import.xml
│   │   ├── libzmq
│   │   │   ├── libzmq.props
│   │   │   ├── libzmq.vcxproj
│   │   │   ├── libzmq.vcxproj.filters
│   │   │   └── libzmq.xml
│   │   ├── libzmq.import.props
│   │   ├── libzmq.import.xml
│   │   ├── libzmq.sln
│   │   ├── local_lat
│   │   │   ├── local_lat.props
│   │   │   └── local_lat.vcxproj
│   │   ├── local_thr
│   │   │   ├── local_thr.props
│   │   │   └── local_thr.vcxproj
│   │   ├── remote_lat
│   │   │   ├── remote_lat.props
│   │   │   └── remote_lat.vcxproj
│   │   └── remote_thr
│   │   ├── remote_thr.props
│   │   └── remote_thr.vcxproj
│   └── redhat
│   └── zeromq.spec.in
├── ChangeLog
├── CMakeLists.txt
├── config
│   ├── compile
│   ├── config.guess
│   ├── config.sub
│   ├── depcomp
│   ├── install-sh
│   ├── libtool.m4
│   ├── ltmain.sh
│   ├── lt~obsolete.m4
│   ├── ltoptions.m4
│   ├── ltsugar.m4
│   ├── ltversion.m4
│   ├── missing
│   └── test-driver
├── configure
├── configure.ac
├── COPYING
├── COPYING.LESSER
├── doc
│   ├── asciidoc.conf
│   ├── Makefile.am
│   ├── Makefile.in
│   ├── zmq.7
│   ├── zmq_bind.3
│   ├── zmq_bind.html
│   ├── zmq_bind.txt
│   ├── zmq_close.3
│   ├── zmq_close.html
│   ├── zmq_close.txt
│   ├── zmq_connect.3
│   ├── zmq_connect.html
│   ├── zmq_connect.txt
│   ├── zmq_ctx_get.3
│   ├── zmq_ctx_get.html
│   ├── zmq_ctx_get.txt
│   ├── zmq_ctx_new.3
│   ├── zmq_ctx_new.html
│   ├── zmq_ctx_new.txt
│   ├── zmq_ctx_set.3
│   ├── zmq_ctx_set.html
│   ├── zmq_ctx_set.txt
│   ├── zmq_ctx_shutdown.3
│   ├── zmq_ctx_shutdown.html
│   ├── zmq_ctx_shutdown.txt
│   ├── zmq_ctx_term.3
│   ├── zmq_ctx_term.html
│   ├── zmq_ctx_term.txt
│   ├── zmq_curve.7
│   ├── zmq_curve.html
│   ├── zmq_curve_keypair.3
│   ├── zmq_curve_keypair.html
│   ├── zmq_curve_keypair.txt
│   ├── zmq_curve.txt
│   ├── zmq_disconnect.3
│   ├── zmq_disconnect.html
│   ├── zmq_disconnect.txt
│   ├── zmq_errno.3
│   ├── zmq_errno.html
│   ├── zmq_errno.txt
│   ├── zmq_getsockopt.3
│   ├── zmq_getsockopt.html
│   ├── zmq_getsockopt.txt
│   ├── zmq_has.3
│   ├── zmq_has.html
│   ├── zmq_has.txt
│   ├── zmq.html
│   ├── zmq_inproc.7
│   ├── zmq_inproc.html
│   ├── zmq_inproc.txt
│   ├── zmq_ipc.7
│   ├── zmq_ipc.html
│   ├── zmq_ipc.txt
│   ├── zmq_msg_close.3
│   ├── zmq_msg_close.html
│   ├── zmq_msg_close.txt
│   ├── zmq_msg_copy.3
│   ├── zmq_msg_copy.html
│   ├── zmq_msg_copy.txt
│   ├── zmq_msg_data.3
│   ├── zmq_msg_data.html
│   ├── zmq_msg_data.txt
│   ├── zmq_msg_get.3
│   ├── zmq_msg_get.html
│   ├── zmq_msg_gets.3
│   ├── zmq_msg_gets.html
│   ├── zmq_msg_gets.txt
│   ├── zmq_msg_get.txt
│   ├── zmq_msg_init.3
│   ├── zmq_msg_init_data.3
│   ├── zmq_msg_init_data.html
│   ├── zmq_msg_init_data.txt
│   ├── zmq_msg_init.html
│   ├── zmq_msg_init_size.3
│   ├── zmq_msg_init_size.html
│   ├── zmq_msg_init_size.txt
│   ├── zmq_msg_init.txt
│   ├── zmq_msg_more.3
│   ├── zmq_msg_more.html
│   ├── zmq_msg_more.txt
│   ├── zmq_msg_move.3
│   ├── zmq_msg_move.html
│   ├── zmq_msg_move.txt
│   ├── zmq_msg_recv.3
│   ├── zmq_msg_recv.html
│   ├── zmq_msg_recv.txt
│   ├── zmq_msg_send.3
│   ├── zmq_msg_send.html
│   ├── zmq_msg_send.txt
│   ├── zmq_msg_set.3
│   ├── zmq_msg_set.html
│   ├── zmq_msg_set.txt
│   ├── zmq_msg_size.3
│   ├── zmq_msg_size.html
│   ├── zmq_msg_size.txt
│   ├── zmq_null.7
│   ├── zmq_null.html
│   ├── zmq_null.txt
│   ├── zmq_pgm.7
│   ├── zmq_pgm.html
│   ├── zmq_pgm.txt
│   ├── zmq_plain.7
│   ├── zmq_plain.html
│   ├── zmq_plain.txt
│   ├── zmq_poll.3
│   ├── zmq_poll.html
│   ├── zmq_poll.txt
│   ├── zmq_proxy.3
│   ├── zmq_proxy.html
│   ├── zmq_proxy_steerable.3
│   ├── zmq_proxy_steerable.html
│   ├── zmq_proxy_steerable.txt
│   ├── zmq_proxy.txt
│   ├── zmq_recv.3
│   ├── zmq_recv.html
│   ├── zmq_recvmsg.3
│   ├── zmq_recvmsg.html
│   ├── zmq_recvmsg.txt
│   ├── zmq_recv.txt
│   ├── zmq_send.3
│   ├── zmq_send_const.3
│   ├── zmq_send_const.html
│   ├── zmq_send_const.txt
│   ├── zmq_send.html
│   ├── zmq_sendmsg.3
│   ├── zmq_sendmsg.html
│   ├── zmq_sendmsg.txt
│   ├── zmq_send.txt
│   ├── zmq_setsockopt.3
│   ├── zmq_setsockopt.html
│   ├── zmq_setsockopt.txt
│   ├── zmq_socket.3
│   ├── zmq_socket.html
│   ├── zmq_socket_monitor.3
│   ├── zmq_socket_monitor.html
│   ├── zmq_socket_monitor.txt
│   ├── zmq_socket.txt
│   ├── zmq_strerror.3
│   ├── zmq_strerror.html
│   ├── zmq_strerror.txt
│   ├── zmq_tcp.7
│   ├── zmq_tcp.html
│   ├── zmq_tcp.txt
│   ├── zmq_tipc.7
│   ├── zmq_tipc.html
│   ├── zmq_tipc.txt
│   ├── zmq.txt
│   ├── zmq_unbind.3
│   ├── zmq_unbind.html
│   ├── zmq_unbind.txt
│   ├── zmq_version.3
│   ├── zmq_version.html
│   ├── zmq_version.txt
│   ├── zmq_z85_decode.3
│   ├── zmq_z85_decode.html
│   ├── zmq_z85_decode.txt
│   ├── zmq_z85_encode.3
│   ├── zmq_z85_encode.html
│   └── zmq_z85_encode.txt
├── include
│   ├── zmq.h
│   └── zmq_utils.h
├── INSTALL
├── MAINTAINERS
├── Makefile.am
├── Makefile.in
├── NEWS
├── perf
│   ├── inproc_lat.cpp
│   ├── inproc_thr.cpp
│   ├── local_lat.cpp
│   ├── local_thr.cpp
│   ├── remote_lat.cpp
│   └── remote_thr.cpp
├── src
│   ├── address.cpp
│   ├── address.hpp
│   ├── array.hpp
│   ├── atomic_counter.hpp
│   ├── atomic_ptr.hpp
│   ├── blob.hpp
│   ├── clock.cpp
│   ├── clock.hpp
│   ├── command.hpp
│   ├── config.hpp
│   ├── ctx.cpp
│   ├── ctx.hpp
│   ├── curve_client.cpp
│   ├── curve_client.hpp
│   ├── curve_server.cpp
│   ├── curve_server.hpp
│   ├── dbuffer.hpp
│   ├── dealer.cpp
│   ├── dealer.hpp
│   ├── decoder.hpp
│   ├── devpoll.cpp
│   ├── devpoll.hpp
│   ├── dist.cpp
│   ├── dist.hpp
│   ├── encoder.hpp
│   ├── epoll.cpp
│   ├── epoll.hpp
│   ├── err.cpp
│   ├── err.hpp
│   ├── fd.hpp
│   ├── fq.cpp
│   ├── fq.hpp
│   ├── gssapi_client.cpp
│   ├── gssapi_client.hpp
│   ├── gssapi_mechanism_base.cpp
│   ├── gssapi_mechanism_base.hpp
│   ├── gssapi_server.cpp
│   ├── gssapi_server.hpp
│   ├── i_decoder.hpp
│   ├── i_encoder.hpp
│   ├── i_engine.hpp
│   ├── io_object.cpp
│   ├── io_object.hpp
│   ├── io_thread.cpp
│   ├── io_thread.hpp
│   ├── ipc_address.cpp
│   ├── ipc_address.hpp
│   ├── ipc_connecter.cpp
│   ├── ipc_connecter.hpp
│   ├── ipc_listener.cpp
│   ├── ipc_listener.hpp
│   ├── ip.cpp
│   ├── ip.hpp
│   ├── i_poll_events.hpp
│   ├── kqueue.cpp
│   ├── kqueue.hpp
│   ├── lb.cpp
│   ├── lb.hpp
│   ├── libzmq.pc.cmake.in
│   ├── libzmq.pc.in
│   ├── libzmq.vers
│   ├── likely.hpp
│   ├── mailbox.cpp
│   ├── mailbox.hpp
│   ├── mechanism.cpp
│   ├── mechanism.hpp
│   ├── metadata.cpp
│   ├── metadata.hpp
│   ├── msg.cpp
│   ├── msg.hpp
│   ├── mtrie.cpp
│   ├── mtrie.hpp
│   ├── mutex.hpp
│   ├── norm_engine.cpp
│   ├── norm_engine.hpp
│   ├── null_mechanism.cpp
│   ├── null_mechanism.hpp
│   ├── object.cpp
│   ├── object.hpp
│   ├── options.cpp
│   ├── options.hpp
│   ├── own.cpp
│   ├── own.hpp
│   ├── pair.cpp
│   ├── pair.hpp
│   ├── pgm_receiver.cpp
│   ├── pgm_receiver.hpp
│   ├── pgm_sender.cpp
│   ├── pgm_sender.hpp
│   ├── pgm_socket.cpp
│   ├── pgm_socket.hpp
│   ├── pipe.cpp
│   ├── pipe.hpp
│   ├── plain_client.cpp
│   ├── plain_client.hpp
│   ├── plain_server.cpp
│   ├── plain_server.hpp
│   ├── platform.hpp.in
│   ├── poll.cpp
│   ├── poller_base.cpp
│   ├── poller_base.hpp
│   ├── poller.hpp
│   ├── poll.hpp
│   ├── precompiled.cpp
│   ├── precompiled.hpp
│   ├── proxy.cpp
│   ├── proxy.hpp
│   ├── pub.cpp
│   ├── pub.hpp
│   ├── pull.cpp
│   ├── pull.hpp
│   ├── push.cpp
│   ├── push.hpp
│   ├── random.cpp
│   ├── random.hpp
│   ├── raw_decoder.cpp
│   ├── raw_decoder.hpp
│   ├── raw_encoder.cpp
│   ├── raw_encoder.hpp
│   ├── reaper.cpp
│   ├── reaper.hpp
│   ├── rep.cpp
│   ├── rep.hpp
│   ├── req.cpp
│   ├── req.hpp
│   ├── router.cpp
│   ├── router.hpp
│   ├── select.cpp
│   ├── select.hpp
│   ├── session_base.cpp
│   ├── session_base.hpp
│   ├── signaler.cpp
│   ├── signaler.hpp
│   ├── socket_base.cpp
│   ├── socket_base.hpp
│   ├── socks_connecter.cpp
│   ├── socks_connecter.hpp
│   ├── socks.cpp
│   ├── socks.hpp
│   ├── stdint.hpp
│   ├── stream.cpp
│   ├── stream_engine.cpp
│   ├── stream_engine.hpp
│   ├── stream.hpp
│   ├── sub.cpp
│   ├── sub.hpp
│   ├── tcp_address.cpp
│   ├── tcp_address.hpp
│   ├── tcp_connecter.cpp
│   ├── tcp_connecter.hpp
│   ├── tcp.cpp
│   ├── tcp.hpp
│   ├── tcp_listener.cpp
│   ├── tcp_listener.hpp
│   ├── thread.cpp
│   ├── thread.hpp
│   ├── tipc_address.cpp
│   ├── tipc_address.hpp
│   ├── tipc_connecter.cpp
│   ├── tipc_connecter.hpp
│   ├── tipc_listener.cpp
│   ├── tipc_listener.hpp
│   ├── trie.cpp
│   ├── trie.hpp
│   ├── v1_decoder.cpp
│   ├── v1_decoder.hpp
│   ├── v1_encoder.cpp
│   ├── v1_encoder.hpp
│   ├── v2_decoder.cpp
│   ├── v2_decoder.hpp
│   ├── v2_encoder.cpp
│   ├── v2_encoder.hpp
│   ├── v2_protocol.hpp
│   ├── windows.hpp
│   ├── wire.hpp
│   ├── xpub.cpp
│   ├── xpub.hpp
│   ├── xsub.cpp
│   ├── xsub.hpp
│   ├── ypipe_base.hpp
│   ├── ypipe_conflate.hpp
│   ├── ypipe.hpp
│   ├── yqueue.hpp
│   ├── zmq.cpp
│   └── zmq_utils.cpp
├── tests
│   ├── test_abstract_ipc.cpp
│   ├── test_bind_src_address.cpp
│   ├── test_capabilities.cpp
│   ├── test_conflate.cpp
│   ├── test_connect_delay_tipc.cpp
│   ├── test_connect_resolve.cpp
│   ├── test_connect_rid.cpp
│   ├── test_ctx_destroy.cpp
│   ├── test_ctx_options.cpp
│   ├── test_diffserv.cpp
│   ├── test_disconnect_inproc.cpp
│   ├── test_filter_ipc.cpp
│   ├── test_fork.cpp
│   ├── test_getsockopt_memset.cpp
│   ├── test_hwm.cpp
│   ├── test_hwm_pubsub.cpp
│   ├── test_immediate.cpp
│   ├── test_inproc_connect.cpp
│   ├── test_invalid_rep.cpp
│   ├── test_iov.cpp
│   ├── test_ipc_wildcard.cpp
│   ├── test_issue_566.cpp
│   ├── test_last_endpoint.cpp
│   ├── test_many_sockets.cpp
│   ├── test_metadata.cpp
│   ├── test_monitor.cpp
│   ├── test_msg_flags.cpp
│   ├── test_pair_inproc.cpp
│   ├── test_pair_ipc.cpp
│   ├── test_pair_tcp.cpp
│   ├── test_pair_tipc.cpp
│   ├── test_probe_router.cpp
│   ├── test_proxy.cpp
│   ├── test_proxy_single_socket.cpp
│   ├── test_proxy_terminate.cpp
│   ├── test_req_correlate.cpp
│   ├── test_req_relaxed.cpp
│   ├── test_reqrep_device.cpp
│   ├── test_reqrep_device_tipc.cpp
│   ├── test_reqrep_inproc.cpp
│   ├── test_reqrep_ipc.cpp
│   ├── test_reqrep_tcp.cpp
│   ├── test_reqrep_tipc.cpp
│   ├── test_router_handover.cpp
│   ├── test_router_mandatory.cpp
│   ├── test_router_mandatory_hwm.cpp
│   ├── test_router_mandatory_tipc.cpp
│   ├── test_security_curve.cpp
│   ├── test_security_null.cpp
│   ├── test_security_plain.cpp
│   ├── test_shutdown_stress.cpp
│   ├── test_shutdown_stress_tipc.cpp
│   ├── test_spec_dealer.cpp
│   ├── test_spec_pushpull.cpp
│   ├── test_spec_rep.cpp
│   ├── test_spec_req.cpp
│   ├── test_spec_router.cpp
│   ├── test_srcfd.cpp
│   ├── test_stream.cpp
│   ├── test_stream_disconnect.cpp
│   ├── test_stream_empty.cpp
│   ├── test_stream_timeout.cpp
│   ├── test_sub_forward.cpp
│   ├── test_sub_forward_tipc.cpp
│   ├── test_system.cpp
│   ├── test_term_endpoint.cpp
│   ├── test_term_endpoint_tipc.cpp
│   ├── test_timeo.cpp
│   ├── test_unbind_inproc.cpp
│   ├── test_unbind_wildcard.cpp
│   ├── testutil.hpp
│   └── test_xpub_nodrop.cpp
├── tools
│   └── curve_keygen.cpp
├── version.sh
└── zeromq.spec

44 directories, 558 files