UDP实现聊天直播间 chatroom

这篇具有很好参考价值的文章主要介绍了UDP实现聊天直播间 chatroom。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1.memcmp() 函数

int memcmp(const void *s1, const void *s2, size_t n);


memcmp() 函数用于比较两个内存区域前 n 个字节的内容。

它接受三个参数:

•const void *s1:指向第一个内存区域的指针。

•const void *s2:指向第二个内存区域的指针。

•size_t n:要比较的字节数。

返回值: memcmp() 函数返回一个整数值,表示两个内存区域内容的比较结果:

•如果 s1 和 s2 相同,返回0。

•如果 s1 小于 s2(按字典序),返回一个小于0的值。

•如果 s1 大于 s2(按字典序),返回一个大于0的值。

在实际应用中,通常使用 memcmp() 函数来判断两个内存区域的内容是否完全相同。

例如,if (memcmp(&TmpAddr, &ClientIpList[i].addr, sizeof(TmpAddr)) != 0)

上述表达式用于判断 TmpAddr 是否与 ClientIpList[i].addr 的内容相等。如果两者内容完全相同,memcmp() 返回0,否则返回非零值。

2.memset()

void *memset(void *s, int c, size_t n);


memset() 函数用于将一个内存区域的前 n 个字节填充为指定的字符 c。

它接受三个参数:

•void *s:指向要填充的内存区域的起始位置的指针。

•int c:要填充的字符,可以是整数值或字符值

•size_t n:要填充的字节数。

将sendmsg清零    : memset(&sendmsg, 0, sizeof(sendmsg));

在实际应用中,通常使用 memset() 函数来初始化一个结构体、数组或其他内存区域为全0(或全特定值)。例如,上述表达式用于将 sendmsg 变量的所有字节清零。

优点:

•确保已知的初始状态:清零后,sendmsg 变量的所有字段(如果为结构体)或元素(如果为数组)都将具有已知的初始值(0)。这对于后续的使用和调试非常有益,避免了未初始化的内存带来的不确定性。

•避免内存泄漏:如果 sendmsg 包含指针成员,清零可以确保这些指针被设置为 NULL。这样在释放内存时,如果检查指针是否为 NULL,可以有效避免因未初始化指针导致的内存泄漏。

基于UDP实现直播间聊天的功能


需求:
    软件划分为用户客户端和主播服务端两个软件client.c和server.c 

    用户客户端负责:
        1.接收用户的昵称
        2.接收用户输入的信息,能够将信息发送给服务端
        3.接收服务端回复的数据信息,并完成显示
    
    主播服务端负责:
        1.对所有加入直播间的用户的IP地址和端口实现管理(加入、退出)
        2.当有新的客户端加入时,能够向所有客户端提示:"欢迎 XXX 用户进入直播间"
        3.当有客户端退出时,能够向所有客户端提示:"XXX 离开直播间"
        4.能够实现客户端聊天内容的转发,当某个客户端发送聊天信息时,能够将该信息转给除了该用户之外聊天室内所有其余客户端用户

UDP实现聊天直播间 chatroom,udp,网络协议,网络

UDP实现聊天直播间 chatroom,udp,网络协议,网络 UDP实现聊天直播间 chatroom,udp,网络协议,网络

代码实现

/*************************************************************************
	> File Name: head.h
	> Author: yas
	> Mail: rage_yas@hotmail.com
	> Created Time: 2024年03月14日 星期四 22时52分09秒
 ************************************************************************/

#ifndef _HEAD_H
#define _HEAD_H

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <dirent.h>
#include <time.h>
#include <pwd.h>
#include <grp.h>
#include <pthread.h>
#include <semaphore.h>
#include <signal.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <sys/sem.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/ip.h>
#include <netinet/in.h>

struct msgbuf{
    int type;               //消息类型
    char name[32];           //昵称
    char text[512];           //消息内容
};


struct address
{
    struct sockaddr_in addr;           //IP地址及端口号
    int mark;                              //是否被使用的标志位
};

#define MSG_TYPE_START   100                  //开始聊天消息类型
#define MSG_TYPE_END     200                    //退出聊天消息类型

