ZBLOG

使用C语言实现一个简单的WebSocket server

以下是使用C语言实现一个简单的WebSocket服务器的基本示例代码:

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <sys/socket.h>
  5. #include <netinet/in.h>
  6. #define MAX_CLIENTS 10
  7. #define BUFFER_SIZE 1024
  8. int main() {
  9. int serverSocket, clientSockets[MAX_CLIENTS], maxClients = MAX_CLIENTS;
  10. struct sockaddr_in serverAddress, clientAddress;
  11. char buffer[BUFFER_SIZE];
  12. // 创建服务器套接字
  13. if ((serverSocket = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
  14. perror("Failed to create socket");
  15. exit(1);
  16. }
  17. // 设置服务器地址和端口
  18. serverAddress.sin_family = AF_INET;
  19. serverAddress.sin_addr.s_addr = INADDR_ANY;
  20. serverAddress.sin_port = htons(8080);
  21. // 绑定套接字到指定地址和端口
  22. if (bind(serverSocket, (struct sockaddr *)&serverAddress, sizeof(serverAddress)) == -1) {
  23. perror("Failed to bind socket");
  24. exit(1);
  25. }
  26. // 开始监听连接请求
  27. if (listen(serverSocket, maxClients) == -1) {
  28. perror("Error in listen");
  29. exit(1);
  30. }
  31. printf("WebSocket Server running on port 8080\n");
  32. while (1) {
  33. socklen_t clientLength = sizeof(clientAddress);
  34. int newSocket;
  35. // 等待客户端连接请求
  36. if ((newSocket = accept(serverSocket, (struct sockaddr *)&clientAddress,
  37. &clientLength)) == -1) {
  38. perror("Error in accepting connection");
  39. exit(1);
  40. }
  41. printf("New connection accepted\n");
  42. // 接收和发送数据
  43. while (1) {
  44. memset(buffer, 0, BUFFER_SIZE);
  45. // 接收客户端发送的消息
  46. if (recv(newSocket, buffer, BUFFER_SIZE - 1, 0) == -1) {
  47. perror("Error in receiving data");
  48. exit(1);
  49. }
  50. printf("Received message: %s\n", buffer);
  51. // 发送回复消息给客户端
  52. const char *response = "Hello from WebSocket server!";
  53. if (send(newSocket, response, strlen(response), 0) == -1) {
  54. perror("Error in sending data");
  55. exit(1);
  56. }
  57. }
  58. }
  59. // 关闭套接字
  60. for (int i = 0; i < maxClients; i++) {
  61. close(clientSockets[i]);
  62. }
  63. close(serverSocket);
  64. return 0;
  65. }

这只是一个简单示例,用于监听来自客户端的连接请求并发送回复消息。在实际应用中,您可能需要根据WebSocket协议规范处理更多细节,并实现WebSocket的握手过程、帧解析和数据处理等功能。


内容由零声教学AI助手提供,问题来源于学员提问

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://golang.0voice.com/?id=15763

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?