Skip to content

Commit a51d5ed

Browse files
redboltzredboltz
authored
Merge pull request #812 from redboltz/add_client_cert_example
Added client certificate example.
2 parents 21f6b36 + d163f88 commit a51d5ed

15 files changed

+535
-79
lines changed

‎example/CMakeLists.txt

+7
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ IF (MQTT_USE_TLS)
1717
tls_client.cpp
1818
tls_server.cpp
1919
tls_both.cpp
20+
tls_both_client_cert.cpp
2021
)
2122
ENDIF ()
2223

@@ -68,19 +69,25 @@ FILE(COPY broker.conf DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
6869
FILE(COPY ../test/certs/mosquitto.org.crt DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
6970
FILE(COPY ../test/certs/server.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
7071
FILE(COPY ../test/certs/server.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
72+
FILE(COPY ../test/certs/client.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
73+
FILE(COPY ../test/certs/client.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
7174
FILE(COPY ../test/certs/cacert.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}" )
7275

7376
IF ("${CMAKE_CXX_COMPILER_ID}" STREQUAL "MSVC")
7477
FILE(COPY broker.conf DESTINATION ${CMAKE_CURRENT_BINARY_DIR}/Release)
7578
FILE(COPY ../test/certs/mosquitto.org.crt DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
7679
FILE(COPY ../test/certs/server.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
7780
FILE(COPY ../test/certs/server.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
81+
FILE(COPY ../test/certs/client.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
82+
FILE(COPY ../test/certs/client.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
7883
FILE(COPY ../test/certs/cacert.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Release")
7984

8085
FILE(COPY broker.conf DESTINATION ${CMAKE_CURRENT_BINARY_DIR}/Debug)
8186
FILE(COPY ../test/certs/mosquitto.org.crt DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
8287
FILE(COPY ../test/certs/server.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
8388
FILE(COPY ../test/certs/server.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
89+
FILE(COPY ../test/certs/client.crt.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
90+
FILE(COPY ../test/certs/client.key.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
8491
FILE(COPY ../test/certs/cacert.pem DESTINATION "${CMAKE_CURRENT_BINARY_DIR}/Debug")
8592

8693
ENDIF ()

‎example/no_tls_both.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
288288
[&subs, wp]
289289
(packet_id_t packet_id,
290290
std::vector<MQTT_NS::subscribe_entry> entries) {
291-
locked_cout() << "[server]subscribe received. packet_id: " << packet_id << std::endl;
291+
locked_cout() << "[server] subscribe received. packet_id: " << packet_id << std::endl;
292292
std::vector<MQTT_NS::suback_return_code> res;
293293
res.reserve(entries.size());
294294
auto sp = wp.lock();
@@ -306,7 +306,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
306306
[&subs, wp]
307307
(packet_id_t packet_id,
308308
std::vector<MQTT_NS::unsubscribe_entry> entries) {
309-
locked_cout() << "[server]unsubscribe received. packet_id: " << packet_id << std::endl;
309+
locked_cout() << "[server] unsubscribe received. packet_id: " << packet_id << std::endl;
310310
for (auto const& e : entries) {
311311
subs.erase(e.topic_filter);
312312
}

‎example/no_tls_server.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ int main(int argc, char** argv) {
195195
[&subs, wp]
196196
(packet_id_t packet_id,
197197
std::vector<MQTT_NS::subscribe_entry> entries) {
198-
std::cout << "[server]subscribe received. packet_id: " << packet_id << std::endl;
198+
std::cout << "[server] subscribe received. packet_id: " << packet_id << std::endl;
199199
std::vector<MQTT_NS::suback_return_code> res;
200200
res.reserve(entries.size());
201201
auto sp = wp.lock();
@@ -213,7 +213,7 @@ int main(int argc, char** argv) {
213213
[&subs, wp]
214214
(packet_id_t packet_id,
215215
std::vector<MQTT_NS::unsubscribe_entry> entries) {
216-
std::cout << "[server]unsubscribe received. packet_id: " << packet_id << std::endl;
216+
std::cout << "[server] unsubscribe received. packet_id: " << packet_id << std::endl;
217217
for (auto const& e : entries) {
218218
subs.erase(e.topic_filter);
219219
}

‎example/no_tls_ws_both.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
287287
[&subs, wp]
288288
(packet_id_t packet_id,
289289
std::vector<MQTT_NS::subscribe_entry> entries) {
290-
locked_cout() << "[server]subscribe received. packet_id: " << packet_id << std::endl;
290+
locked_cout() << "[server] subscribe received. packet_id: " << packet_id << std::endl;
291291
std::vector<MQTT_NS::suback_return_code> res;
292292
res.reserve(entries.size());
293293
auto sp = wp.lock();
@@ -305,7 +305,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
305305
[&subs, wp]
306306
(packet_id_t packet_id,
307307
std::vector<MQTT_NS::unsubscribe_entry> entries) {
308-
locked_cout() << "[server]unsubscribe received. packet_id: " << packet_id << std::endl;
308+
locked_cout() << "[server] unsubscribe received. packet_id: " << packet_id << std::endl;
309309
for (auto const& e : entries) {
310310
subs.erase(e.topic_filter);
311311
}

‎example/no_tls_ws_server.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ int main(int argc, char** argv) {
195195
[&subs, wp]
196196
(packet_id_t packet_id,
197197
std::vector<MQTT_NS::subscribe_entry> entries) {
198-
std::cout << "[server]subscribe received. packet_id: " << packet_id << std::endl;
198+
std::cout << "[server] subscribe received. packet_id: " << packet_id << std::endl;
199199
std::vector<MQTT_NS::suback_return_code> res;
200200
res.reserve(entries.size());
201201
auto sp = wp.lock();
@@ -213,7 +213,7 @@ int main(int argc, char** argv) {
213213
[&subs, wp]
214214
(packet_id_t packet_id,
215215
std::vector<MQTT_NS::unsubscribe_entry> entries) {
216-
std::cout << "[server]unsubscribe received. packet_id: " << packet_id << std::endl;
216+
std::cout << "[server] unsubscribe received. packet_id: " << packet_id << std::endl;
217217
for (auto const& e : entries) {
218218
subs.erase(e.topic_filter);
219219
}

‎example/tls_both.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
289289
[&subs, wp]
290290
(packet_id_t packet_id,
291291
std::vector<MQTT_NS::subscribe_entry> entries) {
292-
locked_cout() << "[server]subscribe received. packet_id: " << packet_id << std::endl;
292+
locked_cout() << "[server] subscribe received. packet_id: " << packet_id << std::endl;
293293
std::vector<MQTT_NS::suback_return_code> res;
294294
res.reserve(entries.size());
295295
auto sp = wp.lock();
@@ -307,7 +307,7 @@ void server_proc(Server& s, std::set<con_sp_t>& connections, mi_sub_con& subs) {
307307
[&subs, wp]
308308
(packet_id_t packet_id,
309309
std::vector<MQTT_NS::unsubscribe_entry> entries) {
310-
locked_cout() << "[server]unsubscribe received. packet_id: " << packet_id << std::endl;
310+
locked_cout() << "[server] unsubscribe received. packet_id: " << packet_id << std::endl;
311311
for (auto const& e : entries) {
312312
subs.erase(e.topic_filter);
313313
}

0 commit comments

Comments
 (0)