QNX平台上实现Socket通信的示例代码

本示例代码演示了在QNX平台上如何使用Socket实现进程间通信，使用简单的TCP协议建立通信连接，并且使用多线程实现并发通信。通过本示例代码，用户可以学习如何实现在QNX平台上使用Socket进行进程间通信的基本功。

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>

#define PORT 8080

void *processClient(void *socket_desc){
  int sock = *(int*)socket_desc;
  int read_size;
  char message[2000], client_reply[2000];

  while( (read_size = recv(sock, client_reply, 2000, 0)) > 0 ){
    printf("[Client %d] message recieved from client: %s\n", sock, client_reply);
    write(sock, client_reply, strlen(client_reply));
    memset(&client_reply[0], 0, sizeof(client_reply));
  }
  if(read_size == 0){
    printf("[Client %d] client disconnected\n", sock);
    fflush(stdout);
  }
  else if(read_size == -1){
    perror("recv failed");
  }
  free(socket_desc);
  pthread_exit(NULL);
}

int main(){
  int socket_desc, new_socket, c, *new_sock;
  struct sockaddr_in server, client;

  socket_desc = socket(AF_INET, SOCK_STREAM, 0);
  if(socket_desc == -1){
    printf("Failed to create socket\n");
    return -1;
  }

  server.sin_family = AF_INET;
  server.sin_addr.s_addr = INADDR_ANY;
  server.sin_port = htons(PORT);

  if(bind(socket_desc, (struct sockaddr *)&server, sizeof(server)) < 0){
    printf("Failed to bind the socket\n");
    return -1;
  }

  listen(socket_desc, 3);

  printf("Waiting for incoming connections...\n");
  c = sizeof(struct sockaddr_in);

  while( (new_socket = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c)) ){
    printf("Connection accepted from %s:%d\n", inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    pthread_t sniffer_thread;
    new_sock = malloc(1);
    *new_sock = new_socket;
    if(pthread_create(&sniffer_thread, NULL, processClient, (void*)new_sock) < 0){
      perror("could not create thread\n");
      return -1;
    }
    printf("Handler assigned\n");
  }

  if(new_socket < 0){
    printf("Connection refused\n");
    return -1;
  }
  return 0;
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com