C中的服务器到客户端广播

如何解决C中的服务器到客户端广播

我目前正在处理一个需要客户端-服务器-客户端通信的项目。我有一个代码，它从 client1 获取消息，将其发送到服务器，然后服务器发送确认。 我希望服务器然后将信号广播到同一代码块中的其余客户端。我该怎么做？任何帮助都会很棒！

Server.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h> // for close
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#define PORT 8081

int main(){

char server_message[2000]; // server message ack 1
char server_message2[2000]; //server message ack 2
char client_msg1[2000]; //client msg
//char client_msg2[2000];
int address_len; // IP address length
int newSocket; //variable for socket no
int bind_socket; //variable for binding socket
int rcv_data; //variable for rcving of data
int sent_data; //sent data variable
int sent_data2;
int sent_data3;

char broadcast = '1';

//Clearing Data
memset(server_message,'\0',sizeof(server_message));
memset(server_message2,sizeof(server_message2));
memset(client_msg1,sizeof(client_msg1));

//Server AckNowledgement messages
strcpy(server_message,"\n\tAckNowledged.\n");
strcpy(server_message2,"1");

//Server structure
struct sockaddr_in address;
address.sin_addr.s_addr = htonl(INADDR_ANY);
address.sin_port = htons(PORT);
address.sin_family = AF_INET;

address_len = sizeof(address);

//Creating socket
newSocket = socket(AF_INET,SOCK_DGRAM,0);
printf("\n\tSocket no: %d\n",newSocket);

//Checking socket creation
if(newSocket < 0){
    printf("\t[-]Error Creating Socket\n");
    exit(1);
}
else printf("\n\t[+]Socket Creation Success.\n");

//Binding socket with IP
bind_socket = bind(newSocket,(struct sockaddr *)&address,sizeof(address));

//Checking Bind Process
if(bind_socket < 0){
    printf("\t[-]Error Binding Socket\n");
    exit(1);
}
else printf("\n\t[+]Binding Success.\n");


printf("\n\tREMOTE CONTROL UNIT SERVER ON.\n\n");

while(1){
    
    //rcving data from server in clt msg 1
    rcv_data = recvfrom(newSocket,client_msg1,sizeof(client_msg1),&address_len);
    
    //checking if recv process was successful
    if(rcv_data < 0){
        printf("\n\t[-]Error receiving data\n");
        exit(1);
    }
    else printf("\n\t[+]Message recieved Success.\n");
    
    //printing msg from client,i.e. on/off
    printf("\n\tMessage from Client: %s\n",client_msg1);
    
    //Algo for sending ackNowledgment to client
    if(strcmp(client_msg1,"0")){
        printf("\n\tL1 -> ON. Applying trajectory algorithim and sending broadcasting.\n");
        sent_data = sendto(newSocket,server_message,sizeof(server_message),(struct sockaddr*)&address,address_len);
        //checking if data transmission was succesful
        if(sent_data < 0){
            printf("\n\t[-]Error sending ACK\n");
            exit(1);
        }
        else printf("\n\t[+]AckNowledgement sent.\n");
    }
    
    if(strcmp(client_msg1,"1")){
        printf("\n\tL1 -> OFF.\n");
        sent_data2 = sendto(newSocket,address_len);
        if(sent_data2 < 0){
            printf("\n\t[-]Error sending data\n");
            exit(1);
            }
        else printf("\n\t[+]AckNowledgement sent.\n");
 }
}

    //clearing all buffers
    memset(server_message,sizeof(server_message));
    memset(client_msg1,sizeof(client_msg1));
    
    //closing socket
    close(newSocket);

    return 0;
}

客户端.c

    #include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h> // for close

#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#define ARRAY 10
#define PORT 8081

int main(){

char buffer[3000];
char server_message[30000];
int clientSocket;
int sendData;
int rcvData;


struct sockaddr_in server_addr;
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(PORT);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");

// Creating socket
clientSocket = socket(AF_INET,clientSocket);

//Checking if socket creation was successful
if(clientSocket < 0){
    printf("\n\t[-]Error Creating Socket\n");
    exit(1);
}
else
    printf("\n\t[+]Socket Creation Success.\n");

//clearing buffer and server message
memset(buffer,sizeof(buffer));
memset(server_message,sizeof(server_message));

int server_struct_size = sizeof(server_addr);

//data to be sent to server

while(1){
    
    printf("\n\tEnter message to server: \n");
    gets(buffer);
    
    //Sending data to server
    sendData = sendto(clientSocket,buffer,sizeof(buffer),(struct sockaddr*) &server_addr,server_struct_size);
        
    //Checking if data transmission was succcesful
        if(sendData < 0){
            printf("\n\t[-]Error sending Data.\n");
            exit(1);
        }
        else printf("\n\t[+]Data Transmission Success.\n");
    memset(buffer,sizeof(buffer));
    
    // receiving data from server,ack
        rcvData = recvfrom(clientSocket,(struct sockaddr *) & server_addr,&server_struct_size);
        
    //checking recv data
        if(rcvData < 0){
            printf("\n\t[-]Error receiving Data\n");
            exit(1);
        }
        else printf("\n\t[+]Data Recive Success.\n");
        
        printf("\n\tServer Message: %s\n",server_message);
        
        //cearing buffer,server message
        memset(server_message,sizeof(server_message));

    
}



    

    
//clsing socket
close(rcvData);
close(clientSocket);

return 0;
}