TCP服务端主动向客户端发送数据

C++ TCP 服务端和客户端通信的例子

在此基础上,要修改服务端代码,使其能够每秒向客户端发送当前时间,你需要添加一个循环,每次循环发送当前时间给客户端。同时,你需要在客户端代码中添加接收服务端发送的数据的逻辑。

以下是修改后的代码:

服务端代码:

#include <iostream>
#include <winsock2.h>
#include <Ws2tcpip.h> // for inet_ntop
#include <ctime> // for time and localtime_s#pragma comment(lib, "Ws2_32.lib")#define PORT 8080int main() {WSADATA wsaData;SOCKET serverSocket, newSocket;struct sockaddr_in serverAddr, clientAddr;int clientAddrLen = sizeof(clientAddr);char buffer[1024] = { 0 };const char* message = "Hello from server";// 初始化 Winsockif (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {std::cerr << "WSAStartup failed." << std::endl;return 1;}// 创建服务器套接字if ((serverSocket = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) {std::cerr << "Socket creation failed." << std::endl;WSACleanup();return 1;}// 设置服务器地址serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = INADDR_ANY;serverAddr.sin_port = htons(PORT);// 将套接字绑定到服务器地址if (bind(serverSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {std::cerr << "Bind failed." << std::endl;closesocket(serverSocket);WSACleanup();return 1;}// 监听连接if (listen(serverSocket, 5) == SOCKET_ERROR) {std::cerr << "Listen failed." << std::endl;closesocket(serverSocket);WSACleanup();return 1;}std::cout << "Server listening on port " << PORT << std::endl;// 接受客户端连接if ((newSocket = accept(serverSocket, (struct sockaddr*)&clientAddr, &clientAddrLen)) == INVALID_SOCKET) {std::cerr << "Accept failed." << std::endl;closesocket(serverSocket);WSACleanup();return 1;}// Convert client IP address to stringchar clientIP[INET_ADDRSTRLEN];inet_ntop(AF_INET, &clientAddr.sin_addr, clientIP, INET_ADDRSTRLEN);std::cout << "Connection accepted from " << clientIP << ":" << ntohs(clientAddr.sin_port) << std::endl;// 每秒向客户端发送当前时间while (true) {// 获取当前时间time_t currentTime = time(nullptr);struct tm localTime;localtime_s(&localTime, &currentTime);std::string timeString = asctime(&localTime);// 发送当前时间给客户端if (send(newSocket, timeString.c_str(), timeString.size(), 0) == SOCKET_ERROR) {std::cerr << "Send failed." << std::endl;closesocket(newSocket);closesocket(serverSocket);WSACleanup();return 1;}std::cout << "Message sent to client: " << timeString;Sleep(1000); // 等待1秒钟}// 关闭套接字closesocket(newSocket);closesocket(serverSocket);WSACleanup();return 0;
}

客户端代码:

#include <iostream>
#include <winsock2.h>
#include <Ws2tcpip.h> // for inet_pton#pragma comment(lib, "Ws2_32.lib")#define PORT 8080
#define SERVER_IP "127.0.0.1"int main() {WSADATA wsaData;SOCKET clientSocket;struct sockaddr_in serverAddr;char buffer[1024] = { 0 };// 初始化 Winsockif (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {std::cerr << "WSAStartup failed." << std::endl;return 1;}// 创建客户端套接字if ((clientSocket = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET) {std::cerr << "Socket creation failed." << std::endl;WSACleanup();return 1;}// 设置服务器地址serverAddr.sin_family = AF_INET;inet_pton(AF_INET, SERVER_IP, &(serverAddr.sin_addr));serverAddr.sin_port = htons(PORT);// 连接到服务器if (connect(clientSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {std::cerr << "Connect failed." << std::endl;closesocket(clientSocket);WSACleanup();return 1;}std::cout << "Connected to server." << std::endl;// 接收来自服务器的消息int valread;while ((valread = recv(clientSocket, buffer, sizeof(buffer), 0)) > 0) {std::cout << "Message from server: " << buffer << std::endl;memset(buffer, 0, sizeof(buffer)); // 清空缓冲区}if (valread == 0) {std::cout << "Server disconnected." << std::endl;} else {std::cerr << "Recv failed." << std::endl;}// 关闭套接字closesocket(clientSocket);WSACleanup();return 0;
}

