在C中使用Socket实现多线程异步TCP消息发送

news2024/9/25 11:12:58

目录

  • 基础知识
  • 开始实现
  • 主要函数说明
  • 结束语

在本篇文章中,我们会探讨如何在C语言中使用socket来实现多线程,异步发送TCP消息的系统。虽然C标准库并没有原生支持异步和多线程编程,但是我们可以结合使用POSIX线程(pthread)库和socket来达到目的。
在这里插入图片描述

基础知识

TCP (Transmission Control Protocol) 是一种面向连接的、可靠的、基于字节流的通信协议。

Socket 是一种网络编程接口,它允许应用程序在网络上发送和接收数据。

多线程编程 是一个并发执行多个任务的方法,每个任务运行在一个单独的线程中。

异步消息发送 是一种编程模型,消息发送者不需要等待接收者处理消息,它可以立即返回并继续执行其它任务。

开始实现

首先,我们需要包含必要的头文件。

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <unistd.h>

然后,我们定义一个函数send_message,该函数将在一个新线程中被调用以发送消息。

void* send_message(void* arg)
{
    char* message = (char*)arg;
    int sock;
    struct sockaddr_in server;

    // Create socket
    sock = socket(AF_INET , SOCK_STREAM , 0);
    if (sock == -1)
    {
        perror("Could not create socket");
        return NULL;
    }

    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    server.sin_family = AF_INET;
    server.sin_port = htons(8888);

    // Connect to remote server
    if (connect(sock, (struct sockaddr*)&server, sizeof(server)) < 0)
    {
        perror("Connect failed");
        return NULL;
    }

    // Send some data
    if (send(sock, message, strlen(message), 0) < 0)
    {
        perror("Send failed");
        return NULL;
    }

    close(sock);

    return NULL;
}

send_message函数首先创建一个socket,并连接到远程服务器。然后,它发送一条消息,并关闭socket。

现在,我们可以在main函数中创建多个线程,每个线程发送一条消息。

int main()
{
    // Array of messages to be sent
    char* messages[] = {"Hello", "from", "C"};

    // Create a new thread for each message
    pthread_t threads[sizeof(messages)/sizeof(char*)];
    for (int i = 0; i < sizeof(messages)/sizeof(char*); i++)
    {
       if (pthread_create(&threads[i], NULL, send_message, messages[i]) < 0)
       {
           perror("Could not create thread");
           return 1;
       }
    }

    // Wait for all threads to finish
    for (int i = 0; i < sizeof(threads)/sizeof(pthread_t); i++)
    {
        pthread_join(threads[i], NULL);
    }

    return 0;
}

在这段代码中,我们为每个要发送的消息创建了一个新的线程,并传递send_message函数作为线程函数。然后,我们等待所有的线程完成。

主要函数说明

1. socket函数

socket函数是用来创建一个套接字,并返回这个套接字的文件描述符,它在<sys/socket.h>头文件中定义。其函数原型如下:

int socket(int domain, int type, int protocol);
  • domain:此参数指定使用的协议族(Protocol Family)。常见的协议族有AF_INET(IPv4网络协议)、AF_INET6(IPv6网络协议)等。

  • type:此参数指定服务类型。常见的服务类型有SOCK_STREAM(提供面向连接的稳定数据传输,即TCP协议)、SOCK_DGRAM(提供无连接的不稳定数据传输,即UDP协议)等。

  • protocol:此参数通常设置为0,让系统根据type自动选择合适的协议,例如TCP或UDP。

如果socket函数成功,返回一个新的socket描述符;否则返回-1,并设置errno为错误号。

2. pthread_create函数

pthread_create函数用来创建一个新线程,并让这个新线程执行指定的函数。它在<pthread.h>头文件中定义。其函数原型如下:

int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);
  • thread:这是一个输出参数,用于返回新创建的线程ID。

  • attr:一个指向线程属性结构的指针,用于设置新线程的属性。如果设置为NULL,则使用默认属性。

  • start_routine:一个函数指针,指向新线程要运行的函数。

  • arg:一个指针,指向要传递给start_routine的参数。

如果pthread_create函数成功,返回0;如果失败,则返回一个非0的错误码(注意,这个函数不会设置errno)。新创建的线程从start_routine函数的地址开始运行,一旦start_routine返回,那么这个线程就会自动结束。

