C++基于socket UDP网络编程实现简单聊天室功能

更新时间：2021年07月01日 11:00:37 作者：csdn_WHB

这篇文章主要为大家详细介绍了C++基于socket UDP网络编程实现简单聊天室功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

本文实例为大家分享了C++基于socket UDP实现简单聊天室功能的具体代码，供大家参考，具体内容如下

0.通信步骤流程图

（左：服务器；右：客户端；）

1.服务器代码

1.1服务器类头文件(CServer_UDP.h)

#pragma once
 
#include <winsock2.h>
 
class CServer_UDP
{
public:
 CServer_UDP();
 void SendMsg(const char sendBuf[]);
 void RecMsg();
 ~CServer_UDP();
 
private:
 SOCKET m_sServer;
 struct sockaddr_in m_SocAddrClient;  //建立连接时，用于保存客户端信息
 bool m_terminal;
};

1.2服务器类源文件(CServer_UDP.cpp)

#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include "CServer_UDP.h"
 
#include <iostream>
 
#pragma comment(lib, "ws2_32.lib")
 
 
CServer_UDP::CServer_UDP():m_terminal(false)
{
 //必须进行如下初始化， 否则socket()会返回10093错误
 //初始化WSA  
 WORD sockVersion = MAKEWORD(2, 2);
 WSADATA wsaData;
 if (WSAStartup(sockVersion, &wsaData) != 0) //通过一个进程初始化ws2_32.dll
 {
  std::cout << "Initialize WSA failed" << std::endl;
  return;
 }
 //初始化UDDP套接字
 m_sServer = socket(AF_INET, SOCK_DGRAM, 0);
 
 struct sockaddr_in m_SocAddrserver;
 m_SocAddrserver.sin_addr.S_un.S_addr = 0;//htonl(INADDR_ANY);
 m_SocAddrserver.sin_family = AF_INET;
 m_SocAddrserver.sin_port = htons(8090);
 
 int ret = bind(m_sServer, (sockaddr*)&m_SocAddrserver, sizeof(m_SocAddrserver));
 if (ret == -1)
 {
  std::cout << "bind failed!" << std::endl;
  WSACleanup();
 }
 else
 {
  //此处必须赋初值，不然会导致服务器端无法正常发送
  int len_Client = sizeof(sockaddr);  
  char recBuf[1025];
  int len = recvfrom(m_sServer, recBuf, 1024, 0, (sockaddr*)&m_SocAddrClient, &len_Client);
  if (len > 0)
  {
   recBuf[len] = '\0';
   std::cout << "Client say:" << recBuf << std::endl;
  }
 }
 
 
}
void CServer_UDP::SendMsg(const char sendBuf[])
{
 int ret = sendto(m_sServer, sendBuf, strlen(sendBuf), 0, (sockaddr*)&m_SocAddrClient, sizeof(m_SocAddrClient));
 if (ret == -1)
 {
  std::cout << "send failed" << std::endl;
  std::cout << GetLastError()<< std::endl;
 }
}
void CServer_UDP::RecMsg()
{
 char recBuf[1025];
 while (!m_terminal)
 {
  //std::cout << "Begin rec...(server)" << std::endl;
  int len = recvfrom(m_sServer, recBuf, 1024, 0, 0, 0);
  if (len > 0)
  {
   recBuf[len] = '\0';
   std::cout << "Client say:" << recBuf << std::endl;
  }
 }
 
}
CServer_UDP::~CServer_UDP()
{
 closesocket(m_sServer);
 WSACleanup();
 
}

1.3服务器主函数

#include <iostream>
#include <thread>
#include <string>
 
#include "CServer_UDP.h"
 
using namespace std;
 
int main()
{
 CServer_UDP server_UDP;
 
 thread recProc(&CServer_UDP::RecMsg, &server_UDP);
 
 while (1)
 {
  //cout << "Pleaes input content:" << endl;
  string content;
  cin >> content;
  server_UDP.SendMsg(content.c_str());
 }
 
 recProc.join();
 cout << "I love china!" << endl;
 system("pause");
 return 0;
}

2.客户端代码

2.1客户端类头文件(CClient.h)

#pragma once
 
#include <winsock2.h>
 
class CClient
{
public:
 CClient();
 void RecMsg();
 void SendMsg(const char sendBuf[]);
 ~CClient();
private:
 SOCKET m_sockClient;
 sockaddr_in m_TargetServer;
};

2.2客户端类源文件(CClient.cpp)

#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include "CClient.h"
 
