服务器之家:专注于VPS、云服务器配置技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - C/C++ - C++ Thread实现简单的socket多线程通信

C++ Thread实现简单的socket多线程通信

2023-02-21 16:45合工大机器人实验室 C/C++

本文主要介绍了C++ Thread实现简单的socket多线程通信,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

起因

为什么要用C++的Thread,很简单,因为我菜

一打五用pthread实现了socket多线程通信,我之前学并发的时候没看pthread,因此代码只能看个大概,后面还是要系统学一下pthread的

服务端

多线程功能放在腾讯云服务器上,代码如下:

?
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
#include "tcpserver.h"
#include <thread>
#include <mutex>
 
TcpServer server;
mutex tcp_mutex;
 
void tcpFunc(int clientfd);
 
int main(int argc, char *argv[])
{
 
    if (server.initServer(6666) == false)
    {
        cout << "服务端初始化失败!!!" << endl;
        return -1;
    }
 
    vector<thread> tcp_vec;
    while (true)
    {
        if (!server.tcpAccept())
        {
            continue;
        }
        tcp_vec.emplace_back(tcpFunc, server.m_connectfd);
        // thread tcpThread(tcpFunc, server.m_connectfd);
        // if (tcpThread.joinable())
        if(tcp_vec.back().joinable())
        {
            // cout << "Tcp thread " << tcpThread.get_id() << "is joinable!" << endl;
            cout << "Tcp thread " << tcp_vec.back().get_id() << " is joinable!" << endl;
            tcp_vec.back().detach();
        }
    }
 
    return 0;
}
 
void tcpFunc(int clientfd)
{
    int buf_len = 0;
    char buffer[1024];
    while (true)
    {
        unique_lock<mutex> tcplck(tcp_mutex);
        memset(buffer, 0, sizeof(buffer));
        if (!server.tcpRecv(clientfd, buffer, &buf_len, 5))
        {
            cout << "接收客户端数据失败!" << endl;
            tcplck.unlock();
            break;
        }
        cout << "服务端接收数据:" << buffer << endl;
 
        strcpy(buffer, "I am your father!");
        if (!server.tcpSend(clientfd, buffer, sizeof(buffer)))
        {
            cout << "向客户端发送数据失败!" << endl;
            tcplck.unlock();
            break;
        }
        tcplck.unlock();
                usleep(100);
    }
    cout << "通信异常!" << endl;
    return;
}

实在是很简单,贻笑大方了

有几个注意点:

  • 全局变量在main函数执行完后会销毁,线程中用到了全局变量server,线程detach后要保证数据的收发,就要保持server的生存期,这里体现为在main中循环等待客户端的连接
  • 要用锁锁住线程中server的操作,避免不同线程同时操作server造成混乱
  • usleep(100);是为了避免不同线程争抢同一把锁而造成死锁的发生

ROS客户端

?
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
#include "tcpclient.h"
#include <ros/ros.h>
#include <geometry_msgs/Twist.h>
 
TcpClient client;
string send_str = "I am king of the world!";
char recv_buff[1024];
 
void client_callback(const geometry_msgs::Twist::ConstPtr &msg)
{
    cout << "vel X:" << msg->linear.x << ";vel Y:" << msg->linear.y << ";angular Z:" << msg->angular.z << endl;
    if (!client.tcpSend(client.m_sockfd, send_str.data(), send_str.size()))
    {
        cout << "向服务端发送报文失败!" << endl;
    }
    if (!client.tcpRecv(client.m_sockfd, recv_buff, NULL, 10))
    {
        cout << "从服务端接收报文失败!" << endl;
    }
    cout << "接收服务端报文:" << recv_buff << endl << endl;
}
 
int main(int argc, char **argv)
{
    ros::init(argc, argv, "joystick_client");
    ros::NodeHandle nh;
 
    string server_ip = "1.116.137.21";
    string loop_ip = "127.0.0.1";
 
    if (client.connectToServer(server_ip.data(), 6666) == false)
    {
        cout << "连接失败!!!" << endl;
        return -1;
    }
 
    ros::Subscriber sub = nh.subscribe("/cmd_vel", 1, client_callback);
 
    ros::spin();
}

很简单,订阅了手柄发布的话题/cmd_vel,在回调函数中和服务端通讯

话题的发布频率是10Hz,意味着和服务端通讯的频率也是10Hz

普通客户端

?
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
#include "tcp/tcpclient.h"
 
