热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

socket学习笔记——易犯错误

今天我将分享socket编程,在这条路上的坑,我还能剩多少了!之前再linux系统下进行学习,今天尝试再window下进行编程;区别:后者需要在进行socket编程,加载socket链接库。

今天我将分享socket编程,在这条路上的坑,我还能剩多少了!

之前再linux系统下进行学习,今天尝试再window下进行编程;

区别:后者需要在进行socket编程,加载socket链接库。

server端:

#include
#include<string>
#include 
using namespace std;

#include
#include

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

#define CONNECT_NUM_MAX 10   //最大连接数
#define MSG_MAX_NUM 256        //接受最大数据数
#define MY_PORT 18000        //端口
#define MY_IP 127.0.0.1        //IP

int main()
{
    //0.加载套接字库
    WSADATA wsaData;
    int ret = 0;
    if ((WSAStartup(MAKEWORD(2, 2), &wsaData)) != 0)
    {
        cout <<"WSAStartup(MAKEWORD(2, 2) execute failed!" << endl;
        return -1;
    }
    if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion))
    {
        WSACleanup();
        cout <<"WSADATA version is not correct" << endl;
        return -1;
    }
    
    //1.创建套接字
    SOCKET sockSer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sockSer == INVALID_SOCKET)
    {
        cout <<"sockSer create fail" << endl;
        return -1;
    }

    //初始化服务器地址族变量
    sockaddr_in serAddr;
    serAddr.sin_family = AF_INET;
    serAddr.sin_port = htons(18000);
    serAddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

    int serLen = sizeof(SOCKADDR);

    //2.bind链接
    ret = bind(sockSer, (sockaddr *)&serAddr, serLen);
    if (ret == SOCKET_ERROR)
    {
        cout <<"bind execute fail" << endl;
        closesocket(sockSer);
        WSACleanup();
        return -1;
    }

    //3.listen监听
    ret = listen(sockSer, CONNECT_NUM_MAX);
    if (ret == SOCKET_ERROR)
    {
        cout <<"listen execute failed" << endl;
        closesocket(sockSer);
        return -1;
    }
    else
    {
        cout <<"Server is listening on" <":" <"." << endl;
    }

    //4.accept
    sockaddr_in cliAddr;
    int cliLen = sizeof(SOCKADDR);
    SOCKET sockCli = accept(sockSer, (sockaddr *)&cliAddr, &cliLen);
    if (sockCli == INVALID_SOCKET)
    {
        cout <<"Accepted failed with error code:%d\n" < endl;;
        closesocket(sockSer);
        WSACleanup();
        return -1;
    }
    cout <<"Accepted\n" ;

    //5.recv/send
    char sendMsg[MSG_MAX_NUM];
    char recvMsg[MSG_MAX_NUM];
    while (1)
    {
        ZeroMemory(recvMsg, MSG_MAX_NUM);  //对数组进行初始化
        recv(sockCli, recvMsg, 256,0);
        cout <<"Cli:>"< endl;

        ZeroMemory(sendMsg, MSG_MAX_NUM);
        cout <<"Ser:>";
        cin >> sendMsg;
        send(sockCli, sendMsg, strlen(sendMsg)+1, 0);
        
    }

    //6.close
    closesocket(sockSer);
    return 0;
}

坑1:在服务端,我们需要两个SOCKET对象(sockSer和sockCli),前者用来连接、监听和接受客户端请求;后者则在服务端接受客户端请求后返回的sockCli,作为在收发消息的第一个参数。

坑2:必须将客户端和服务器的端口好进行统一。

坑3:sockaddr_in 创建的结构体变量,在配置完成后,connect函数中使用需要进行强转(sockaddr *).

客户端:

#include
#include<string>
#include
using namespace std;

#include
#include

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

#define MSG_MAX_NUM 256
#define MY_IP 127.0.0.1
#define MY_PORT 18000


int main()
{
    //0.加载套接字库
    WSADATA wsaData;
    int ret = 0;
    if ((WSAStartup(MAKEWORD(2, 2), &wsaData)) != 0)
    {
        cout <<"WSAStartup(MAKEWORD(2, 2), &wsaData) execute failed" << endl;
        return -1;
    }
    if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion))
    {
        WSACleanup();
        cout <<"WSADATA version is not correct" << endl;
        return -1;
    }
    //1.创建套接字
    SOCKET sockCli = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (sockCli == INVALID_SOCKET)
    {
        cout <<"sockCli create failed" << endl;
    }
    //初始化客户端链接服务器端变量
    sockaddr_in serAddr;
    serAddr.sin_family = AF_INET;
    serAddr.sin_port = htons(MY_PORT);
    serAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
    
    int serLen = sizeof(sockaddr);
    //2.connect
    ret = connect(sockCli, (sockaddr *)&serAddr, serLen);
    if (ret != 0)
    {
        cout <<"connect failed" << endl;
        closesocket(sockCli);
        WSACleanup();
        cin.get();
        return -1;
    }
    //3.收发消息
    char sendMsg[MSG_MAX_NUM];
    char recvMsg[MSG_MAX_NUM];
    while (1)
    {
        ZeroMemory(sendMsg, MSG_MAX_NUM);
        cout <<"Cli:>";
        cin >> sendMsg;
        send(sockCli, sendMsg, strlen(sendMsg) + 1, 0);

        ZeroMemory(recvMsg, MSG_MAX_NUM);
        recv(sockCli, recvMsg, 256, 0);
        cout <<"Ser:>" < endl;
    }

    //4.关闭套接字
    closesocket(sockCli);
    return 0;
}