结束语

这就是在C中使用socket实现多线程异步发送TCP消息的简单示例。这是一个基础的示例,实际使用时可能需要添加错误处理和异常处理代码。同时,因为C语言没有内置的异步或多线程支持,所以这种方法并不完全异步,但是我们可以通过使用多线程来模拟异步行为。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/890028.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

React2023电商项目实战 - 1.项目搭建

古人学问无遗力&#xff0c;少壮工夫老始成。 纸上得来终觉浅&#xff0c;绝知此事要躬行。 —— 陆游《《冬夜读书示子聿》》 系列文章目录 项目搭建App登录及网关App文章自媒体平台&#xff08;博主后台&#xff09;内容审核(自动) 文章目录 系列文章目录一、项目介绍1.页面…

二维码网络钓鱼攻击泛滥!美国著名能源企业成主要攻击目标

近日&#xff0c;Cofense发现了一次专门针对美国能源公司的网络钓鱼攻击活动&#xff0c;攻击者利用二维码将恶意电子邮件塞进收件箱并绕过安全系统。 Cofense 方面表示&#xff0c;这是首次发现网络钓鱼行为者如此大规模的使用二维码进行钓鱼攻击&#xff0c;这表明他们可能正…

云计算——ACA学习 云计算核心技术

作者简介&#xff1a;一名云计算网络运维人员、每天分享网络与运维的技术与干货。 座右铭&#xff1a;低头赶路&#xff0c;敬事如仪 个人主页&#xff1a;网络豆的主页​​​​​ 写在前面 本系列将会持续更新云计算阿里云ACA的学习&#xff0c;了解云计算及网络安全相关…

使用 AI 将绘画和照片转换为动画

推荐&#xff1a;使用 NSDT场景编辑器 助你快速搭建可二次编辑器的3D应用场景 华盛顿大学和Facebook的研究人员最近发表了一篇论文&#xff0c;展示了一种基于深度学习的系统&#xff0c;可以将静止图像和绘画转换为动画。称为照片唤醒的算法使用卷积神经网络从单个静止图像以 …

性能分析之MySQL慢查询日志分析(慢查询日志)

一、背景 MySQL的慢查询日志是MySQL提供的一种日志记录,他用来记录在MySQL中响应的时间超过阈值的语句,具体指运行时间超过long_query_time(默认是10秒)值的SQL,会被记录到慢查询日志中。 慢查询日志一般用于性能分析时开启,收集慢SQL然后通过explain进行全面分析,一…

【STM32】FreeRTOS事件组学习

事件组&#xff08;Event Group&#xff09; 一个任务执行之前需要经过多个条件进行判断&#xff0c;当条件全部满足或多个条件中的某一个条件满足才执行。 实验&#xff1a;创建两个任务&#xff0c;一个事件组&#xff0c;当按键一二三都按过一遍才打印。 实现&#xff1a…

【论文阅读】SHADEWATCHER:使用系统审计记录的推荐引导网络威胁分析(SP-2022)

SHADEWATCHER: Recommendation-guided CyberThreat Analysis using System Audit Records S&P-2022 新加坡国立大学、中国科学技术大学 Zengy J, Wang X, Liu J, et al. Shadewatcher: Recommendation-guided cyber threat analysis using system audit records[C]//2022 I…

python3 0学习笔记之基本知识

0基础学习笔记之基础知识 &#x1f4da; 基础内容1. 条件语句 if - elif - else2. 错误铺捉try - except(一种保险策略&#xff09;3. 四种开发模式4. 函数&#xff1a;def用来定义函数的5. 最大值最小值函数&#xff0c;max &#xff0c;min6. is 严格的相等&#xff0c;is no…

【Linux命令详解 | gzip命令】 gzip命令用于压缩文件,可以显著减小文件大小

文章标题 简介一&#xff0c;参数列表二&#xff0c;使用介绍1. 基本压缩和解压2. 压缩目录3. 查看压缩文件内容4. 测试压缩文件的完整性5. 强制压缩6. 压缩级别7. 与其他命令结合使用8. 压缩多个文件9. 自动删除原文件 总结 简介 在Linux中&#xff0c;gzip命令是一款强大的文…

使用grep做文本的过滤