#define MSG_TYPE_CHAT    300                   //正在聊天

#define RECV_ADDR         "192.168.1.151"             //接收端地址
#define RECV_PORT       50000                       //接收端端口

#endif

 

/*************************************************************************
	> File Name: client.c
	> Author: yas
	> Mail: rage_yas@hotmail.com
	> Created Time: 2024年03月15日 星期五 19时45分02秒
 ************************************************************************/
/**
 *
 *客户端
 *
 *
 *
 *
 * */
#include"head.h"

char name[32] = {0};
int sockfd = 0;
struct sockaddr_in recvaddr;      //ip 地址及端口号
pthread_t tid_send;          //发送线程
pthread_t tid_recv;             //接收线程

void *sendfun(void *arg)
{
    struct msgbuf sendmsg;
    ssize_t nsize =0;
    
    while(1)
    {
        memset(&sendmsg,0,sizeof(sendmsg));
        sendmsg.type = MSG_TYPE_CHAT;    //让状态变为 聊天模式
        sprintf(sendmsg.name,"%s",name);
        gets(sendmsg.text);

        if(!strcmp(sendmsg.text,".quit"))
        {
            sendmsg.type = MSG_TYPE_END;
        }

        nsize = sendto(sockfd,&sendmsg,sizeof(sendmsg),0,(struct sockaddr*)&recvaddr,sizeof(recvaddr));
        if(-1 == nsize)
        {
            perror("fail to sendto");
            return NULL;
        }

        if(sendmsg.type == MSG_TYPE_END)
        {
            break;
        }
    }

    pthread_cancel(tid_recv);

    return NULL;
}

void *recvfun(void *arg)
{
    struct msgbuf recvmsg;
    ssize_t nsize = 0;
    while(1)
    {
        memset(&recvmsg,0,sizeof(recvmsg));
        nsize = recvfrom(sockfd,&recvmsg,sizeof(recvmsg),0,NULL,NULL);
        if(-1 == nsize)
        {
            perror("fail to recvfrom");
            return NULL;
        }

        if(recvmsg.type == MSG_TYPE_CHAT)
        {
            printf("%s(%s:%d)>%s\n",recvmsg.name,RECV_ADDR,RECV_PORT,recvmsg.text);

        }
        else if(recvmsg.type == MSG_TYPE_END)
        {
            break;
        }
    }
    pthread_cancel(tid_send);
    return NULL;
}


int main(void)
{
    struct msgbuf sendmsg;
    ssize_t nsize = 0;

    recvaddr.sin_family =AF_INET;
    recvaddr.sin_port = htons(RECV_PORT);
    recvaddr.sin_addr.s_addr = inet_addr(RECV_ADDR);

    printf("Enter ID:\n");
    gets(name);

    sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("fail to socket");
        return -1;
    }

    memset(&sendmsg,0,sizeof(sendmsg));
    sendmsg.type = MSG_TYPE_START;
    sprintf(sendmsg.name,"%s",name);
    nsize = sendto(sockfd,&sendmsg,sizeof(sendmsg),0,(struct sockaddr *)&recvaddr,sizeof(recvaddr));
    if(-1 == nsize)
    {
        perror("fail to sendto");
        return -1;
    }

    pthread_create(&tid_send,NULL,sendfun,NULL);//发送消息和接收消息双线程执行 实现全双工通信
    pthread_create(&tid_recv,NULL,recvfun,NULL);

    pthread_join(tid_send,NULL);
    pthread_join(tid_recv,NULL);

    close(sockfd);

    return 0;
}
/*************************************************************************
	> File Name: server.c
	> Author: yas
	> Mail: rage_yas@hotmail.com
	> Created Time: 2024年04月01日 星期一 02时34分55秒
 ************************************************************************/
/***
 *
 *服务端
 *
 *
 */
#include"head.h"

struct address ClientlpList[100]; //最大的用户数为100