这样修改后,服务端每秒钟向客户端发送当前时间,而客户端接收并打印出来。

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

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

相关文章

基于PHP的校园招聘管理系统

有需要请加文章底部Q哦 可远程调试 基于PHP的校园招聘管理系统 一 介绍 此校园招聘管理系统基于原生PHP开发&#xff0c;数据库mysql&#xff0c;前端bootstrap。系统角色分为个人用户&#xff0c;企业和管理员三种。 技术栈&#xff1a;phpmysqlbootstrapphpstudyvscode 二…

蓝桥杯刷题第六天(昨天忘记发了)

今天想从不一样的角度来解题&#xff1a;从时间紧张暴力求解到思路阔达直接通过所有案例 暴力方法&#xff1a; 思路第一眼看到这个问题我就想到了第一个思路就是先用两个数组一个存石子数一个存颜色状态&#xff0c;每次遍历一遍看看有没有相邻石子颜色一样且为和最小的。 im…

C语言算法学习记录:不创建第三个参数进行交换

int a 90;int b 20;printf("交换之前 a %d b %d\n", a, b);a a ^ b;b a ^ b;a a ^ b;printf("交换之后 a %d b %d\n", a, b);

深度学习理论基础(五)卷积神经网络CNN

目录 一、卷积神经网络基础1.卷积层&#xff08;1&#xff09;内部参数&#xff1a;卷积核权重&#xff08;2&#xff09;内部参数&#xff1a;偏置&#xff08;3&#xff09;外部参数&#xff1a;填充padding&#xff08;默认不填充&#xff09;&#xff08;3&#xff09;外部…

分月饼 java题解

