add request logic

cmu/src/cmd_processer_server.cc

@@ -51,6 +51,6 @@ namespace offcn
 	}
 	void CmdProcesserServer::OnServerMessageArrived(std::string topic, std::string message)
 	{
-		printf("receive message : topic = %s, context : %s\n", topic.c_str(), message.c_str());
+		printf("\nreceive message : topic = %s, context : %s\n", topic.c_str(), message.c_str());
 	}
 }
\ No newline at end of file

kcp-client/kcp-client.vcxproj

@@ -22,12 +22,14 @@
     <ClCompile Include="..\thirdparty\jsoncpp\src\json_reader.cpp" />
     <ClCompile Include="..\thirdparty\jsoncpp\src\json_value.cpp" />
     <ClCompile Include="..\thirdparty\jsoncpp\src\json_writer.cpp" />
+    <ClCompile Include="..\thirdparty\mqtt\mqtt_request.cc" />
     <ClCompile Include="..\thirdparty\mqtt\mqtt_wrapper.cc" />
     <ClCompile Include="src\cmd_processer_client.cc" />
     <ClCompile Include="src\kcp-client.cpp" />
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="..\thirdparty\jsoncpp\src\json_tool.h" />
+    <ClInclude Include="..\thirdparty\mqtt\mqtt_request.h" />
     <ClInclude Include="..\thirdparty\mqtt\mqtt_wrapper.h" />
     <ClInclude Include="src\cmd_processer_client.h" />
   </ItemGroup>

kcp-client/kcp-client.vcxproj.filters

@@ -39,6 +39,9 @@
     <ClCompile Include="..\thirdparty\jsoncpp\src\json_writer.cpp">
       <Filter>源文件\json</Filter>
     </ClCompile>
+    <ClCompile Include="..\thirdparty\mqtt\mqtt_request.cc">
+      <Filter>源文件\mqtt</Filter>
+    </ClCompile>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="..\thirdparty\mqtt\mqtt_wrapper.h">
@@ -50,6 +53,9 @@
     <ClInclude Include="..\thirdparty\jsoncpp\src\json_tool.h">
       <Filter>源文件\json</Filter>
     </ClInclude>
+    <ClInclude Include="..\thirdparty\mqtt\mqtt_request.h">
+      <Filter>源文件\mqtt</Filter>
+    </ClInclude>
   </ItemGroup>
   <ItemGroup>
     <None Include="..\thirdparty\jsoncpp\src\json_valueiterator.inl">

kcp-client/src/cmd_processer_client.cc

 #include "cmd_processer_client.h"
+#include "mqtt_request.h"
 
 namespace offcn
 {
@@ -46,7 +47,7 @@ namespace offcn
 		printf("subscribe topic success!\n");
 		
 		std::string topic = kGlobalTopic;
-		std::string req = "I am Programmer";
+		std::string req = MqttRequest::JoinRequest(kLocalID);;
 
 		mqtt_wrapper_->SendRequest(topic, req);
 	}