int AddClientlp(struct sockaddr_in TmpAddr) //增加用户列表信息
{
    int i = 0;
    for(i = 0;i < 100;i++)
    {
        if(0 == ClientlpList[i].mark)
        {
            ClientlpList[i].addr = TmpAddr;  //将此时客户端IP添加到直播间的用户列表中
            ClientlpList[i].mark = 1;  // 将这个位置的标志为置为1 表示已经被占用
            break;
        }
    }
    return 0;
}

int DelClientlp(struct sockaddr_in TmpAddr) //删除用户列表信息
{
    int i = 0;
    for(i = 0;i < 100;i++)
    {
        if(0 == memcmp(&TmpAddr,&ClientlpList[i].addr,sizeof(TmpAddr)))//比较传入的待删除地址 和数组中的地址  如果相同  则把标志位置为0 说明这个位置被清空了
        {
            ClientlpList[i].mark = 0;
            break;
        }   
    }
    return 0;
}

int BoardcastClientlp(int sockfd,struct sockaddr_in TmpAddr,struct msgbuf TmpMes)
{
    int i = 0;
    ssize_t nsize = 0;

    for(i = 0;i < 100;i++)
    {
        if(0 == ClientlpList[i].mark)
        {
            continue;
        }
        if(memcmp(&TmpAddr,&ClientlpList[i].addr,sizeof(TmpAddr))!= 0)
        {
            nsize = sendto(sockfd,&TmpMes,sizeof(TmpMes),0,(struct sockaddr*)&ClientlpList[i].addr,sizeof(ClientlpList[i].addr));
            if(-1 == nsize)
            {
                perror("fail to sendto");
                continue;
            }
        }
    }
    return 0;
}


int main(void)
{
    int sockfd = 0;
    int ret = 0;
    ssize_t nsize = 0;
    struct msgbuf recvmes;
    struct sockaddr_in recvaddr;
    struct sockaddr_in sendaddr;
    socklen_t addrlen = sizeof(sendaddr);

    recvaddr.sin_family = AF_INET;
    recvaddr.sin_port = htons(RECV_PORT);
    recvaddr.sin_addr.s_addr = INADDR_ANY; //接收端可以 绑定自己的ip地址

    sockfd = socket(AF_INET,SOCK_DGRAM,0);
    if(-1 == sockfd)
    {
        perror("fail to socket");
        return -1;
    }
    
    ret = bind(sockfd,(struct sockaddr*)&recvaddr,sizeof(recvaddr));
    if(-1 == ret)
    {
        perror("fail to bind");
        return -1;
    }

    while(1)
    {
        memset(&recvmes,0,sizeof(recvmes));
        nsize = recvfrom(sockfd,&recvmes,sizeof(recvmes),0,(struct sockaddr*)&sendaddr,&addrlen);
        if(-1 == nsize)
        {
            perror("fail to recvfrom");
            return -1;
        }
        if(recvmes.type == MSG_TYPE_START)
        {
            AddClientlp(sendaddr);
            recvmes.type = MSG_TYPE_CHAT;
            sprintf(recvmes.text,"欢迎%s进入直播间",recvmes.name);  
        }
        else if(recvmes.type == MSG_TYPE_END)
        {
            DelClientlp(sendaddr);
            recvmes.type = MSG_TYPE_CHAT;
            sprintf(recvmes.text,"%s离开直播间",recvmes.name);
        }

        if(recvmes.type == MSG_TYPE_CHAT)
        {
            BoardcastClientlp(sockfd,sendaddr,recvmes);
        }
    }
    return 0;
}

实现效果

UDP实现聊天直播间 chatroom,udp,网络协议,网络文章来源地址https://www.toymoban.com/news/detail-847155.html

