Zmq.hpp

chronolaw · chronolaw · commit b5828b9afe8f · 2020-04-10T11:31:37.000+08:00
diff --git a/section5/Zmq.hpp b/section5/Zmq.hpp
@@ -1,10 +1,11 @@
 // Copyright (c) 2020 by Chrono
 
-#ifndef _SPIN_LOCK_HPP
-#define _SPIN_LOCK_HPP
+#ifndef _ZMQ_HPP
+#define _ZMQ_HPP
 
 #include "cpplang.hpp"
 
+// /usr/include/zmq.hpp
 #include <zmq.hpp>
 
 BEGIN_NAMESPACE(cpp_study)
@@ -30,19 +31,26 @@ class ZmqContext final
         return ctx;
     }
 public:
-    zmq_socket_type socket(int mode, size_t hwm = 1000) const
+    zmq_socket_type recv_sock(size_t hwm = 1000) const
     {
-        zmq_socket_type sock(context(), mode);
+        zmq_socket_type sock(context(), ZMQ_PULL);
 
-        sock.setsockopt(
-            mode == ZMQ_PULL ? ZMQ_RCVHWM : ZMQ_SNDHWM,
-            hwm);
+        sock.setsockopt(ZMQ_RCVHWM, hwm);
+
+        return sock;
+    }
+
+    zmq_socket_type send_sock(size_t hwm = 1000) const
+    {
+        zmq_socket_type sock(context(), ZMQ_PUSH);
+
+        sock.setsockopt(ZMQ_SNDHWM, hwm);
 
         return sock;
     }
 };
 
 END_NAMESPACE(cpp_study)
 
-#endif  //_SPIN_LOCK_HPP
+#endif  //_ZMQ_HPP
 
diff --git a/section5/config.lua b/section5/config.lua
@@ -1,10 +1,15 @@
 -- copyright (c) 2020 chrono
 
--- it is more flexible than json
+-- lua is more flexible than json
+
 config = {
 
     max_buf_size = 4 * 1024,
 
+    zmq_ipc_addr = "tcp://127.0.0.1:5555",
+
+    http_addr = "http://localhost/cpp_study?token=cpp@2020",
+
     keyword = "super",
 
     sold_criteria = 100,
