实现:
编写发布订阅实现,要求发布方以10HZ (十分之一/秒)的频率发布文本消息,订阅方订阅消息并将消息内容打印输出。
分析:
在实现中,ROS master 已有不需要实现,而连接的建立也以及被ros系统封存好了,所以我们只需要关注的关键点有三个
1、发布方
2、接受方
3、数据(此处为普通文本)
流程:
1、编写发布方实现;
2、编写订阅方实现;
3、编辑配置文件;
4、编译并执行;
具体实现:
创建一个工作空间
首先创建一个工作空间以及一个src子目录,然后再进入工作空间调用catkin_make命令编译
mkdir -p demo01_ws/src
cd demo01_ws/
catkin_make
启动VScode
code .
右键点击src,点击Create Catkin Package
输入
plumbing_pub_sub
roscpp rospy std_msgs
在plumbing_pub_sub功能包中的src中新建C++工具包demo01_pub.cpp
在demo01_pub.cpp中编写代码
#include "ros/ros.h"
#include "std_msgs/String.h"
//1.包含ros头文件,ros中文本类型为std_msgs/String.h
int main(int argc, char *argv[])
{
//2.初始化ROS节点 ;
ros::init(argc,argv,"erGouzi");
//3.创建节点句柄;
ros::NodeHandle nh;
//4.创建发布者对象;
ros::Publisher pub=nh.advertise("fang",10);
// nh.advertise创建发布者对象,std_msgs::String数据类型
// fang为话题,用于和订阅方匹配;
// 10代表数据缓冲区,如果我们要发12条消息,但是由于网络延迟要12条全部发送会堵塞,就可以选后10条发送
//5.编写发布逻辑并发布数据;
//创建被发送的消息 msg
std_msgs::String msg;
//编写循环,循环中发布数据
while(ros::ok())//如果这个节点还存在,则while继续执行
{
msg.data = "HOW_ARE_YOU";
pub.publish(msg); //发布数据
}
return 0;
}
打开plumbing_pub_sub的CmakeLists.txt进行文件配置
找到
# add_executable(${PROJECT_NAME}_node src/plumbing_pub_sub_node.cpp)
将其修改为
add_executable(demo01_pub src/demo01_pub.cpp)
找到
# target_link_libraries(${PROJECT_NAME}_node
# ${catkin_LIBRARIES}
# )
将其修改为
target_link_libraries(demo01_pub
${catkin_LIBRARIES}
)
按ctrl+shift+B编译一下
新建一个终端打开ros
roscore
再新建一个终端输入
cd demo03_ws/ source ./devel/setup.bash rosrun plumbing_pub_sub demo01_pub
再新创一个终端输入
rostopic echo fang
如果是这样的,那程序到现在为止都是正确的



