怎么用SOCKET进行“多播”而不是进行“广播”? 在线等 解决方案 » 免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货 这个程序并不是我写的,是原来我从csdn这里抄的!!!组播通讯:////////////////////send.c////////////////////////////#include <winsock2.h>#include <ws2tcpip.h>#include <stdio.h>#define BUFFSIZE 2048#define IP_ADDR "224.8.8.1" #define DEST_PORT 8888int main(int argc,char *argv[]){ int sockfd; struct sockaddr_in addr; char szError[100]; char buf[] = "Hello, World!"; int ttl = 255 ; // Arbitrary TTL value. WSADATA WSAData; WORD wVersionRequested; wVersionRequested = MAKEWORD(2, 2); if (WSAStartup (wVersionRequested , &WSAData) != 0) { printf ("recver:Initialize Winsock error!"); exit(1); } if (LOBYTE(WSAData.wVersion) != 2 || HIBYTE(WSAData.wVersion) != 2 ) { WSACleanup( ); printf ("setsockopt failed! Error: %d", WSAGetLastError ()); exit(1); } addr.sin_family = AF_INET; addr.sin_port = htons(DEST_PORT); addr.sin_addr.s_addr = inet_addr(IP_ADDR); if ((sockfd=socket(AF_INET,SOCK_DGRAM,0)) < 0) { printf("sender:new a socket error!\n"); exit(1); } if(setsockopt(sockfd, IPPROTO_IP, IP_MULTICAST_TTL, (char *)&ttl, sizeof(ttl))!=0) { printf("error setsockopt IP_MULTICAST_TTL\n"); exit(1); }/* if (bind(sockfd,(struct sockaddr *)&recver_addr,sizeof(recver_addr)) < 0) { closesocket(sockfd); printf("recver:bind socket error!\n"); exit(1); }*/ if (sendto (sockfd, buf, sizeof(buf) , 0, (struct sockaddr *)&addr, sizeof(addr)) == SOCKET_ERROR) { wsprintf (szError, TEXT("sendto failed! Error: %d"), WSAGetLastError ()); MessageBox (NULL, szError, TEXT("Error"), MB_OK); closesocket (sockfd); return FALSE; } else { printf("send ok\n"); } // Close Sock. closesocket (sockfd); WSACleanup (); return 0;}////////////////////send.c/////////////////////////////////////////////////////////receive.c//////////////////////////////#include <windows.h>#include <winsock2.h>#include <ws2tcpip.h>#include <stdio.h>#define BUFFSIZE 2048#define RECV_IP_ADDR "224.8.8.1" #define DEST_PORT 8888int main(int argc,char *argv[]){ int sockfd; int sock_reuse = 1; struct ip_mreq multicast; struct sockaddr_in recver_addr; char szError[100]; int index = 0, // Integer index iRecvLen; // Length of recv_sin char szMessageA[1024*320]; // ASCII string TCHAR szMessageW[1024*320]; // Unicode string WSADATA WSAData; WORD wVersionRequested; wVersionRequested = MAKEWORD(2, 2); if (WSAStartup (wVersionRequested , &WSAData) != 0) { printf ("recver:Initialize Winsock error!"); exit(1); } if (LOBYTE(WSAData.wVersion) != 2 || HIBYTE(WSAData.wVersion) != 2 ) { WSACleanup( ); printf ("setsockopt failed! Error: %d", WSAGetLastError ()); exit(1); } multicast.imr_multiaddr.s_addr = inet_addr(RECV_IP_ADDR); multicast.imr_interface.s_addr = htonl(INADDR_ANY); recver_addr.sin_family = AF_INET; recver_addr.sin_port = htons(DEST_PORT); recver_addr.sin_addr.s_addr = INADDR_ANY; if ((sockfd=socket(AF_INET,SOCK_DGRAM,0)) < 0) { printf("recver:new a socket error!\n"); exit(1); } if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (char *)&sock_reuse, sizeof(sock_reuse)) < 0) { printf("recver : socket options set error"); exit(1); } if (bind(sockfd,(struct sockaddr *)&recver_addr,sizeof(recver_addr)) < 0) { closesocket(sockfd); printf("recver:bind socket error!\n"); exit(1); } if (setsockopt(sockfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,(char *)&multicast,sizeof(multicast)) < 0 ) { sprintf (szError, TEXT("setsockopt failed! Error: %d"), WSAGetLastError ()); printf("%s\n", szError); closesocket(sockfd); exit(1); } printf("Receive on %s:%d\n", RECV_IP_ADDR, DEST_PORT); iRecvLen = sizeof (recver_addr); memset(szMessageA, 0, sizeof(szMessageA)); // Receive data from the multicasting group server. if (recvfrom (sockfd, szMessageA, sizeof(szMessageA), 0, (struct sockaddr FAR *) &recver_addr, &iRecvLen) == SOCKET_ERROR) { wsprintf (szError, TEXT("recvfrom failed! Error: %d"), WSAGetLastError ()); MessageBox (NULL, szError, TEXT("Error"), MB_OK); closesocket (sockfd); return FALSE; } else { // Convert the ASCII string to a Unicode string. for (index = 0; index <= sizeof (szMessageA); index++) szMessageW[index] = szMessageA[index]; MessageBox (NULL, szMessageW, TEXT("Info"), MB_OK); } // Disable receiving on Sock before closing it. shutdown (sockfd, 0x00); // Close Sock. closesocket (sockfd); WSACleanup (); return 0;}/////////////////////////////receive.c//////////////////////////// MFC里如何只显示自定义的对话框 牛人们,tcp 分包的标志是什么呢? 关于多文档编程中异常错误的问题! 改动了debug设置,怎么改回来? 如何让应用程序将自己的函数能提供给别的应用程序调用? static library里的资源如何应用到调用这个静态库的工程里? 初学者的问题 在MFC中,如何获取文件夹内最新加入的文件名? 做了一个输入法,有个小问题不知道如何解决. 各位大虾,我想在弹出菜单里显示位图,可以吗? 帮我看看程序的连接问题!!!!!! 请 NickTang (萧峰) 来那分。
组播通讯:
////////////////////send.c////////////////////////////
#include <winsock2.h>
#include <ws2tcpip.h>
#include <stdio.h>#define BUFFSIZE 2048
#define IP_ADDR "224.8.8.1"
#define DEST_PORT 8888int main(int argc,char *argv[])
{
int sockfd;
struct sockaddr_in addr;
char szError[100];
char buf[] = "Hello, World!";
int ttl = 255 ; // Arbitrary TTL value. WSADATA WSAData;
WORD wVersionRequested;
wVersionRequested = MAKEWORD(2, 2);
if (WSAStartup (wVersionRequested , &WSAData) != 0)
{
printf ("recver:Initialize Winsock error!");
exit(1);
}
if (LOBYTE(WSAData.wVersion) != 2 || HIBYTE(WSAData.wVersion) != 2 ) {
WSACleanup( );
printf ("setsockopt failed! Error: %d", WSAGetLastError ());
exit(1);
} addr.sin_family = AF_INET;
addr.sin_port = htons(DEST_PORT);
addr.sin_addr.s_addr = inet_addr(IP_ADDR);
if ((sockfd=socket(AF_INET,SOCK_DGRAM,0)) < 0) {
printf("sender:new a socket error!\n");
exit(1);
} if(setsockopt(sockfd, IPPROTO_IP, IP_MULTICAST_TTL, (char *)&ttl, sizeof(ttl))!=0)
{
printf("error setsockopt IP_MULTICAST_TTL\n");
exit(1);
}
/*
if (bind(sockfd,(struct sockaddr *)&recver_addr,sizeof(recver_addr)) < 0) {
closesocket(sockfd);
printf("recver:bind socket error!\n");
exit(1);
}
*/
if (sendto (sockfd, buf, sizeof(buf) , 0, (struct sockaddr *)&addr, sizeof(addr))
== SOCKET_ERROR)
{
wsprintf (szError, TEXT("sendto failed! Error: %d"),
WSAGetLastError ());
MessageBox (NULL, szError, TEXT("Error"), MB_OK);
closesocket (sockfd);
return FALSE;
}
else
{
printf("send ok\n");
} // Close Sock.
closesocket (sockfd);
WSACleanup ();
return 0;
}
////////////////////send.c/////////////////////////////////////////////////////////receive.c////////////////////////////
//#include <windows.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#include <stdio.h>#define BUFFSIZE 2048
#define RECV_IP_ADDR "224.8.8.1"
#define DEST_PORT 8888int main(int argc,char *argv[])
{
int sockfd;
int sock_reuse = 1;
struct ip_mreq multicast;
struct sockaddr_in recver_addr;
char szError[100]; int index = 0, // Integer index
iRecvLen; // Length of recv_sin
char szMessageA[1024*320]; // ASCII string
TCHAR szMessageW[1024*320]; // Unicode string
WSADATA WSAData;
WORD wVersionRequested;
wVersionRequested = MAKEWORD(2, 2);
if (WSAStartup (wVersionRequested , &WSAData) != 0)
{
printf ("recver:Initialize Winsock error!");
exit(1);
}
if (LOBYTE(WSAData.wVersion) != 2 || HIBYTE(WSAData.wVersion) != 2 ) {
WSACleanup( );
printf ("setsockopt failed! Error: %d", WSAGetLastError ());
exit(1);
} multicast.imr_multiaddr.s_addr = inet_addr(RECV_IP_ADDR);
multicast.imr_interface.s_addr = htonl(INADDR_ANY);
recver_addr.sin_family = AF_INET;
recver_addr.sin_port = htons(DEST_PORT);
recver_addr.sin_addr.s_addr = INADDR_ANY;
if ((sockfd=socket(AF_INET,SOCK_DGRAM,0)) < 0) {
printf("recver:new a socket error!\n");
exit(1);
}
if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (char *)&sock_reuse, sizeof(sock_reuse)) < 0) {
printf("recver : socket options set error");
exit(1);
} if (bind(sockfd,(struct sockaddr *)&recver_addr,sizeof(recver_addr)) < 0) {
closesocket(sockfd);
printf("recver:bind socket error!\n");
exit(1);
}
if (setsockopt(sockfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,(char *)&multicast,sizeof(multicast)) < 0 ) {
sprintf (szError, TEXT("setsockopt failed! Error: %d"), WSAGetLastError ());
printf("%s\n", szError);
closesocket(sockfd);
exit(1);
} printf("Receive on %s:%d\n", RECV_IP_ADDR, DEST_PORT);
iRecvLen = sizeof (recver_addr);
memset(szMessageA, 0, sizeof(szMessageA));
// Receive data from the multicasting group server.
if (recvfrom (sockfd,
szMessageA,
sizeof(szMessageA),
0,
(struct sockaddr FAR *) &recver_addr,
&iRecvLen) == SOCKET_ERROR)
{
wsprintf (szError, TEXT("recvfrom failed! Error: %d"),
WSAGetLastError ());
MessageBox (NULL, szError, TEXT("Error"), MB_OK);
closesocket (sockfd);
return FALSE;
}
else
{
// Convert the ASCII string to a Unicode string.
for (index = 0; index <= sizeof (szMessageA); index++)
szMessageW[index] = szMessageA[index]; MessageBox (NULL, szMessageW, TEXT("Info"), MB_OK);
} // Disable receiving on Sock before closing it.
shutdown (sockfd, 0x00); // Close Sock.
closesocket (sockfd); WSACleanup ();
return 0;
}
/////////////////////////////receive.c////////////////////////////