#include <iostream>
 
#pragma comment(lib, "ws2_32.lib")
 
CClient::CClient()
{
 //必须进行如下初始化， 否则socket()会返回10093错误
 //初始化WSA  
 WORD sockVersion = MAKEWORD(2, 2);
 WSADATA wsaData;
 if (WSAStartup(sockVersion, &wsaData) != 0) //通过一个进程初始化ws2_32.dll
 {
  std::cout << "Initialize WSA failed" << std::endl;
  return;
 }
 
 m_sockClient = socket(AF_INET, SOCK_DGRAM, 0);
 
 m_TargetServer.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
 m_TargetServer.sin_family = AF_INET;
 m_TargetServer.sin_port = htons(8090);
 
 if (m_sockClient == -1)
 {
  std::cout << "Create socket failed!" << std::endl;
  WSACleanup();
 }
 else
 {
  //发送信息与服务器建立连接(必须加)
  sendto(m_sockClient, "hello server", strlen("hello server"), 0, (sockaddr*)&m_TargetServer, sizeof(m_TargetServer));
 }
}
 
void CClient::SendMsg(const char sendBuf[])
{
 sendto(m_sockClient, sendBuf, strlen(sendBuf), 0, (sockaddr*)&m_TargetServer, sizeof(m_TargetServer));
}
void CClient::RecMsg()
{
 char recBuf[1025];
 
 while (1)
 {
  //std::cout << "Begin rec...(client)" << std::endl;
  int len = recvfrom(m_sockClient, recBuf, 1024, 0, 0, 0);
  if (len > 0)
  {
   recBuf[len] = '\0';
   std::cout << "Server say: " << recBuf << std::endl;
  }
 }
 
}
CClient::~CClient()
{
 closesocket(m_sockClient);
 WSACleanup();
}

2.3客户端主函数

#include <iostream>
#include <string>
#include <thread>
 
#include "CClient.h"
 
using namespace std;
 
int main()
{
 CClient client_UDP;
 
 thread RecProc(&CClient::RecMsg, &client_UDP);
 
 while (1)
 {
  //cout << "Please input content:" << endl;
  string content;
  cin >> content;
 
  client_UDP.SendMsg(content.c_str());
 }
 
 
 RecProc.join();
 cout << "I love china!" << endl;
 system("pause");
 return 0;
}

3.效果图(win7+VS2017)

3.1服务端

3.2客户端

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

C++实现假装蓝屏整蛊小程序
因为工作的需要，有时候我们离开时并不想让别人看到我们电脑的内容，所以本文为大家分享了一个基于C++实现的假装蓝屏的小程序，需要的可以参考下
2023-06-06
详解C++11中的线程库
线程是操作系统中的一个概念，线程对象可以关联一个线程，用来控制线程以及获取线程的状态，这篇文章主要介绍了C++11中的线程库的相关知识,需要的朋友可以参考下
2022-01-01
C语言实现财务管理系统
这篇文章主要为大家详细介绍了C语言实现财务管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-11-11
C语言详细讲解#error与#line如何使用
这篇文章主要介绍了C语言中#error与#line如何使用，#error与#line虽然在语言里面用的比较少，但是还是有必要了解一下
2022-04-04
Qt 自定义属性Q_PROPERTY不显示float类型的解决
这篇文章主要介绍了Qt 自定义属性Q_PROPERTY不显示float类型的问题及解决，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-11-11
基于C语言实现三子棋游戏
这篇文章主要为大家详细介绍了基于C语言实现三子棋游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-08-08
c语言基于stdarg.h的可变参数函数的用法
本篇文章主要介绍了c语言基于stdarg.h的可变参数函数的用法，详细的介绍了可变参数函数的详细用法和源码实例，有兴趣的可以了解一下
2017-07-07
C++ 对多线程/并发的支持(上)
这篇文章主要介绍的是C++ 对多线程/并发的支持，并发，即同时执行多个任务，常用来提高吞吐量或者改善响应性，下面我们就来看文章详细介绍C++ 对多线程并发的支持相关资料的内容吧
2021-10-10
C语言中动态内存管理图文详解
在编写程序时,通常并不知道需要处理的数据量,或者难以评估所需处理数据量的变动程度,下面这篇文章主要给大家介绍了关于C语言中动态内存管理的相关资料,需要的朋友可以参考下
2022-06-06
C语言实现中缀表达式转换为后缀表达式
这篇文章主要为大家详细介绍了C语言实现中缀表达式转换为后缀表达式，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-04-04