int main(int argc, char **argv)
{
    TcpClient client;
 
    string server_ip = "1.116.137.21";
    string loop_ip = "127.0.0.1";
 
    if (client.connectToServer(server_ip.data(), 6666) == false)
    {
        cout << "连接失败!!!" << endl;
        return -1;
    }
    cout << "成功连接服务器!" << endl;
 
    char buff[1024];
    while (true)
    {
        memset(buff, 0, sizeof(buff));
        sprintf(buff, "Ouch!");
        if (!client.tcpSend(client.m_sockfd, buff, sizeof(buff)))
        {
            cout << "向服务端发送报文失败!" << endl;
            return -1;
        }
 
        memset(buff, 0, sizeof(buff));
        if (!client.tcpRecv(client.m_sockfd, buff, NULL, 5))
        {
            cout << "从服务端接收报文失败!" << endl;
            return -1;
        }
        cout << "接收服务端报文:" << buff << endl << endl;
        sleep(0.1);
    }
    return 0;
}

这里sleep(0.1);是为了模拟ROS中话题的频率

sleep过长会导致服务端阻塞等待该客户端的消息,从而导致其余客户端与服务端的通信失败(如果客户端中允许的通信延时很短的话)

运行效果

云服务器上的服务端

[root@VM-4-11-centos bin]# ./server_thread 
Tcp thread 140662362572544 is joinable!
服务端接收数据:I am king of the world!
服务端接收数据:I am king of the world!
服务端接收数据:I am king of the world!
服务端接收数据:I am king of the world!
Tcp thread 140662354179840 is joinable!
服务端接收数据:I am king of the world!
服务端接收数据:Ouch!
服务端接收数据:I am king of the world!
服务端接收数据:Ouch!
服务端接收数据:I am king of the world!
服务端接收数据:Ouch!
服务端接收数据:I am king of the world!
服务端接收数据:Ouch!

笔记本上的ROS客户端

redwall@redwall-G3-3500:~$ rosrun joystick_client joystick_client 
[ERROR] [1656939307.244367879]: [registerPublisher] Failed to contact master at [localhost:11311].  Retrying...
[ INFO] [1656939314.923909682]: Connected to master at [localhost:11311]
vel X:0;vel Y:0;angular Z:0
接收服务端报文:I am your father!

vel X:0;vel Y:0;angular Z:0
接收服务端报文:I am your father!

vel X:0;vel Y:0;angular Z:0
接收服务端报文:I am your father!

虚拟机的普通客户端

  • prejudice@prejudice-VirtualBox:~/socket_test/socket_for_linux/bin$ ./tcp_client 成功连接服务器!
  • 接收服务端报文:I am your father!
  • 接收服务端报文:I am your father!
  • 接收服务端报文:I am your father!

不足

  • 未考虑线程的清理
  • 未考虑信号的退出处理

 到此这篇关于C++ Thread实现简单的socket多线程通信的文章就介绍到这了,更多相关C++  socket多线程通信内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/qq_34935373/article/details/125608828

延伸 · 阅读

精彩推荐
  • C/C++C++实现广度优先遍历图

    C++实现广度优先遍历图

    这篇文章主要为大家详细介绍了C++实现广度优先遍历图,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    Kayla小可爱4352022-01-07
  • C/C++C++简明分析inline函数的使用

    C++简明分析inline函数的使用

    inline是C++关键字,在函数声明或定义中,函数返回类型前加上关键字inline,即可以把函数指定为内联函数。这样可以解决一些频繁调用的函数大量消耗栈空...

    编程小程7972023-02-16
  • C/C++深入解读C++中的指针变量

    深入解读C++中的指针变量

    这篇文章主要介绍了深入解读C++中的指针变量,是C语言入门学习中的基础知识,需要的朋友可以参考下...

    C++教程网4622021-03-13
  • C/C++C语言实现的猜数字小游戏

    C语言实现的猜数字小游戏

    这篇文章主要为大家详细介绍了C语言实现的猜数字小游戏,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    LI大大11302021-08-11
  • C/C++C++设计模式之抽象工厂模式

    C++设计模式之抽象工厂模式

    这篇文章主要介绍了C++设计模式之抽象工厂模式,本文要讲的抽象工厂模式,就是工厂方法模式的扩展和延伸,需要的朋友可以参考下...

    果冻想7102021-02-03
  • C/C++C语言中的指针以及二级指针代码详解

    C语言中的指针以及二级指针代码详解

    这篇文章主要介绍了C语言中的指针以及二级指针代码详解,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下...

    luciferbeing10782021-06-18
  • C/C++C++调用C接口的实现示例

    C++调用C接口的实现示例

    这篇文章主要介绍了C++调用C接口的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着...

    DeRoy3902021-10-08
  • C/C++C语言辗转相除法求2个数的最小公约数

    C语言辗转相除法求2个数的最小公约数

    辗转相除法最大的用途就是用来求两个数的最大公约数。下面通过本文给大家介绍C语言辗转相除法求2个数的最小公约数,非常不错,感兴趣的朋友一起看...

    legenda6242021-04-24