import java.util.Scanner;public class Main {public static void main(String[] args) {Scanner sc new Scanner(System.in); int m sc.nextInt(); // 读取员工数量mint n sc.nextInt(); // 读取月饼数量n// 调用distribute方法并打印返回的分配方法总数//先默认每人分一个…

--headless=new,pythom,爬虫

相信大家在看很多爬虫资料的时候&#xff0c;都知道&#xff0c;有一个无头模式。也就是不显示浏览器窗口。 但是实际上&#xff0c;无头模式&#xff0c;在很多地方会被很多网站检测。比如cloundfront, 亚马逊的DNS保护就会拦截导致403 错误。 实际上呢。无头模式&#xff0…

2024年华为OD机试真题-亲子游戏-Java-OD统一考试(C卷)

题目描述: 宝宝和妈妈参加亲子游戏,在一个二维矩阵(N*N)的格子地图上,宝宝和妈妈抽签决定各自的位置,地图上每个格子有不同的糖果数量,部分格子有障碍物。 游戏规则是妈妈必须在最短的时间(每个单位时间只能走一步)到达宝宝的位置,路上的所有糖果都可以拿走,不能走障…

如何冷迁移Oracle RAC到单机(非RMAN)

1、起因 群友说有套数据库要进行迁移&#xff0c;源端是套跑了十年的RAC&#xff0c;目标段是个新的单机&#xff08;都是同一架构平台&#xff09;&#xff0c;数据量约3T左右。 目前DATA目录存储和归档放在一起&#xff0c;整个磁盘组只剩下了20G空间&#xff0c;每间隔1小…

Google DeepMind 大语言模型中的长形态事实性

&#x1f349; CSDN 叶庭云&#xff1a;https://yetingyun.blog.csdn.net/ 论文标题&#xff1a;Long-form factuality in large language models 论文链接&#xff1a;https://arxiv.org/abs/2403.18802 论文的关键信息总结如下&#xff1a; 研究问题是什么&#xff1f;论文…

如何优化Flutter应用以通过iOS应用商店的审核流程

本文探讨了使用Flutter开发的iOS应用能否上架&#xff0c;以及上架的具体流程。苹果提供了App Store作为正式上架渠道&#xff0c;同时也有TestFlight供开发者进行内测。合规并通过审核后&#xff0c;Flutter应用可以顺利上架。但上架过程可能存在一些挑战&#xff0c;因此可能…

kubernetes-dashboard 安装配置

k8s 1.23以上的版本 https://raw.githubusercontent.com/kubernetes/dashboard/v2.7.0/aio/deploy/recommended.yaml 执行命令&#xff1a; kubectl apply -f https://raw.githubusercontent.com/kubernetes/dashboard/v2.7.0/aio/deploy/recommended.yaml 安装完成后&#x…

寒冬已逝,“量子春天”正来

最近&#xff0c;全球对量子技术领域的私人投资有所下降&#xff0c;引发了一些观点认为这个领域可能正逐渐衰退。 政治家、资助者和投资者并不总是以科学为关注焦点。然而&#xff0c;某些科技领域偶尔会成为热点&#xff0c;正如20世纪50年代核能技术的兴起&#xff0c;那时人…

【Linux】ubuntu安装google gtest框架

本文首发于 ❄️慕雪的寒舍 ubuntu 22.04.03 LTS 安装 google gtest 框架 1.依赖项 首先在ubuntu中安装如下包 sudo apt install -y unzip g gcc cmake make automake2.下载软件包 进入google gtest的github页面&#xff0c;下载源码包 Releases google/googletest https…

EXCEL通过VBA字典快速分类求和

EXCEL通过VBA字典快速分类求和 汇总截图 Option ExplicitOption Explicit Sub answer3() Dim wb As Workbook Dim sht As Worksheet Set wb ThisWorkbook Set sht wb.Worksheets(2) Dim ss1 As Integer Dim ss2 As Integer Dim i As Integer Dim j As Integer j 1Dim aa()…

Linux环境基础和工具的使用

目录 1、Linux软件包管理器---yum 2、Linux开发工具 2.1、vim基本概念 2.2 vim基本操作 2.3 vim正常模式命令集 2.4 vim末行模式命令集 2.5 简单vim配置 2.5.1 配置文件的位置 3 Linux编译器--gcc/g的使用 3.1 背景知识 3.2 gcc完成 4 Linux调试器--gdb使用 4.1 背…

JS实现省市区三级联动(json假数据)

省市级三级联动通常指的是在用户界面上&#xff0c;用户可以通过选择省份&#xff0c;然后基于所选择的省份选择对应的城市&#xff0c;最后基于所选择的城市选择对应的区县。这种联动效果在很多应用中都有出现&#xff0c;例如电商平台的收货地址选择、政务服务的地区选择等。…

文件操作(2)【文件的随机读写】【文件读取结束的判定】

一.文件的随机读写 1.fseek函数 这个函数可以根据文件指针的位置和偏移量来定位文件指针&#xff08;文件内容的光标&#xff09;。有三个参数&#xff1a; stream&#xff1a;文件指针&#xff0c;指向要设置位置的文件。offset&#xff1a;偏移量&#xff0c;可以为正数、负…

Vue3:用Pinia的storeToRefs结构赋值store数据

一、情景描述 我们学习了Pinia之后&#xff0c;知道&#xff0c;数据是配置在Pinia的state里面的。 那么&#xff0c;如果有多个字段需要取出来使用&#xff0c;并且不丢失数据的响应式&#xff0c;如何优雅的操作了&#xff1f; 这里就用到了Pinia的storeToRefs函数 二、案…

三角形最小路径和

题目链接 三角形最小路径和 题目描述 注意点 -10000 < triangle[i][j] < 10000triangle[i].length triangle[i - 1].length 1triangle[0].length 1 解答思路 由题意得&#xff0c;到达任意第i层第j个节点的路径和一定是由第i - 1层第j - 1或第j个节点到达&#x…

【基频提取算法-PYIN】

本文对基频提取算法 PYIN 做以介绍。如有表述不当之处欢迎批评指正。欢迎任何形式的转载&#xff0c;但请务必注明出处。 文章目录 1. 引言2. PYIN 各模块代码讲解2.1. 概率 YIN 算法2.2. 使用 HMM 得到更平滑的音高轨迹2.2.1. 观测概率2.2.2. 状态转移概率2.2.3. 维特比算法解…