Linux网络-Socket套接字_Windows与Linux端双平台基于Udp传输协议进行多线程跨平台的服务器与客户端网络通信的简易聊天室实现

文章目录

  • 一、Socket套接字
  • 二、socket 常见API
    • 1. int socket(int domain, int type, int protocol);
    • 2. int bind(int socket, const struct sockaddr *address, socklen_t address_len);
      • struct sockaddr
    • 3. ssize_t recvfrom(int socket, void *restrict buffer, size_t length, int flags, struct sockaddr *restrict address,socklen_t *restrict address_len);
    • 4. ssize_t sendto(int socket, const void *message, size_t length, int flags, const struct sockaddr *dest_addr,socklen_t dest_len);
    • 5. uint16_t htons(uint16_t hostshort);
      • 网络字节序
    • 6. in_addr_t inet_addr(const char *cp);
  • 三、Server端
    • 1.初始化Socket套接字
    • 2.发送和接收
    • Server端全代码
      • const std::string default_ip = "0.0.0.0";
  • Client端
  • Windows Client端
  • 简易聊天室运行图

一、Socket套接字

在互联网中，我们在网络层采用 IP + 端口号 的方式即可在全网中找到唯一进程，IP标识唯一主机，端口号标识该主机端口号绑定的进程。

这就是Socket套接字。

二、socket 常见API

1. int socket(int domain, int type, int protocol);

创建 socket 文件描述符 (TCP/UDP, 客户端 + 服务器)

参数 int domin ：指定要在其中创建套接字的通信域。这里我们使用AF_INET采用IPV4通信域。

参数 int type ： 指定要创建的套接字类型。 Udp协议是采用面向数据流，所以是用SOCK_DGRAM。

参数 int protocol ：指定与套接字一起使用的特定协议。

返回值： 如果成功则返回创建的socket 文件描述符， 失败则返回-1.

代码示例

		int socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == -1){exit(1);}

2. int bind(int socket, const struct sockaddr *address, socklen_t address_len);

绑定端口号 (TCP/UDP, 服务器)
参数 int socket 就是使用socket接口函数所创建的那个socket文件描述符。

struct sockaddr

在这里插入图片描述
由于底层有不同的网络协议，所以它们的地址格式并不相同，所以通常使用struct sockaddr* 作为参数，然后根据前16位地址类型来确定协议内容。

参数 socklen_t address_len， 结构体sockaddr的长度。
typedef unsigned int socklen_t

返回值： 如果绑定成功则返回0， 失败则返回-1.

代码示例

		int socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == -1){exit(1);}struct sockaddr_in Server;bzero(&Server, 0);Server.sin_family = AF_INET;Server.sin_addr.s_addr = inet_addr(_ip.c_str()); //？Server.sin_port = htons(_port); //？int n = bind( socket_fd, (const struct sockaddr *)&Server, sizeof(Server));if (n != 0){exit(2);}

3. ssize_t recvfrom(int socket, void *restrict buffer, size_t length, int flags, struct sockaddr *restrict address,socklen_t *restrict address_len);

参数 int socket 就是使用socket接口函数所创建的那个socket文件描述符。
参数 void *restrict buffer为缓冲区，可以用来存放接收的字节数据。
参数 size_t length 为读取的字节长度。
参数 struct sockaddr *restrict address，输出型参数，用于获取发送方的socketaddr。
参数 socklen_t *restrict address_len，输出型参数，用于获取发送方的sockaddr的长度。

