ROS講座121 rosbridge経由でpub/subをする
環境
この記事は以下の環境で動いています。
項目 | 値 |
---|---|
CPU | Core i5-8250U |
Ubuntu | 18.04 |
ROS | Melodic |
インストールについてはROS講座02 インストールを参照してください。
またこの記事のプログラムはgithubにアップロードされています。ROS講座11 gitリポジトリを参照してください。
概要
ROSを使えばpub-subを簡単に行うことが出来ますが、例えばロボットのほかのPCで操作用のGUIを表示したいというときには複数のPC間でROSが動くように設定をしなければなりません(20 複数のPCでROS接続1)ただしこのの方法では。
- PCのIP設定などの設定が煩雑
- rosmasterが一度落ちるとシステム全体を再起動しないといけない
- ROSのそのままの通信なのでランダムに多数のポートを使った通信をする
- 同一のセグメントにいないと使用不可
- 複数のマシンに同時につなぐなどの運用が不可
等のように実際に使おうとすると多くの制約がつきます。
そこでWEbからのアクセスの時に使ったようにrosbridgeを使ってこれ越しにpub,subする方法を解説します。
jsonパーサー
rosbridgeではデータをjson形式にしてやり取りします。json parserは数々のものがありますが、ROSパッケージとして以下のjson transportがあるので今回はこれを使います。これはnlohmannをラップしているものです。以下のコマンドでインストールできます。
sudo apt install ros-melodic-json-transport
Simple-WebSocket-Server
今回rosbridge_serverにはwebsocketという通信方式でアクセスします。websocketとはtcp上で実装されているプロトコルで、双方向通信を簡単に行うためのものです。今回Simple-WebSocket-Serverというライブラリを使用します。
ライブラリのインストール
このライブラリはバイナリではなくソースで提供しているので、git submoduleで抱えてみましょう
cd ros_lecture/app_lecture
git submodule add https://gitlab.com/eidheim/Simple-WebSocket-Server.git
ソースコード
cpp
app_lecture/src/rosbridge_client_example.cpp
#include <stdio.h>
#include <client_ws.hpp>
#include <memory>
#include <thread>
#include <ros/static_assert.h>
#include <json_transport/json_transport.hpp>
using WsClient = SimpleWeb::SocketClient<SimpleWeb::WS>;
class RosBrigeClientExample
{
public:
RosBrigeClientExample(std::string target) : client_(target)
{
using namespace std::placeholders;
client_.on_open = std::bind(&RosBrigeClientExample::onOpen, this, _1);
client_.on_message = std::bind(&RosBrigeClientExample::onMessage, this, _1, _2);
client_.on_close = std::bind(&RosBrigeClientExample::onClose, this, _1, _2, _3);
client_.on_error = std::bind(&RosBrigeClientExample::onError, this, _1, _2);
send_thread_ = std::thread(std::bind(&RosBrigeClientExample::sendThread, this));
ws_thread_ = std::thread([&] { client_.start(); });
}
private:
void onOpen(std::shared_ptr<WsClient::Connection> connection)
{
std::cout << "Client: Opened connection" << std::endl;
connection_ = connection;
// advertise
json_transport::json_t command;
command["op"] = "advertise";
command["topic"] = "/hello_from_client";
command["type"] = "std_msgs/String";
connection_->send(command.dump());
// subscribe
command.clear();
command["op"] = "subscribe";
command["topic"] = "/hello_from_ros";
command["type"] = "std_msgs/String";
connection_->send(command.dump());
};
void onMessage(std::shared_ptr<WsClient::Connection> connection, std::shared_ptr<WsClient::InMessage> in_message)
{
json_transport::json_t recv = json_transport::json_t::parse(in_message->string());
if (recv["topic"].is_string() && recv["topic"] == "/hello_from_ros")
{
std::cout << "recv: " << recv["msg"]["data"] << std::endl;
}
};
void onClose(std::shared_ptr<WsClient::Connection> connection, int status, const std::string& reason)
{
std::cout << "Client: Closed connection with status code " << status << std::endl;
};
void onError(std::shared_ptr<WsClient::Connection> connection, const SimpleWeb::error_code& ec)
{
std::cout << "Client: Error: " << ec << ", error message: " << ec.message() << std::endl;
};
void sendThread(void)
{
while (true)
{
if (connection_)
{
json_transport::json_t command, msg;
command["op"] = "publish";
command["topic"] = "/hello_from_client";
msg["data"] = "hello client->ros";
command["msg"] = msg;
const std::string output = command.dump();
connection_->send(output);
}
sleep(2);
}
}
WsClient client_;
std::shared_ptr<WsClient::Connection> connection_;
std::thread send_thread_;
std::thread ws_thread_;
};
int main(int argc, char** argv)
{
printf("start\n");
RosBrigeClientExample rosbridge_client_example("localhost:9090");
while (true)
{
sleep(1);
}
return 0;
}
-
SimpleWeb::SocketClient<SimpleWeb::WS>;
がwebsocketのクライアントを操作するクラスです。
-
SimpleWeb::SocketClient<SimpleWeb::WS>("localhost:9090/hoge")
とインスタンス化します。引数はターゲットとなるWebSocketのサーバーのアドレスです。
- on_open、on_message、on_close、on_errorの4つのメソッドを登録します。Websocketのサーバーにつながるとon_openが、サーバーからのメッセージが来ればon_messageが呼び出されます。
-
start()
はブロッキングなメソッドなので別スレッドに今回しました。
- WebSocket自体はただの文字列の送受信をするにとどまります。rosbridgeではjson形式の文字列を送受信して通信を行います。
-
{"op":"advertise","topic":"/hello_from_client","type":"std_msgs/String"}
でpublishの開始(advertise)をします。
-
{"op":"subscribe","topic":"/hello_from_ros","type":"std_msgs/String"}
でsubscribeの開始をします。
- 実際にtopicを送る際は
{"op":"publish","topic":"/hello_from_client","type":"std_msgs/String","msg":"*******"}
とします。msgの内容はmsgフィールド以下に詰めます。
CMakeList
app_lecture/CMakeLists.txtの編集事項
find_package(catkin REQUIRED COMPONENTS
roscpp
json_transport # この行を追加(1)
)
add_subdirectory(Simple-WebSocket-Server) # この行を追加(2)
include_directories(
# include
${catkin_INCLUDE_DIRS}
Simple-WebSocket-Server # この行を追加(3)
)
add_executable(rosbridge_client_example src/rosbridge_client_example.cpp)
target_link_libraries(rosbridge_client_example
simple-websocket-server # この行を追加(4)
)
- (1)json_transport が必要なので追加します。
- (2)submoduleとして取得したSimple-WebSocket-Serverをビルドするために必要です。
- (3)Simple-WebSocket-Serverディレクトリのヘッダファイルをインクルードするのに必要です。
- (4)Simple-WebSocket-Serverをビルドしてできるライブラリのバイナリをリンクするのに必要です。
ビルド
cd ~/catkin_ws
catkin_make
実行
1つ目のターミナル
roslaunch rosbridge_server rosbridge_websocket.launch
2つ目のターミナル
rosrun app_lecture rosbridge_client_example
#include <stdio.h>
#include <client_ws.hpp>
#include <memory>
#include <thread>
#include <ros/static_assert.h>
#include <json_transport/json_transport.hpp>
using WsClient = SimpleWeb::SocketClient<SimpleWeb::WS>;
class RosBrigeClientExample
{
public:
RosBrigeClientExample(std::string target) : client_(target)
{
using namespace std::placeholders;
client_.on_open = std::bind(&RosBrigeClientExample::onOpen, this, _1);
client_.on_message = std::bind(&RosBrigeClientExample::onMessage, this, _1, _2);
client_.on_close = std::bind(&RosBrigeClientExample::onClose, this, _1, _2, _3);
client_.on_error = std::bind(&RosBrigeClientExample::onError, this, _1, _2);
send_thread_ = std::thread(std::bind(&RosBrigeClientExample::sendThread, this));
ws_thread_ = std::thread([&] { client_.start(); });
}
private:
void onOpen(std::shared_ptr<WsClient::Connection> connection)
{
std::cout << "Client: Opened connection" << std::endl;
connection_ = connection;
// advertise
json_transport::json_t command;
command["op"] = "advertise";
command["topic"] = "/hello_from_client";
command["type"] = "std_msgs/String";
connection_->send(command.dump());
// subscribe
command.clear();
command["op"] = "subscribe";
command["topic"] = "/hello_from_ros";
command["type"] = "std_msgs/String";
connection_->send(command.dump());
};
void onMessage(std::shared_ptr<WsClient::Connection> connection, std::shared_ptr<WsClient::InMessage> in_message)
{
json_transport::json_t recv = json_transport::json_t::parse(in_message->string());
if (recv["topic"].is_string() && recv["topic"] == "/hello_from_ros")
{
std::cout << "recv: " << recv["msg"]["data"] << std::endl;
}
};
void onClose(std::shared_ptr<WsClient::Connection> connection, int status, const std::string& reason)
{
std::cout << "Client: Closed connection with status code " << status << std::endl;
};
void onError(std::shared_ptr<WsClient::Connection> connection, const SimpleWeb::error_code& ec)
{
std::cout << "Client: Error: " << ec << ", error message: " << ec.message() << std::endl;
};
void sendThread(void)
{
while (true)
{
if (connection_)
{
json_transport::json_t command, msg;
command["op"] = "publish";
command["topic"] = "/hello_from_client";
msg["data"] = "hello client->ros";
command["msg"] = msg;
const std::string output = command.dump();
connection_->send(output);
}
sleep(2);
}
}
WsClient client_;
std::shared_ptr<WsClient::Connection> connection_;
std::thread send_thread_;
std::thread ws_thread_;
};
int main(int argc, char** argv)
{
printf("start\n");
RosBrigeClientExample rosbridge_client_example("localhost:9090");
while (true)
{
sleep(1);
}
return 0;
}
SimpleWeb::SocketClient<SimpleWeb::WS>;
がwebsocketのクライアントを操作するクラスです。
-
SimpleWeb::SocketClient<SimpleWeb::WS>("localhost:9090/hoge")
とインスタンス化します。引数はターゲットとなるWebSocketのサーバーのアドレスです。 - on_open、on_message、on_close、on_errorの4つのメソッドを登録します。Websocketのサーバーにつながるとon_openが、サーバーからのメッセージが来ればon_messageが呼び出されます。
-
start()
はブロッキングなメソッドなので別スレッドに今回しました。
-
{"op":"advertise","topic":"/hello_from_client","type":"std_msgs/String"}
でpublishの開始(advertise)をします。 -
{"op":"subscribe","topic":"/hello_from_ros","type":"std_msgs/String"}
でsubscribeの開始をします。 - 実際にtopicを送る際は
{"op":"publish","topic":"/hello_from_client","type":"std_msgs/String","msg":"*******"}
とします。msgの内容はmsgフィールド以下に詰めます。
find_package(catkin REQUIRED COMPONENTS
roscpp
json_transport # この行を追加(1)
)
add_subdirectory(Simple-WebSocket-Server) # この行を追加(2)
include_directories(
# include
${catkin_INCLUDE_DIRS}
Simple-WebSocket-Server # この行を追加(3)
)
add_executable(rosbridge_client_example src/rosbridge_client_example.cpp)
target_link_libraries(rosbridge_client_example
simple-websocket-server # この行を追加(4)
)
cd ~/catkin_ws
catkin_make
実行
1つ目のターミナル
roslaunch rosbridge_server rosbridge_websocket.launch
2つ目のターミナル
rosrun app_lecture rosbridge_client_example
roslaunch rosbridge_server rosbridge_websocket.launch
rosrun app_lecture rosbridge_client_example
clientのプログラムがrosbridge_serverに接続すると1つ目のターミナルのほうに[INFO] [....]: Client connected. 1 clients total.
と表示されます。
この状態でrostopic list
とすると/hello_from_client
と/hello_from_ros
の2つのROSトピックがあることが分かります。
client->rosbridgeの通信の確認
rostopic echo /hello_from_client
とするとclient由来のmsgが流れてくることが分かります。
rosbridge->clientの通信の確認
rostopic pub -1 /hello_from_ros std_msgs/String "data: 'sample'"
とするとclient側の画面にdataの内容が表示されます。
参考
nlohmannのAPI説明
Simple-WebSocket-Server
目次ページへのリンク
Author And Source
この問題について(ROS講座121 rosbridge経由でpub/subをする), 我々は、より多くの情報をここで見つけました https://qiita.com/srs/items/1fcbd720e2489a0ce7cf著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .