14.6 Socket 应用结构体传输

简介: 当在套接字编程中传输结构体时,可以将结构体序列化为字符串(即把结构体的所有成员打包成一个字符串),然后将字符串通过套接字传输到对端,接收方可以将字符串解析为结构体,然后使用其中的成员数据。这种方法通常被称为序列化(Serialization)和反序列化(Deserialization),本章中我们可以采用将一个结构体序列化为一个纯字符串,然后将该字符串通过套接字传输给对端,当对端收到后只需要将字节序强制转换为对等的结构体指针即可实现对该结构的解析。

当在套接字编程中传输结构体时,可以将结构体序列化为字符串(即把结构体的所有成员打包成一个字符串),然后将字符串通过套接字传输到对端,接收方可以将字符串解析为结构体,然后使用其中的成员数据。这种方法通常被称为序列化(Serialization)和反序列化(Deserialization),本章中我们可以采用将一个结构体序列化为一个纯字符串,然后将该字符串通过套接字传输给对端,当对端收到后只需要将字节序强制转换为对等的结构体指针即可实现对该结构的解析。

14.6.1 服务端实现

首先来看服务端的实现流程,笔者定义了message结构体变量,代码中在接收到套接字传输过来的字符串之后,通过(message*)recv_buf的方式将该套接字强制转换为一个结构体指针,并赋值给message* msg指针,此时在服务端则可通过->的方式输出当前结构体内的完整成员参数。

#include <iostream>
#include <winsock2.h>

#pragma comment(lib,"ws2_32.lib")

// 定义一个自定义结构体
typedef struct
{
   
   
  unsigned short uuid;
  char HostName[32];
  char Buffer[32];

  struct
  {
   
   
    char HostAddress[1024];
    char HostPassword[1024];
    char HostPort[1024];
  }HostInfo;

  unsigned short cmd_type;
}message;

int main(int argc, char* argv[])
{
   
   
  WSADATA WSAData;
  SOCKET sock;

  WSAStartup(MAKEWORD(2, 0), &WSAData);
  sock = socket(AF_INET, SOCK_STREAM, 0);
  if (sock == INVALID_SOCKET)
  {
   
   
    std::cout << "创建套接字失败" << std::endl;
  }

  struct sockaddr_in ServerAddr;
  ServerAddr.sin_family = AF_INET;
  ServerAddr.sin_port = htons(9999);
  ServerAddr.sin_addr.s_addr = INADDR_ANY;

  // 绑定套接字
  auto res = bind(sock, (LPSOCKADDR)&ServerAddr, sizeof(ServerAddr));
  if (res == SOCKET_ERROR)
  {
   
   
    std::cout << "绑定失败" << std::endl;
  }

  // 侦听套接字
  res = listen(sock, 10);
  if (res == SOCKET_ERROR)
  {
   
   
    std::cout << "侦听失败" << std::endl;
  }

  SOCKET msgsock;

  // 用于接收结构
  char recv_buf[4096] = {
   
    0 };

  msgsock = accept(sock, (LPSOCKADDR)0, (int*)0);
  if (msgsock != INVALID_SOCKET)
  {
   
   
    recv(msgsock, recv_buf, sizeof(recv_buf), 0);

    // 接收到结构,强制类型转换
    message* msg = (message*)recv_buf;

    std::cout << "ID: " << msg->uuid << " 主机名: " << msg->HostName
      << " 数据包: " << msg->Buffer << " 主机地址: " << msg->HostInfo.HostAddress
      << "主机密码: " << msg->HostInfo.HostPassword << std::endl;
  }

  closesocket(sock);
  WSACleanup();
  return 0;
}

14.6.2 客户端实现

对于客户端来说,在定义好全局message结构体之后直接通过字符串拷贝方法实现对全局结构的填充,当全局结构体被填充后直接使用memcpy(send_buf, &msg, sizeof(message))将该结构体的字节拷贝到send_buf这个缓冲区内,最后调用send()发送这段缓冲区即可实现。

#include <iostream>
#include <winsock2.h>

#pragma comment(lib,"ws2_32.lib")

// 定义一个自定义结构体
typedef struct
{
   
   
  unsigned short uuid;
  char HostName[32];
  char Buffer[32];

  struct
  {
   
   
    char HostAddress[1024];
    char HostPassword[1024];
    char HostPort[1024];
  }HostInfo;

  unsigned short cmd_type;
}message;

// 定义变量
message msg;