常与 管道符&#xff08;|&#xff09;结合在一起使用 管道符 piping&#xff1a;用于前一个命令的输出当作后一个命令的输入。常用于连接多个命令 ┌──(root㉿kali)-[~/work/exam] └─# ps aux | grep apache2 root 41946 0.0 0.2 6568 2304 pts/1 S 17:26…

怎么对mp4视频进行压缩?分享了几个不错的方法

怎么对mp4视频进行压缩&#xff1f;这个问题非常重要。确实&#xff0c;MP4视频文件由于包含音频和图像&#xff0c;通常会占据较大的存储空间。如果我们在手机或电脑上保存过多的MP4视频文件&#xff0c;随着时间的积累&#xff0c;会导致存储容量不足的问题。另外&#xff0c…

用cpolar生成的公网地址,对位于本地的Cloudreve网盘进行访问

文章目录 1、前言2、本地网站搭建2.1 环境使用2.2 支持组件选择2.3 网页安装2.4 测试和使用2.5 问题解决 3、本地网页发布3.1 cpolar云端设置3.2 cpolar本地设置 4、公网访问测试5、结语 1、前言 自云存储概念兴起已经有段时间了&#xff0c;各互联网大厂也纷纷加入战局&#…

段错误核心转储

在linux下运行可执行文件的时候出现了以下错误&#xff1a; error:segmentation fault core dumped解决方法&#xff1a; #查看core文件大小判断是否可写 $ ulimit -a real-time non-blocking time (microseconds, -R) unlimited core file size (blocks, -c) …

教学实训平台,新增批量设置作业小组|ModelWhale 版本更新

始惊三伏尽&#xff0c;又遇立秋时。季节更迭、岁月匆匆&#xff0c;ModelWhale 又迎来了新一轮的版本更新。 本次更新中&#xff0c;ModelWhale 主要进行了以下功能迭代&#xff1a; • 新增 批量设置作业小组&#xff08;团队版✓ &#xff09; • 新增 断网时支持连接数据…

opencv-python视频实时识别二维码

代码如下&#xff1a; import numpy as np import cv2 as cv import globcap cv.VideoCapture(0) if not cap.isOpened():print("Cannot open camera")exit() while True:# Capture frame-by-frameret, frame cap.read()# if frame is read correctly ret is True…

3D产品配置器简介【电商】

3D 配置器对整个电子商务业务有良好影响&#xff0c;本文将介绍如何实现&#xff0c;并且涵盖了 3D 产品配置器的重要方面以及一些最常见的问题。 在电子商务营销中采用 3D 技术已显示出更高的客户参与度。 这进一步表明消费者喜欢访问可以为他们提供个性化购物体验的在线商店…

AI智能语音机器人的基本业务流程

先画个图&#xff0c;了解下AI语音机器人的基本业务流程。 上图是一个AI语音机器人的业务流程&#xff0c;简单来说就是首先要配置话术&#xff0c;就是告诉机器人在遇到问题该怎么回答&#xff0c;这个不同公司不同行业的差别比较大&#xff0c;所以一般每个客户都会配置其个性…

低代码如何提效开发者?

低代码如何提效开发者&#xff1f; 一、低代码的出现 二、低代码解决方案的主要特点 三、优秀强大的软件开发工具 四、你所在企业为什么要关心低代码开发&#xff1f; 一、低代码的出现 无论你是一个初级的开发者还是一位经验丰富的专家&#xff0c;低代码都将为你提供了一个突…

华为OD机试 - BOSS的收入 - 回溯(Java 2023 B卷 100分)

目录 专栏导读一、题目描述二、输入描述三、输出描述四、解题思路五、Java算法源码六、效果展示1、输入2、输出3、说明 华为OD机试 2023B卷题库疯狂收录中&#xff0c;刷题点这里 专栏导读 本专栏收录于《华为OD机试&#xff08;JAVA&#xff09;真题&#xff08;A卷B卷&#…

定向传音?静音广播?这所学校会“法术”!

“老者念念有词&#xff0c;一个与世隔绝的空间便形成了&#xff0c;明明身处闹市&#xff0c;周围的人却听不见空间里声音。”小说里经常出现的场景&#xff0c;如今&#xff0c;现实世界正在实现&#xff01; 广州的一所学校里&#xff0c;活力四射的学生方队&#xff0c;正在…