ROS 发布和订阅图片_ros订阅图片

打开摄像头

cap = cv2.VideoCapture("/dev/video0")
cap.set(3, 640)#weight
cap.set(4, 480)#height
ret, frame = cap.read()
# frame = cv2.flip(frame, 0)  ##图像上下颠倒
1
2
3
4
5

发布图片

 image_pub = rospy.Publisher('/image', Image,queue_size=10)#发布话题
1

image_pub.publish(bridge.cv2_to_imgmsg(frame, "bgr8"))
1

订阅图片

rospy.Subscriber("/image", Image,image_callback,queue_size = 10)
1

• 回调函数，将订阅的图片保存

def image_callback(image_data):
    global bridge,count
    #timestr = "%.6f" % image_data.header.stamp.to_sec()
    frame = bridge.imgmsg_to_cv2(image_data, "bgr8")
    image_name = str(count) + ".jpg"  # 图像命名：时间戳.jpg
    cv2.imwrite(image_path + image_name, frame)  # 保存；
    print("图片保存成功:",image_name)
    rospy.Rate(20).sleep()
    count+=1
1
2
3
4
5
6
7
8
9
'
运行
运行

cv_bridge

• 这里发布和订阅图片都用到python3的cv_bridge进行图片类型转换
• 由于Ubuntu16.04和Ubuntu18.04　python默认版本为python2,所以使用python2的cv_bridge会报错
• 需要下载vision_opencv，并编译,就可以使用下图的cv_bridge,具体教程参考博客
• 可以下载我分别在Ubuntu16.04和Ubuntu18.04编译生成的cv_bridge

sys.path.remove("/opt/ros/kinetic/lib/python2.7/dist-packages")
sys.path.append("/home/bo/catkin_ws/src/racecar/racecar_gazebo/scripts/")
from cv_bridge import CvBridge, CvBridgeError
1
2
3

#!/usr/bin/python2
# -*- coding: utf-8 -*-
import time
import rospy
import sys
import cv2
import numpy as np
import math
from sensor_msgs.msg import Image
sys.path.remove("/opt/ros/kinetic/lib/python2.7/dist-packages")
sys.path.append("/home/bo/catkin_ws/src/racecar/racecar_gazebo/scripts/")
from cv_bridge import CvBridge, CvBridgeError
image_path  = '/home/bo/data/'
count=0
def image_callback(image_data):
    global bridge,count
    #timestr = "%.6f" % image_data.header.stamp.to_sec()
    frame = bridge.imgmsg_to_cv2(image_data, "bgr8")
    image_name = str(count) + ".jpg"  # 图像命名：时间戳.jpg
    cv2.imwrite(image_path + image_name, frame)  # 保存；
    print("图片保存成功:",image_name)
    rospy.Rate(20).sleep()
    count+=1


def main():
    try:
        while not rospy.is_shutdown():
            ret, frame = cap.read()
            # frame = cv2.flip(frame, 0)  ##图像上下颠倒
            image_pub.publish(bridge.cv2_to_imgmsg(frame, "bgr8"))

            cv2.imshow('frame', frame)
            cv2.waitKey(3)
            if cv2.waitKey(1) & 0xFF == 27:
                break
        cap.release()
        cv2.destroyAllWindows()
    except rospy.ROSInterruptException:
        pass


if __name__ == '__main__':
    try:
        rospy.init_node('Server_Socket', anonymous=True)  # 初始化节点
        global bridge,cap,image_pub
        bridge = CvBridge()
        cap = cv2.VideoCapture("/dev/video0")
        cap.set(3, 640)#weight
        cap.set(4, 480)#height

        image_pub = rospy.Publisher('/image', Image,queue_size=10)#发布话题
        rospy.Subscriber("/image", Image,image_callback,queue_size = 10)#(订阅的话题名称，数据类型，回调函数（一直监听话题是否传来消息），队列长度)
        main()
        rospy.spin()
    except rospy.ROSInterruptException:
        pass

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58