示例代码

		char inbuffer[1024];while (true){struct sockaddr_in client;socklen_t len = sizeof(client); // unsigned intbzero(&client, 0);// 服务器接受数据ssize_t n = recvfrom(_socket_fd, inbuffer, sizeof inbuffer - 1, 0, (sockaddr *)&client, &len);if (n > 0){std::string client_ip = inet_ntoa(client.sin_addr);uint16_t client_port = ntohs(client.sin_port);userCheck(client_ip, client);inbuffer[n] = '\0';if(strcmp(inbuffer,"login\0") == 0) continue;std::string info = func(inbuffer, client_ip, client_port);senMessage(info);}}

4. ssize_t sendto(int socket, const void *message, size_t length, int flags, const struct sockaddr *dest_addr,socklen_t dest_len);

参数与 recvfrom类似。不同的是，这里的const struct sockaddr *dest_addr和socklen_t dest_len 变成了输入型参数。 因为你要发送消息，就需要知道对方的socket信息。

5. uint16_t htons(uint16_t hostshort);

这个函数的作用是什么呢？ 这就涉及到网络字节序

网络字节序

我们已经知道,内存中的多字节数据相对于内存地址有大端和小端之分, 磁盘文件中的多字节数据相对于文件中的偏移地址也有大端小端之分, 网络数据流同样有大端小端之分. 那么如何定义网络数据流的地址呢?

规定网络数据在内存中必须采用大端存储方式！！

如果当前发送主机是小端, 就需要先将数据转成大端; 否则就忽略, 直接发送即可

所以这个函数的作用就是将hostshort转换为网络字节序。

6. in_addr_t inet_addr(const char *cp);

由于我们习惯将IP地址 写成这样的格式xxx.xxx.xxx.xxx（例如192.168.0.1），而在网络层面，我们肯定是采用四字节的int来存储IP，所以有这么一个函数将一个xxx.xxx.xxx.xxx的格式的IP转换为四字节int。

三、Server端

1.初始化Socket套接字

代码如下（示例）：

		// 申请套接字int socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == -1){logMessage(FATAL, "Socket Applied Fault");exit(SOCKET_DENIED);}_socket_fd = socket_fd;logMessage(DEBUG, "Socket Applied Success");// bind套接字struct sockaddr_in Server;bzero(&Server, 0);Server.sin_family = AF_INET;Server.sin_addr.s_addr = inet_addr(_ip.c_str()); // inet_addr可以将ip形式x.x.x.x的字符串转化为大段存储的in_addr_t类型（typedef uint32_t in_addr_t;）Server.sin_port = htons(_port);int n = bind(_socket_fd, (const struct sockaddr *)&Server, sizeof(Server));if (n != 0){logMessage(FATAL, "Bind Fault");exit(BIND_FAULT);}

2.发送和接收

代码如下（示例）：

void userCheck(std::string &client_ip, struct sockaddr_in &user){auto it = _user_map.find(client_ip);// std::cout << "开始检测" << std::endl; if (it == _user_map.end()){//没找到std::cout << "新用户[" << client_ip << "]上线..." << std::endl;}_user_map[client_ip] = user;}void senMessage(const std::string& info){for(auto& user:_user_map ){sendto(_socket_fd, info.c_str(), info.size(), 0, (const struct sockaddr *)&(user.second), sizeof(user.second));}}std::string func(const char *res, const std::string& client_ip, const uint16_t client_port){char buffer [1024];snprintf(buffer, sizeof buffer,"[%s:%d]# %s",client_ip.c_str(),client_port,res);std::string mes = buffer;std::cout << mes << std::endl; return mes;}void run(func_t func){char inbuffer[1024];while (true){struct sockaddr_in client;socklen_t len = sizeof(client); // unsigned intbzero(&client, 0);// 服务器接受数据ssize_t n = recvfrom(_socket_fd, inbuffer, sizeof inbuffer - 1, 0, (sockaddr *)&client, &len);if (n > 0){std::string client_ip = inet_ntoa(client.sin_addr);uint16_t client_port = ntohs(client.sin_port);userCheck(client_ip, client);inbuffer[n] = '\0';if(strcmp(inbuffer,"login\0") == 0) continue;std::string info = func(inbuffer, client_ip, client_port);senMessage(info);}}}

Server端全代码

                  //UdpServer.hpp  
#pragma once
#include <iostream>
#include <string>
#include <sys/socket.h>
#include <cstdlib>
#include <unistd.h>
#include "log.hpp"
#include <netinet/in.h>
#include <string.h>
#include <arpa/inet.h>
#include <functional>
#include <unordered_map>
const std::string default_ip = "0.0.0.0"; //?typedef std::function<std::string(const char*, const std::string &, const uint16_t)> func_t;enum
{SOCKET_DENIED = 1,BIND_FAULT
};class UdpServer
{
public:UdpServer(const std::string &ip = default_ip, const uint16_t port = 8080): _socket_fd(0), _ip(ip), _port(port){}void init(){// 申请套接字int socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == -1){logMessage(FATAL, "Socket Applied Fault");exit(SOCKET_DENIED);}_socket_fd = socket_fd;logMessage(DEBUG, "Socket Applied Success");// bind套接字struct sockaddr_in Server;bzero(&Server, 0);Server.sin_family = AF_INET;Server.sin_addr.s_addr = inet_addr(_ip.c_str()); // inet_addr可以将ip形式x.x.x.x的字符串转化为大段存储的in_addr_t类型（typedef uint32_t in_addr_t;）Server.sin_port = htons(_port);int n = bind(_socket_fd, (const struct sockaddr *)&Server, sizeof(Server));if (n != 0){logMessage(FATAL, "Bind Fault");exit(BIND_FAULT);}}void userCheck(std::string &client_ip, struct sockaddr_in &user){auto it = _user_map.find(client_ip);// std::cout << "开始检测" << std::endl; // std::cout << (*it).first << std::endl; if (it == _user_map.end()){//没找到std::cout << "新用户[" << client_ip << "]上线..." << std::endl;}_user_map[client_ip] = user;}void senMessage(const std::string& info){for(auto& user:_user_map ){sendto(_socket_fd, info.c_str(), info.size(), 0, (const struct sockaddr *)&(user.second), sizeof(user.second));// std::cout << "已发送数据给" << user.first << std::endl; }}void run(func_t func){char inbuffer[1024];while (true){struct sockaddr_in client;socklen_t len = sizeof(client); // unsigned intbzero(&client, 0);// 服务器接受数据ssize_t n = recvfrom(_socket_fd, inbuffer, sizeof inbuffer - 1, 0, (sockaddr *)&client, &len);if (n > 0){std::string client_ip = inet_ntoa(client.sin_addr);uint16_t client_port = ntohs(client.sin_port);// std::cout <<  client_ip << " : " << client_port <<std::endl;userCheck(client_ip, client);inbuffer[n] = '\0';if(strcmp(inbuffer,"login\0") == 0) continue;// std::cout << "Server get message# " << inbuffer << std::endl;std::string info = func(inbuffer, client_ip, client_port);senMessage(info);// sendto(_socket_fd, info.c_str(), info.size(), 0, (const struct sockaddr *)&client, len);// sendto(_socket_fd, inbuffer, sizeof inbuffer, 0, (const struct sockaddr *)&client, len);}}}~UdpServer(){if (_socket_fd == 0){close(_socket_fd);}}private:int _socket_fd;std::string _ip;uint16_t _port;std::unordered_map<std::string, struct sockaddr_in> _user_map;
};

                            //main.cc
#include "Udpserver.hpp"std::string func(const char *res, const std::string& client_ip, const uint16_t client_port)
{//std::cout << "[" << client_ip << " : " << client_port << "] # " << res << std::endl;char buffer [1024];snprintf(buffer, sizeof buffer,"[%s:%d]# %s",client_ip.c_str(),client_port,res);std::string mes = buffer;std::cout << mes << std::endl; return mes;
}int main()
{UdpServer us;us.init();us.run(func);return 0;
}

const std::string default_ip = “0.0.0.0”;

这样的ip格式是什么意思呢？ 绑定这样的默认IP，就可以收到任意IP发来的消息

使用 netstat -ua 可以查看主机所有udp协议套接字。

在这里插入图片描述

Client端

#define terminal "/dev/pts" 
void Usage(std::string proc)
{std::cout << "\n\rUsage: " << proc << " serverip serverport\n"<< std::endl;
}enum
{SOCKET_DENIED = 1,
};struct Thread_Data
{int socket_fd;struct sockaddr_in server;
};void *recv_mes(void *args)
{Thread_Data* data = (Thread_Data*)args;char buffer[1024];bzero(buffer,0);while (true){struct sockaddr_in tmp;socklen_t tmp_len;int n = recvfrom(data->socket_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)&tmp, &tmp_len);if (n > 0){buffer[n] = 0;std::cerr <<  buffer << std::endl;}bzero(buffer,0);}
}void *send_mes(void *args)
{Thread_Data* data = (Thread_Data*)args;std::string message = "login";sendto(data->socket_fd, message.c_str(), message.size(), 0, (const struct sockaddr *)&data->server, sizeof(data->server));while (true){std::cout << "Please Enter Message@ ";std::getline(std::cin, message);sendto(data->socket_fd, message.c_str(), message.size(), 0, (const struct sockaddr *)&data->server, sizeof(data->server));}
}int main(int args, char *argv[])
{if (args != 3){Usage("./UdpClient");}int socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == -1){logMessage(FATAL, "Socket Applied Fault");exit(SOCKET_DENIED);}struct sockaddr_in server;memset(&server, 0, sizeof server);server.sin_family = AF_INET;server.sin_addr.s_addr = inet_addr(argv[1]);server.sin_port = htons(std::atoi(argv[2]));pthread_t recv_thread, send_thread;Thread_Data data;data.server = server;data.socket_fd = socket_fd;pthread_create(&send_thread, nullptr, send_mes, (void *)&data);pthread_create(&recv_thread, nullptr, recv_mes, (void *)&data);pthread_join(recv_thread, nullptr);pthread_join(send_thread, nullptr);return 0;
}

采用了多线程的方式， 这里需要知道，因为socket本就支持同时可读可写，我们可以理解为它就是线程安全的。

Windows Client端

#include<iostream>
#include<string>
#include<WinSock2.h>
#include<Windows.h>
#include<thread>
#include<functional>
#pragma comment(lib, "ws2_32.lib") // 链接库文件
#pragma warning(disable:4996)      //防止VS发出4996号警告const int server_port = 8080;
const std::string server_ip = ""; //提前写好服务器IP//warning : 多线程版本仍有一些小问题  
struct Thread_Data
{SOCKET socket_fd;struct sockaddr_in server;
};void recv_mes(const Thread_Data& data)
{char buffer[1024];while (true){memset(buffer, 0, sizeof(buffer));struct sockaddr_in tmp;int tmp_len = sizeof(tmp);int n = recvfrom(data.socket_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr*)&tmp, &tmp_len);if (n > 0){buffer[n] = 0;std::cout << buffer << std::endl;}//std::cout << n << " errno:" << errno << std::endl;}
}void send_mes(const Thread_Data& data)
{std::string message;std::cout << "Send A Message To Start A Chat ";while (true){std::getline(std::cin, message);sendto(data.socket_fd, message.c_str(), (int)message.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));}
}
int main()
{//初始化网络环境WSADATA wsd;    WSAStartup(MAKEWORD(2, 2), &wsd);system("chcp 65001");SOCKET socket_fd = socket(AF_INET, SOCK_DGRAM, 0);if (socket_fd == SOCKET_ERROR){perror("Socket Error");exit(1);}struct sockaddr_in server;memset(&server, 0, sizeof server);server.sin_family = AF_INET;server.sin_addr.s_addr = inet_addr(server_ip.c_str());server.sin_port = htons(server_port);std::thread threads[2];Thread_Data data;data.server = server;data.socket_fd = socket_fd;sendto(socket_fd, "login", 5, 0, (const struct sockaddr*)&server, sizeof(server));threads[0] = std::thread(recv_mes, std::ref(data));threads[1] = std::thread(send_mes, std::ref(data));threads[0].join();threads[1].join();closesocket(socket_fd);WSACleanup();   //清理网络环境return 0;}

这里的Windows端也是实现了一个多线程的版本，因为是不同的操作系统，在接口上是有一些差别的，不过大部分都差不多。

简易聊天室运行图

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

go defer

go defer

type _defer struct {siz int32started boolopenDefer boolsp uintptrpc uintptrfn *funcval_panic *_paniclink *_defer }runtime._defer 结构体是延迟调用链表上的一个元素&#xff0c;所有的结构体都会通过 link 字段串联成链表。 只…
阅读更多...
【全开源】酒店订单管理系统源码（FastAdmin+ThinkPHP）

【全开源】酒店订单管理系统源码（FastAdmin+ThinkPHP）

一款基于FastAdminThinkPHP开发的旨在为民宿、酒店、宾馆等提供房态、订单、财务、客史等数据化、信息化的智慧管理工具&#xff0c;实现一站式订房管理&#xff0c;帮助酒店、民宿、宾馆提升管理效率&#xff0c;降低管理成本&#xff0c;提升行业竞争力。 打造高效、便捷的酒…
阅读更多...
Generate Anything Anywhere in Any Scene #论文阅读

Generate Anything Anywhere in Any Scene #论文阅读

URL https://arxiv.org/pdf/2306.17154 TD;DR 2023 年 6 月 Wisconsin 的文章。围绕 ip 保持做的扩展任务&#xff0c;核心目标是对指定 ip 可以生成任意大小的&#xff08;指定 ip&#xff09;、任意背景的图片&#xff0c;同时可以通过 bbox 控制物体位置和多物体生成。主…
阅读更多...
SOLIDWORKS教育版代理商应该如何选择？

SOLIDWORKS教育版代理商应该如何选择？

SOLIDWORKS作为目前流行的三维设计软件在工程设计&#xff0c;制造和建筑中有着广泛的应用前景。教育版SOLIDWORKS软件是学生及教育机构学习教学的理想平台。 下面介绍几个挑选SOLIDWORKS教育版代理的关键要素: 1、专业知识与经验&#xff1a;代理商应掌握SOLIDWORKS等软件的丰…
阅读更多...
ResNet残差网络的学习【概念+翻译】

ResNet残差网络的学习【概念+翻译】

基于何明凯前辈论文的学习 1.主要内容&#xff08;背景&#xff09; 1、首先提了一个base&#xff1a;神经网络的深度越深&#xff0c;越难以训练。 2、原因&#xff1a;因为随着神经网络层数的增加&#xff0c;通常会遇到梯度消失或梯度爆炸等问题&#xff0c;这会导致训练变…
阅读更多...
gem5模拟器入门（三）——在配置脚本中添加Cache

gem5模拟器入门（三）——在配置脚本中添加Cache

使用gem5模拟器入门（二）——创建一个简单的配置脚本-CSDN博客配置脚本作为起点，本章将介绍一个更复杂的配置。我们将向系统添加一个缓存层次结构，如下图所示。此外，本章还将介绍如何理解gem5的统计输出，并向您的脚本添加命令行参数。 1.创建Cache对象 我们将使用经典的缓…
阅读更多...
Robot Framework自动化测试基础入门

Robot Framework自动化测试基础入门

1、什么是Robot Framework Robot Framework是一个基于Python的关键字驱动的自动化测试框架。以下是关于Robot Framework的几个特点： 基于关键字驱动: 它允许测试人员使用Python封装关键字，这些关键字可以在非编码环境下被用来构建可执行的测试用例。易于扩展: 作为一个开源工…
阅读更多...
20240528解决飞凌的OK3588-C的核心板的TYPE-C1接口识别问题

20240528解决飞凌的OK3588-C的核心板的TYPE-C1接口识别问题

20240528解决飞凌的OK3588-C的核心板的TYPE-C1接口识别问题 2024/5/28 16:46 缘起&#xff1a; 现阶段碰到的USB相关的问题&#xff1a;&#xff08;LINUX R4版本&#xff09; 1、USB3.0插USB摄像头 lsusb找不到设备 2、刷机口只接了3根线&#xff0c;GND/D/D-&#xff0c;可以…
阅读更多...
2024HBCPC：E Breakfast II

2024HBCPC：E Breakfast II

题目描述 作为一个合格的大学生&#xff0c;你不仅需要学习成绩好&#xff0c;还需要会买包子和鸡蛋。 今天&#xff0c;又轮到你们给你的导师买早饭了&#xff01; 这一次你们一共需要给导师买 n n n 个包子和 m m m 个鸡蛋&#xff08;请注意&#xff0c;这一次可能不再只…
阅读更多...
搭贝财务管理助您轻松掌控财务大局

搭贝财务管理助您轻松掌控财务大局

在当今竞争激烈的商业环境中&#xff0c;有效的财务管理是企业成功的关键之一。搭贝财务管理平台为您提供了一揽子解决方案&#xff0c;助您轻松掌握财务大局&#xff0c;实现财务管控的全面数字化。 &#x1f4c8; 基础信息管理 搭贝财务管理平台首先提供了完善的基础信息管理…
阅读更多...
3D开发工具HOOPS在BIM系统中的应用

3D开发工具HOOPS在BIM系统中的应用

建筑信息模型是一种革命性的建筑设计、施工和管理方法。它通过创建和利用数字信息来优化建筑项目的设计、施工和运营过程。在这个过程中&#xff0c;3D开发工具HOOPS扮演着至关重要的角色&#xff0c;为BIM系统提供了强大的技术支持和丰富的功能。HOOPS中文网http://techsoft3d…
阅读更多...
RAG架构的数据准备流程

RAG架构的数据准备流程

虽然现成的大型语言模型 (LLM) 功能强大&#xff0c;但企业发现&#xff0c;根据其专有数据定制 LLM 可以释放更大的潜力。检索增强生成 (RAG) 已成为这种定制的主要方法之一。RAG 模型将大型语言模型强大的语言理解能力与检索组件相结合&#xff0c;使其能够从外部数据源收集相…
阅读更多...
5V升压充电8.4V芯片4A输出电流-AH3330

5V升压充电8.4V芯片4A输出电流-AH3330

AH3330-5V升压充电8.4V芯片&#xff0c;采用SSOP-10封装&#xff0c;配备外挂的MOS管&#xff0c;可支持4.5V到32V的输入电压范围&#xff0c;输出功率高达40W。该芯片广泛应用于多节电池充电控制领域&#xff0c;尤其适用于锂电池、磷酸铁锂电池和铅酸电池等不同类型的充电控制…
阅读更多...
什么是erp仓储管理系统？ERP系统的价值体现在哪些方面？

什么是erp仓储管理系统？ERP系统的价值体现在哪些方面？

ERP仓储管理系统是一个帮助企业管理仓库的工具。想象一下&#xff0c;如果你是一个仓库管理员&#xff0c;里面堆满了各种各样的产品和货物&#xff0c;如何确保这些产品数量准确、摆放有序&#xff0c;以及快速找到自己需要的产品呢&#xff1f; 这时&#xff0c;如果企业引用…
阅读更多...
【MySQL数据库】 MySQL主从复制

【MySQL数据库】 MySQL主从复制

MySQL主从复制 MySQL主从复制主从复制与读写分离的意义主从数据库实现同步&#xff08;主从复制&#xff09;三台mysql服务器搭建主从复制&#xff0c;要求不可以用root帐号同步&#xff0c;要求第三台服务器在测试过1、2的主从复制之后进行主从复制配置 MySQL主从复制 主从复…
阅读更多...
conda 环境找不到 libnsl.so.1

conda 环境找不到 libnsl.so.1

安装prokka后运行报错 perl: error while loading shared libraries: libnsl.so.1: cannot open shared object file: No such file or directory 通过conda list 可以看到 有libsnl 2.00版本&#xff0c;通过修改软链接方式进行欺骗
阅读更多...
代码随想录算法训练营Day2|977.有序数组的平方、59.螺旋矩阵||、 209.长度最小的子数组

代码随想录算法训练营Day2|977.有序数组的平方、59.螺旋矩阵||、 209.长度最小的子数组

977.有序数组的平方 这道题给出的原数组有两个特点&#xff1a; 1、由小到大 2、有负数有正数 因此&#xff0c;这个数组平方后的数应该是从两头向中间的0减小的&#xff0c;但是两头的大小需要我们用两个指针便历之后去判断大小。在遍历的同时left指针向右走&#xff0c;righ…
阅读更多...
详谈 Java中的list.forEach()和list.stream().forEach() 异同点

详谈 Java中的list.forEach()和list.stream().forEach() 异同点

涉及的文章链接&#xff1a;ArrayList 循环Remove遇到的坑 一、想总结本篇博客的原因 在日常开发中&#xff0c;需要对集合数据进行或多或少的赋值修改&#xff0c;那么循环赋值或者做一些处理就是最常见的一种操作了&#xff0c;但是用习惯了stream流&#xff0c;所以在循环的…
阅读更多...
USST新生训练赛div2+div3题解

USST新生训练赛div2+div3题解

目录 前言题解部分B Ichihime and Triangle(800)题目大意题解代码实现 C Kana and Dragon Quest game(900)题目大意题解代码实现 J Squares and Cubes(800)题目大意题解代码实现 F Double Sort(1200)题目大意题解代码实现 I Minimize the Thickness(1100)题目大意题解代码实现 …
阅读更多...
分布式事务解决方案（最终一致性【可靠消息解决方案】）

分布式事务解决方案（最终一致性【可靠消息解决方案】）

可靠消息最终一致性解决方案 可靠消息最终一致性分布式事务解决方案指的是事务的发起方执行完本地事务之后&#xff0c;发出一条消息&#xff0c;事务的参与方&#xff0c;也就是消息的消费者一定能够接收到这条消息并且处理完成&#xff0c;这个方案强调的是只要事务发起方将消…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023