socket+多线程linux下简单实现python与C++进程通信

文章目录

• 前言
• 
  

  一、Socket和多线程

• 
  

  二、效果演示

• 
  

  三、代码

---

前言

本文在ubuntu16.04下实现了python向c++发送数据的socket通信，同时在两个进程中分别开启两个线程，主线程负责处理数据，子线程负责socket通信。

（我也是刚开始学，用比较粗糙的方法实现python和c++通信，可能加上线程锁的相关内容会更加严谨，希望大家多多交流指正。

）

	python call.py	C++ listen.cpp
主线程	随机产生数据	获取数据并打印
子线程	socket发送	socket接收

一、Socket和多线程

Socket原理讲解
C++多线程并发（一）— 线程创建与管理
浅谈C++中的多线程（一）

二、效果演示

python发送的数据格式为 str(double，double，double)以,隔开，C++接收后存入vector中。

三、代码

程序是在同一台机器的两个终端执行的，如果要在不同机器实现通信，需要两台机器在同一个网段内，再修改代码中的ip地址。

Python call.py

import socket
import time
import _thread
import random

def socket_send(name):
    while(1):
        try:
            global msg #使用全局变量进行数据传递
            p = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
            p.connect(('127.0.0.1',1234))
            p.send(msg.encode('utf-8'))
            p.close() 
            time.sleep(0.5)
        except:
            # print ("Connection refused")
            continue
list=[0.123124,2.2145,3.023489]#初始化list防止子线程第一次跑不了
strn=str(list[0])
for i in range(1,len(list)):
    strn=strn+','+str(list[i])
msg = strn
name=1
_thread.start_new_thread(socket_send,(name,))#开启多线程
while 1:
    list.clear()
    for i in range(0,3):
        list.append(round(random.random(),6))
    strn=str(list[0])
    for i in range(1,len(list)):
        strn=strn+','+str(list[i])#将数据用,隔开便于C++获取
    msg = strn
    print(msg)
    time.sleep(0.5)

C++ listen.cpp

#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include   // for std::ostream_iterator
#include  // for std::copy
using namespace std;
//打印vector
void print_(vector<double> *p)
{
    for (std::vector<double>::const_iterator i = p->begin(); i != p->end(); i++)
    {
        std::cout << *i << " ";
    }
    cout << endl;
}
//socket监听
void socket_listen(vector<double> *p, int *flag)
{
    int serv_sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    //将套接字和IP、端口绑定
    struct sockaddr_in serv_addr;
    memset(&serv_addr, 0, sizeof(serv_addr));           //每个字节都用0填充
    serv_addr.sin_family = AF_INET;                     //使用IPv4地址
    serv_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); //具体的IP地址
    serv_addr.sin_port = htons(1234);                   //端口
    bind(serv_sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr));
    //进入监听状态，等待用户发起请求
    while (1)
    {
        listen(serv_sock, 5);
        
        //接收客户端请求
        struct sockaddr_in clnt_addr;
        socklen_t clnt_addr_size = sizeof(clnt_addr);
        int clnt_sock = accept(serv_sock, (struct sockaddr *)&clnt_addr, &clnt_addr_size);
        if (*flag)
        {
            cout << "listen..." << endl;
            //向客户端发送数据
            char str[50];
            recv(clnt_sock, str,49, 0);
            // cout << "get:" << str << endl;
            const char *delim = ",";
            char *re;
            re = strtok(str, delim);
            while (re != NULL)
            {
                // cout << re << endl;
                p->push_back(strtod(re, NULL));
                re = strtok(NULL, delim);
            }
            
        }
        else
        {
            cout << "wait for flag ..." << endl;
            continue;
        }
    }
}
//socket获取数据并存入vector中
void get_socket_data(vector<double> *p,vector<double> &q)
{
    while (1)
    {
        if (p->size() == 3)
        {
            // print_(p);
            q=*p;
            p->clear();
            break;
        }
        else
        {
            continue;
        }
    }
}
int main()
{
    int flag = 0;//socket状态标志符 1为开启监听
    vector<double> temp;
    vector<double> data;
    thread socket_thread(socket_listen, &temp, &flag);
    socket_thread.detach();
    sleep(3);//前三秒flag = 0 终端打印 wait for flag
    flag = 1;
    while(1)
    {
        get_socket_data(&temp,data);
        print_(&data);
    }
    return 0;
}

CMakeLists.txt

cmake_minimum_required(VERSION 3.4.1)
project(socket)
set(CMAKE_CXX_FLAGS "${CAMKE_CXX_FLAGS} -std=c++11 -pthread")
add_executable(listen listen.cpp)