首页 > 代码库 > stream opencv mat (webcam)frame throught tcp by boost asio

stream opencv mat (webcam)frame throught tcp by boost asio

2024-07-02 01:16:46   223人阅读

客户端：

?
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
/*
 * =====================================================================================
 *
 *       Filename:  client.cpp
 *     
 *    Description:  stream opencv Mat frame to server by tcp with boost asio
 *
 *
 *        Version:  1.0
 *        Created:  2014/4/29 11:40:20
 *         Author:  yuliyang
 *
 *           Mail:  wzyuliyang911@gmail.com
 *           Blog:  http://www.cnblogs.com/yuliyang
 *
 * =====================================================================================
 */
 
#include <iostream>
#include <boost/array.hpp>
#include <boost/asio.hpp>
#include <opencv2/objdetect/objdetect.hpp>
#include "opencv2/highgui/highgui.hpp"
#include "opencv2/imgproc/imgproc.hpp"
#include <opencv2/core/core.hpp> 
#include <ctime>
#include <string>
using boost::asio::ip::tcp;
using namespace  std;
using namespace cv;
 
int main()
{
    VideoCapture cap(0);                        /* open webcam */
    if(!cap.isOpened()) 
    { 
        return -1; 
    } 
 
     
    Mat frame;
    cap.set(CV_CAP_PROP_FRAME_WIDTH, 320);      /* set width */
    cap.set(CV_CAP_PROP_FRAME_HEIGHT, 240);     /* set height */
     
        //capture.read(frame);
     
        //frame=imread("g://tinyproxy.jpg");
    while (true)
    {
        cap>>frame;
        imshow("client",frame);  
        waitKey(100);
 
 
     
 
    frame = (frame.reshape(0,1)); // to make it continuous
    int num=frame.total();                      /* num = 320*240 */
    int num2=frame.elemSize();                  /* mun2 =3 channel */
    int  imgSize = frame.total()*frame.elemSize();
    try
    {
        boost::asio::io_service io_service;
        tcp::endpoint end_point(boost::asio::ip::address::from_string("127.0.0.1"), 3200);
 
        tcp::socket socket(io_service);
        socket.connect(end_point);
        boost::system::error_code ignored_error;
         
        /*time_t now = time(0);
 
        std::string message = ctime(&now);
        socket.write_some(boost::asio::buffer(message), ignored_error);*/
 
 
        //std::string message(frame.begin<unsigned char>(),frame.end<unsigned char>());
        std::string message((char *)frame.data,230400); /* the size of mat data is 320*240*3 */
        cout<<"sending...."<<endl;
        socket.write_some(boost::asio::buffer(message), ignored_error);
 
        cout<<"send image finished"<<endl;
    }
    catch (std::exception& e)
    {
        std::cerr << e.what() << std::endl;
    }
 
    }
         
 
    return 0;
 
 
 
 
 
    //try
    //{
    //  boost::asio::io_service io_service;
 
    //  tcp::resolver resolver(io_service);
 
    //  char* serverName = "localhost";
    //  tcp::resolver::query query(serverName, "daytime");
    //  tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
 
    //  tcp::socket socket(io_service);
    //  while(true)
    //  {
    //      boost::asio::connect(socket, endpoint_iterator);
 
    //      for (;;)
    //      {
    //          boost::array<char, 128> buf;
    //          boost::system::error_code error;
 
    //          size_t len = socket.read_some(boost::asio::buffer(buf), error);
 
    //          if (error == boost::asio::error::eof)
    //              break; // Connection closed cleanly by peer.
    //          else if (error)
    //              throw boost::system::system_error(error); // Some other error.
 
    //          std::cout.write(buf.data(), len);
    //          std::cout <<"\n";
    //      }
    //  }
    //}
    //catch (std::exception& e)
    //{
    //  std::cerr << e.what() << std::endl;
    //}
 
    //return 0;
}

 服务器端

?
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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
/*
 * =====================================================================================
 *
 *       Filename:  server.cpp
 *     
 *    Description:  stream opencv mat frame server
 *
 *
 *        Version:  1.0
 *        Created:  2014/4/29 11:44:51
 *         Author:  yuliyang
 *
 *           Mail:  wzyuliyang911@gmail.com
 *           Blog:  http://www.cnblogs.com/yuliyang
 *
 * =====================================================================================
 */
 
#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <boost/array.hpp>
#include "opencv2/highgui/highgui.hpp"
#include "opencv2/imgproc/imgproc.hpp"
#include <opencv2/objdetect/objdetect.hpp>
#include <iostream>
#include <vector>
#include <boost/thread/thread.hpp>
using boost::asio::ip::tcp;
using namespace  std;
using namespace cv;
Mat  img = Mat::zeros( 320,240, CV_8UC3);
bool flag = false;                              /* if flag is false ,the thread is not ready to show the mat frame */
 
void servershow()
{
    while (true)
    {
        if (flag)
        {
            imshow("server",img);
            waitKey(20);
        }
         
         
    }
     
}
int main()
{
    boost::thread thrd(&servershow);
    try
    {
        boost::asio::io_service io_service;
        boost::array<char, 230400> buf;         /* the size of reciev mat frame is caculate by 320*240*3 */
        tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 3200));
         
        for (;;)
        {
            tcp::socket socket(io_service);
            acceptor.accept(socket);
            boost::system::error_code error;
            size_t len = socket.read_some(boost::asio::buffer(buf), error);
            cout<<"get data length :"<<len<<endl; /* disp the data size recieved */
            std::vector<uchar> vectordata(buf.begin(),buf.end()); /* change the recieved mat frame(1*230400) to vector */
            cv::Mat data_mat(vectordata,true);
        /*  cout<<"cols:"<<data_mat.cols<<endl;
            cout<<"rows:"<<data_mat.rows<<endl;
            cout<<"total:"<<data_mat.total()<<endl;
            cout<<"elemSize:"<<data_mat.elemSize()<<endl;*/
            img= data_mat.reshape(3,240);       /* reshape to 3 channel and 240 rows */
            cout<<"reshape over"<<endl;
            flag =true;
            /*imshow("server",img);
            waitKey(100);*/
            //imwrite("save.jpg",img);
            /*std::string message = "This is the Server!";
 
            boost::system::error_code ignored_error;
            boost::asio::write(socket, boost::asio::buffer(message), ignored_error);*/
        }
    }
    catch (std::exception& e)
    {
        std::cerr << e.what() << std::endl;
    }
    thrd.join();
     
 
    return 0;
}

 效果：


联系
我们