坑1:客户端只要一个SOCKET对象,即针对服务端进行连接,发送数据;

坑2:sockaddr_in 创建的结构体变量,在配置完成后,connect函数中使用需要进行强转(sockaddr *).

 


推荐阅读
  • 为了确保iOS应用能够安全地访问网站数据,本文介绍了如何在Nginx服务器上轻松配置CertBot以实现SSL证书的自动化管理。通过这一过程,可以确保应用始终使用HTTPS协议,从而提升数据传输的安全性和可靠性。文章详细阐述了配置步骤和常见问题的解决方法,帮助读者快速上手并成功部署SSL证书。 ... [详细]
  • IOS Run loop详解
    为什么80%的码农都做不了架构师?转自http:blog.csdn.netztp800201articledetails9240913感谢作者分享Objecti ... [详细]
  • Java Socket 关键参数详解与优化建议
    Java Socket 的 API 虽然被广泛使用,但其关键参数的用途却鲜为人知。本文详细解析了 Java Socket 中的重要参数,如 backlog 参数,它用于控制服务器等待连接请求的队列长度。此外,还探讨了其他参数如 SO_TIMEOUT、SO_REUSEADDR 等的配置方法及其对性能的影响,并提供了优化建议,帮助开发者提升网络通信的稳定性和效率。 ... [详细]
  • 本指南介绍了如何在ASP.NET Web应用程序中利用C#和JavaScript实现基于指纹识别的登录系统。通过集成指纹识别技术,用户无需输入传统的登录ID即可完成身份验证,从而提升用户体验和安全性。我们将详细探讨如何配置和部署这一功能,确保系统的稳定性和可靠性。 ... [详细]
  • Python 伦理黑客技术:深入探讨后门攻击(第三部分)
    在《Python 伦理黑客技术:深入探讨后门攻击(第三部分)》中,作者详细分析了后门攻击中的Socket问题。由于TCP协议基于流,难以确定消息批次的结束点,这给后门攻击的实现带来了挑战。为了解决这一问题,文章提出了一系列有效的技术方案,包括使用特定的分隔符和长度前缀,以确保数据包的准确传输和解析。这些方法不仅提高了攻击的隐蔽性和可靠性,还为安全研究人员提供了宝贵的参考。 ... [详细]
  • 本文详细介绍了 Pentaho Kettle 中 RowMetaInterface.writeMeta 方法的使用,并提供了多个代码示例,帮助开发者更好地理解和应用该方法。 ... [详细]
  • 零拷贝技术是提高I/O性能的重要手段,常用于Java NIO、Netty、Kafka等框架中。本文将详细解析零拷贝技术的原理及其应用。 ... [详细]
  • 1.创建目录mkdir-phomerocketmqnamesvr1data&&mkdir-phomerocketmqnamesvr1log&&mkdir-phomerocketm ... [详细]
  • 如何在Java中使用DButils类
    这期内容当中小编将会给大家带来有关如何在Java中使用DButils类,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。D ... [详细]
  • 思科IOS XE与ISE集成实现TACACS认证配置
    本文详细介绍了如何在思科IOS XE设备上配置TACACS认证,并通过ISE(Identity Services Engine)进行用户管理和授权。配置包括网络拓扑、设备设置和ISE端的具体步骤。 ... [详细]
  • 如何在Linux服务器上配置MySQL和Tomcat的开机自动启动
    在Linux服务器上部署Web项目时,通常需要确保MySQL和Tomcat服务能够随系统启动而自动运行。本文将详细介绍如何在Linux环境中配置MySQL和Tomcat的开机自启动,以确保服务的稳定性和可靠性。通过合理的配置,可以有效避免因服务未启动而导致的项目故障。 ... [详细]
  • 在软件开发过程中,经常需要将多个项目或模块进行集成和调试,尤其是当项目依赖于第三方开源库(如Cordova、CocoaPods)时。本文介绍了如何在Xcode中高效地进行多项目联合调试,分享了一些实用的技巧和最佳实践,帮助开发者解决常见的调试难题,提高开发效率。 ... [详细]
  • 如何将TS文件转换为M3U8直播流:HLS与M3U8格式详解
    在视频传输领域,MP4虽然常见,但在直播场景中直接使用MP4格式存在诸多问题。例如,MP4文件的头部信息(如ftyp、moov)较大,导致初始加载时间较长,影响用户体验。相比之下,HLS(HTTP Live Streaming)协议及其M3U8格式更具优势。HLS通过将视频切分成多个小片段,并生成一个M3U8播放列表文件,实现低延迟和高稳定性。本文详细介绍了如何将TS文件转换为M3U8直播流,包括技术原理和具体操作步骤,帮助读者更好地理解和应用这一技术。 ... [详细]
  • 本文介绍了如何利用Shell脚本高效地部署MHA(MySQL High Availability)高可用集群。通过详细的脚本编写和配置示例,展示了自动化部署过程中的关键步骤和注意事项。该方法不仅简化了集群的部署流程,还提高了系统的稳定性和可用性。 ... [详细]
  • 本文探讨了使用JavaScript在不同页面间传递参数的技术方法。具体而言,从a.html页面跳转至b.html时,如何携带参数并使b.html替代当前页面显示,而非新开窗口。文中详细介绍了实现这一功能的代码及注释,帮助开发者更好地理解和应用该技术。 ... [详细]
author-avatar
iainabaobei_151
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有