到了这里,关于UDP实现聊天直播间 chatroom的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 抖音手机实景无人直播间怎么搭建?

    手机无人直播 已成为用户直播和商家直播带货的一项热门技术趋势,为消费者提供了全新的观看体验。无人直播,顾名思义,即通过无人直播软件或数字人来进行无人直播。这一技术的广泛应用,不仅为短视频渠道带来了更丰富的玩法,也为各种领域的商户提供了有效的带货

    2024年02月06日
    浏览(47)
  • python虚拟数字人直播间带货

    本开源项目名为“数字人控制器”。意为,本项目可以充当时下流行的虚拟人、虚拟主播、数字人,等仿人形数字形象的内核部分。 ​ 使用UE、C4D、DAZ、LIVE2D等三维引擎软件开发的数字形象可以与本“数字人控制器”对接,从而实现虚拟主播、数字导游、数字助手等。我们提

    2024年02月04日
    浏览(32)
  • 抖音直播间弹幕rpc学习

    目标url 随便找个直播间即可。 https://live.douyin.com/198986091107 接口分析 首先并没有在xhr下找到对应的接口 因为采用了websocket来传输信息。切换到ws即可看到 消息下,可以看到16进制的数据在源源不断地增加。 那么我们只要找到反序列化后的数据,再发送到本地的socket服务,就

    2023年04月22日
    浏览(75)
  • 销量破亿,董洁直播间凭何出圈?

    近期,“没有五位数走不出”的董洁直播间火了…… 纵观这几年各大平台直播带货,火已不是什么新鲜事,而为何董洁的直播能火上热搜呢? 本期,千瓜将解析董洁直播,同品牌方聊聊小红书直播的那些事儿。 董洁「种草式」直播 开启小红书直播新生态 据小红书官方数据

    2024年02月06日
    浏览(42)
  • 在抖音直播间,项目被资本割韭菜

    VC们也开始直播了。 想象中高高在上、西装革履的投资人对着镜头吆喝项目直投与连麦加群,颇有些魔幻现实的影子。但如果有心,在抖音上,时常可以发现诸如创投机构、XX投资人的直播,其中不乏已然有知名度的部分主体,这一趋势,在今年正在迅速蔓延。 论及缘由,在

    2024年02月16日
    浏览(44)
  • 抖音直播VR全景3D立体元宇宙直播间搭建教程软件详细玩法教程

    标题:抖音直播VR全景3D立体元宇宙直播间搭建教程:详细玩法指南 简介: 本文将为您详细介绍抖音直播VR全景3D立体元宇宙直播间的搭建教程,并提供详细的玩法指南。通过了解的使用和相关软件的操作,帮助您在抖音直播平台上打造独特的虚拟现实直播体验。 第一

    2024年01月20日
    浏览(143)
  • 直播间讨论区需要WebSocket,简单了解下

    由于  http  存在一个明显的弊端(消息只能有客户端推送到服务器端,而服务器端不能主动推送到客户端),导致如果服务器如果有连续的变化,这时只能使用轮询,而轮询效率过低,并不适合。于是  WebSocket 被发明出来。 WebSocket技术在直播间讨论区中通常被使用。WebSoc

    2024年02月06日
    浏览(46)
  • Websocket获取B站直播间弹幕教程 — 哔哩哔哩直播开放平台

    进入 哔哩哔哩直播开放平台:https://open-live.bilibili.com/ 注册申请个人开发者认证,获得access_key_id 和 access_key_secred 进入bilibili创作者服务中心 - 创建项目 - 获得项目ID( app_id ) 官方文档:https://open-live.bilibili.com/document/eba8e2e1-847d-e908-2e5c-7a1ec7d9266f 注意:Post参数需要签名加密,

    2024年02月08日
    浏览(44)
  • AI虚拟数字人直播带货软件 AI数字人直播间怎么搭建 搭建教程分享

    随着近年来移动互联网和直播行业的迅猛发展,越来越多的企业开始将直播带货作为新的营销渠道。AI虚拟数字人直播带货软件则是在这样的背景下应运而生的一种全新的直播带货形式。 AI虚拟数字人直播带货软件通过虚拟主播、智能语音互动、个性化推荐、仿真化体验、实

    2024年02月08日
    浏览(70)
  • 直播必备抖音智能语音互动播报机器人 一键欢迎新人加入直播间软件教程

    标题:抖音智能语音互动播报机器人——直播必备,欢迎新人加入直播间 随着直播行业的发展,越来越多的主播开始利用抖音平台进行直播,而吸引观众参与直播成为了一项重要的任务。为了提高直播互动性和观众黏性,抖音智能语音互动播报机器人应运而生。本文将为您介

    2024年02月03日
    浏览(286)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包