C语言网络编程：物联网设备接入与数据处理

wufei123 2025-01-26 阅读:59 评论:0

c 语言网络编程可用于建立物联网设备的网络连接并处理其数据。具体步骤包括：1. 创建套接字；2. 绑定套接字到端口；3. 侦听传入连接；4. 接受传入连接；5. 发送和接收数据。 C 语言网络编程：物联网设备接入与数据处理简介物联网（...

c 语言网络编程可用于建立物联网设备的网络连接并处理其数据。具体步骤包括：1. 创建套接字；2. 绑定套接字到端口；3. 侦听传入连接；4. 接受传入连接；5. 发送和接收数据。

C 语言网络编程：物联网设备接入与数据处理

简介

物联网（IoT）设备正迅速普及，掌握网络编程技能对于管理和处理这些设备至关重要。本文将介绍如何使用 C 语言为物联网设备建立网络连接并处理它们发送的数据。

建立套接字连接

物联网设备通常使用 TCP（传输控制协议）或 UDP（用户数据报协议）进行通信。要建立连接，我们需要创建一个套接字。以下代码演示了如何创建 TCP 套接字：

#include <sys>

int sock = socket(AF_INET, SOCK_STREAM, 0);
if (sock == -1) {
    perror("socket");
    exit(EXIT_FAILURE);
}</sys>

绑定套接字到端口

一旦创建了套接字，我们需要将其绑定到特定的 IP 地址和端口号。对于服务器端，我们需要绑定到 IP 地址 0.0.0.0（监听所有传入连接）和指定端口。

struct sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = INADDR_ANY;
addr.sin_port = htons(PORT);

if (bind(sock, (struct sockaddr *)&amp;addr, sizeof(addr)) == -1) {
    perror("bind");
    exit(EXIT_FAILURE);
}

侦听传入连接

对于服务器端，我们需要侦听传入的连接。listen() 函数用于此目的：

if (listen(sock, BACKLOG) == -1) {
    perror("listen");
    exit(EXIT_FAILURE);
}

接受传入连接

当有客户端连接时，accept() 函数可以接受并返回一个新套接字，用于与该客户端通信。

int client_sock = accept(sock, NULL, NULL);
if (client_sock == -1) {
    perror("accept");
    exit(EXIT_FAILURE);
}

数据发送和接收

一旦建立了连接，客户端和服务器端就可以使用 send() 和 recv() 函数发送和接收数据。

// 发送数据
int bytes_sent = send(client_sock, "Hello, world!", 13, 0);
if (bytes_sent == -1) {
    perror("send");
    exit(EXIT_FAILURE);
}

// 接收数据
char buffer[1024];
int bytes_received = recv(client_sock, buffer, sizeof(buffer), 0);
if (bytes_received == -1) {
    perror("recv");
    exit(EXIT_FAILURE);
}
printf("Received: %s
", buffer);

实战案例

考虑一个简单的物联网温度传感器，它会定期将温度数据发送到服务器。下面是一个服务器端程序，它会侦听传感器连接并打印接收到的温度：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys>
#include <netinet>

#define PORT 8080
#define BACKLOG 5

int main() {
    int sock = socket(AF_INET, SOCK_STREAM, 0);
    if (sock == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }

    struct sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = INADDR_ANY;
    addr.sin_port = htons(PORT);

    if (bind(sock, (struct sockaddr *)&amp;addr, sizeof(addr)) == -1) {
        perror("bind");
        exit(EXIT_FAILURE);
    }

    if (listen(sock, BACKLOG) == -1) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    while (1) {
        int client_sock = accept(sock, NULL, NULL);
        if (client_sock == -1) {
            perror("accept");
            exit(EXIT_FAILURE);
        }

        char buffer[1024];
        int bytes_received = recv(client_sock, buffer, sizeof(buffer), 0);
        if (bytes_received == -1) {
            perror("recv");
            exit(EXIT_FAILURE);
        }
        printf("Received temperature: %s
", buffer);
        close(client_sock);
    }

    return 0;
}</netinet></sys></string.h></stdlib.h></stdio.h>