int main(int argc, char* argv[])
{
   
   
  WSADATA WSAData;
  SOCKET sock;

  WSAStartup(MAKEWORD(2, 0), &WSAData);
  sock = socket(AF_INET, SOCK_STREAM, 0);
  if (sock == INVALID_SOCKET)
  {
   
   
    std::cout << "创建套接字失败" << std::endl;
  }

  struct sockaddr_in ClientAddr;
  ClientAddr.sin_family = AF_INET;
  ClientAddr.sin_port = htons(9999);
  ClientAddr.sin_addr.s_addr = inet_addr("127.0.0.1");

  // 链接对端
  auto res = connect(sock, (LPSOCKADDR)&ClientAddr, sizeof(ClientAddr));
  if (res == SOCKET_ERROR)
  {
   
   
    std::cout << "链接失败." << std::endl;
  }

  // 首先需要定义一个变量
  char send_buf[4096] = {
   
    0 };

  // 拷贝外部变量
  msg.uuid = 1001;
  strcpy(msg.HostName, "lyshark PC");
  strcpy(msg.Buffer, "hello world");

  // 拷贝内部HostInfo
  strcpy(msg.HostInfo.HostAddress, "192.168.1.1");
  strcpy(msg.HostInfo.HostPassword, "12345678");
  strcpy(msg.HostInfo.HostPort, "8888");

  // 拷贝内部Type
  msg.cmd_type = 1;

  // 发送字节序
  memcpy(send_buf, &msg, sizeof(message));
  send(sock, send_buf, sizeof(send_buf), 0);

  closesocket(sock);
  WSACleanup();
  return 0;
}

运行上述代码片段,读者可看到结构体已被正确的传输给服务端,效果图如下所示;

本文作者: 王瑞
本文链接: https://www.lyshark.com/post/a71d879b.html
版权声明: 本博客所有文章除特别声明外,均采用 BY-NC-SA 许可协议。转载请注明出处!

目录
相关文章
|
2月前
|
Kubernetes 网络协议 Python
Python网络编程:从Socket到Web应用
【4月更文挑战第9天】本文探讨Python在网络编程中的应用,包括Socket编程和Web应用开发。Python的`socket`模块支持TCP/IP客户端和服务器,示例展示了一个echo服务器。此外,Python通过Flask、Django等Web框架简化Web应用开发,支持异步Web编程如Tornado和aiohttp。Python也在微服务架构中占有一席之地,适用于构建轻量级、高效的网络服务。
|
9月前
14.5 Socket 应用组播通信
组播通信是一种基于UDP协议的网络通信方式,它允许发送方将消息同时传递给多个接收方。在组播通信中,发送方和接收方都会加入一个共同的组播组,这个组播组对应一个特定的IP地址,所有加入该组播组的主机都能够接收到发送方发送的消息。组播通信可以有效地减少网络流量和网络负载,因为在传统的点对点通信方式下,每个消息都需要单独传输到每个接收方,而在组播通信中,每个消息只需要传输一次,就可以同时传递给多个接收方。在使用组播模式时,需要在套接字上使用`setsockopt()`函数来设置套接字的`IP_MULTICAST_IF`选项,指定本地主机的出站接口地址,用于发送组播数据包。此外,还可以设置`IP_ADD
116 0
14.5 Socket 应用组播通信
|
28天前
|
Java 数据挖掘 开发者
Java网络编程进阶:Socket通信的高级特性与应用
【6月更文挑战第21天】Java Socket通信是分布式应用的基础,涉及高级特性如多路复用(Selector)和零拷贝,提升效率与响应速度。结合NIO和AIO,适用于高并发场景如游戏服务器和实时数据分析。示例展示了基于NIO的多路复用服务器实现。随着技术发展,WebSockets、HTTP/2、QUIC等新协议正变革网络通信,掌握Socket高级特性为应对未来挑战准备。
|
14天前
|
Java API 开发者
Java中的Socket编程与应用
Java中的Socket编程与应用
|
25天前
|
网络协议
逆向学习网络篇:通过Socket建立连接并传输数据
逆向学习网络篇:通过Socket建立连接并传输数据
17 0
|
28天前
|
Java 测试技术 开发者
Java Socket编程实战案例:打造实时通信应用
【6月更文挑战第21天】Java Socket编程用于构建实时通信应用,如简易聊天系统。阻塞式Socket在读写时会阻塞线程,适合入门级应用。非阻塞式Socket(NIO)更高效,适用于高并发场景,允许线程在无数据时立即返回。通过对比两者,可理解实时通信技术的选择关键。示例代码展示了服务器端和客户端的实现。学习Socket编程能为应对未来挑战打下基础。
|
1月前
|
监控 网络协议 Java
Java Socket编程 - 基于TCP方式的二进制文件传输
Java Socket编程 - 基于TCP方式的二进制文件传输
24 0
|
2月前
|
网络协议 Java 网络安全
【计算机网络】—— Socket通信编程与传输协议分析
【计算机网络】—— Socket通信编程与传输协议分析
95 0
|
2月前
|
网络协议 安全 Python
socket客户端和服务端,文件的传输
socket 实现,客户端和服务端,文件的传输
60 1
|
9月前
|
存储
14.3 Socket 字符串分块传输
首先为什么要实行分块传输字符串,一般而言`Socket`套接字最长发送的字节数为`8192`字节,如果发送的字节超出了此范围则后续部分会被自动截断,此时将字符串进行分块传输将显得格外重要,分块传输的关键在于封装实现一个字符串切割函数,将特定缓冲区内的字串动态切割成一个个小的子块,当切割结束后会得到该数据块的个数,此时通过套接字将个数发送至服务端此时服务端在依次循环接收数据包直到接收完所有数据包之后在组合并显示即可。
42 0
14.3 Socket 字符串分块传输