freesenderdlg.cpp

基于IP UDP协议的sock编程,网络编程应用。

// FreeSenderDlg.cpp : implementation file
//

#include "stdafx.h"
#include "FreeSender.h"
#include "FreeSenderDlg.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
/////////////////////////////////////////////////////////////////////////////
CString	m_from;//
CString	m_to;
CString	m_msg;
byte f1,f2,f3,f4,t1,t2,t3,t4;
//****************************************************************
#pragma comment( lib, "ws2_32.lib" ) /*这句不能少。*/

// Packet format found thanks to a bit a sniffing
static unsigned char packet_header[] =
"\x04\x00\x28\x00"
"\x10\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00"
"\x00\x00\x00\x00\xf8\x91\x7b\x5a\x00\xff\xd0\x11\xa9\xb2\x00\xc0"
"\x4f\xb6\xe6\xfc"
"\xff\xff\xff\xff" // @40 : unique id over 16 bytes ?
"\xff\xff\xff\xff"
"\xff\xff\xff\xff"
"\xff\xff\xff\xff"
"\x00\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00"
"\x00\x00\xff\xff\xff\xff"
"\xff\xff\xff\xff" // @74 : fields length
"\x00\x00";

unsigned char field_header[] =
"\xff\xff\xff\xff" // @0 : field length
"\x00\x00\x00\x00"
"\xff\xff\xff\xff"; // @8 : field length

//打包发送函数，单ip可调用之。
int sd(unsigned long ip,CString from="a",CString machine="b",CString msg="c")
{
        int i, packet_size, fields_size, s;
        char packet[8192];
		struct	sockaddr_in addr;
	    WSADATA wsaData;
		WSAStartup(0x0202, &wsaData);
    	ZeroMemory(&addr, sizeof(addr));
		addr.sin_addr.s_addr = ip;
		addr.sin_port = htons(135);
        addr.sin_family = AF_INET;
		ZeroMemory(packet, sizeof(packet));
        packet_size = 0;
        memcpy(&packet[packet_size], packet_header, 80);
        packet_size += 80;
        i = from.GetLength()+1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size += 12;
        strcpy(&packet[packet_size], from);
        packet_size += (((i - 1) >> 2) + 1) << 2; // padded to a multiple of 4
        i = machine.GetLength() + 1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size +=12;
        strcpy(&packet[packet_size], machine);
        packet_size += (((i - 1) >> 2) + 1) << 2; // padded to a multiple of 4
		i = msg.GetLength() + 1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size += 12;
        strcpy(&packet[packet_size], msg);
        packet_size += i;
        fields_size = packet_size - 80;
        *(unsigned int *)(&packet[40]) = time(NULL);
        *(unsigned int *)(&packet[74]) = fields_size;
		if ((s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)
              return 0;
        if (sendto(s, packet, packet_size, 0, (struct sockaddr *)&addr, sizeof(addr)) == -1)
             return 0;
     
return 1;
}

//消息群发，发送线程
UINT Send(LPVOID mpPara)
{
		CString str;
		long int ip;
		int i, packet_size, fields_size, s;
        char packet[8192];
		struct	sockaddr_in addr;
	    WSADATA wsaData;
		ZeroMemory(packet, sizeof(packet));
        packet_size = 0;
        memcpy(&packet[packet_size], packet_header, 80);
        packet_size += 80;
        i = m_from.GetLength()+1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size += 12;
        strcpy(&packet[packet_size], m_from);
        packet_size += (((i - 1) >> 2) + 1) << 2; // padded to a multiple of 4
        i = m_to.GetLength() + 1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size +=12;
        strcpy(&packet[packet_size], m_to);
        packet_size += (((i - 1) >> 2) + 1) << 2; // padded to a multiple of 4
		i = m_msg.GetLength() + 1;
        *(unsigned int *)(&field_header[0]) = i;
        *(unsigned int *)(&field_header[8]) = i;
        memcpy(&packet[packet_size], field_header, 12);
        packet_size += 12;
        strcpy(&packet[packet_size], m_msg);
        packet_size += i;
        fields_size = packet_size - 80;
        *(unsigned int *)(&packet[40]) = time(NULL);
        *(unsigned int *)(&packet[74]) = fields_size;
		
		for(int l=f1;l<=t1;l++)
			for(int j=f2;j<=t2;j++)
				for(int m=f3;m<=t3;m++)
					for(int n=f4;n<=t4;n++)
					{
						str.Format("%d.%d.%d.%d",l,j,m,n);
						ip=inet_addr(str);
						WSAStartup(0x0202, &wsaData);
						ZeroMemory(&addr, sizeof(addr));
						addr.sin_addr.s_addr = ip;
						addr.sin_port = htons(135);
						addr.sin_family = AF_INET;
						if ((s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)
						{	
							AfxMessageBox("create socket error!");
							continue;
						}
						if(sendto(s, packet, packet_size, 0, (struct sockaddr *)&addr, sizeof(addr)) == -1)
						{	
							AfxMessageBox("send failed!");
							continue;
						}
						
					}
	return 1;
}
//****************************************************************
// CAboutDlg dialog used for App About
class CAboutDlg : public CDialog
{
public:
	CAboutDlg();

// Dialog Data
	//{{AFX_DATA(CAboutDlg)
	enum { IDD = IDD_ABOUTBOX };
	//}}AFX_DATA

	// ClassWizard generated virtual function overrides
	//{{AFX_VIRTUAL(CAboutDlg)
	protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support
	//}}AFX_VIRTUAL

// Implementation
protected:
	//{{AFX_MSG(CAboutDlg)
	//}}AFX_MSG
	DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
	//{{AFX_DATA_INIT(CAboutDlg)
	//}}AFX_DATA_INIT
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CAboutDlg)
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
	//{{AFX_MSG_MAP(CAboutDlg)
		// No message handlers
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CFreeSenderDlg dialog

CFreeSenderDlg::CFreeSenderDlg(CWnd* pParent /*=NULL*/)
	: CDialog(CFreeSenderDlg::IDD, pParent)
{
	//{{AFX_DATA_INIT(CFreeSenderDlg)
	m_from = _T("USTC");
	m_to = _T("USTC");
	m_msg = _T("");
	//}}AFX_DATA_INIT
	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}

void CFreeSenderDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CFreeSenderDlg)
	DDX_Control(pDX, IDC_IPADDRESS2, m_ip2);
	DDX_Control(pDX, IDC_IPADDRESS1, m_ip1);
	DDX_Control(pDX, IDC_LIST1, m_list);
	DDX_Text(pDX, IDC_EDIT1, m_from);
	DDX_Text(pDX, IDC_EDIT2, m_to);
	DDX_Text(pDX, IDC_EDIT3, m_msg);
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CFreeSenderDlg, CDialog)
	//{{AFX_MSG_MAP(CFreeSenderDlg)
	ON_WM_SYSCOMMAND()
	ON_WM_PAINT()
	ON_WM_QUERYDRAGICON()
	ON_BN_CLICKED(IDC_SEND, OnSend)
	ON_BN_CLICKED(IDC_OPENFILE, OnOpenfile)
	ON_EN_CHANGE(IDC_EDIT3, OnChangeEdit3)
	ON_BN_CLICKED(IDC_ADD, OnAdd)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CFreeSenderDlg message handlers

BOOL CFreeSenderDlg::OnInitDialog()
{
	CDialog::OnInitDialog();
	// Add "About..." menu item to system menu.
	// IDM_ABOUTBOX must be in the system command range.
	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
	ASSERT(IDM_ABOUTBOX < 0xF000);
	CMenu* pSysMenu = GetSystemMenu(FALSE);
	if (pSysMenu != NULL)
	{
		CString strAboutMenu;
		strAboutMenu.LoadString(IDS_ABOUTBOX);
		if (!strAboutMenu.IsEmpty())
		{
			pSysMenu->AppendMenu(MF_SEPARATOR);
			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
		}
	}
	SetIcon(m_hIcon, TRUE);			// Set big icon
	SetIcon(m_hIcon, FALSE);		// Set small icon
	// TODO: Add extra initialization here
	//--------------------------------------------------------
	m_ip1.SetAddress(192,168,0,1);//初始化起始ip
	m_ip2.SetAddress(192,168,0,254);//初始化结束ip
	//--------------------------------------------------------
	//--------------------------------------------------------
	return TRUE;  // return TRUE  unless you set the focus to a control
}

void CFreeSenderDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
	{
		CAboutDlg dlgAbout;
		dlgAbout.DoModal();
	}
	else
	{
		CDialog::OnSysCommand(nID, lParam);
	}
}

// If you add a minimize button to your dialog, you will need the code below
//  to draw the icon.  For MFC applications using the document/view model,
//  this is automatically done for you by the framework.

void CFreeSenderDlg::OnPaint() 
{
	if (IsIconic())
	{
		CPaintDC dc(this); // device context for painting
		SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
		// Center icon in client rectangle
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;
		// Draw the icon
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialog::OnPaint();
	}
}

HCURSOR CFreeSenderDlg::OnQueryDragIcon()
{
	return (HCURSOR) m_hIcon;
}

void CFreeSenderDlg::OnSend() 
{
	UpdateData(1);//控件－>变量 数据交换。
	m_ip1.GetAddress(f1,f2,f3,f4);//取得起始ip
	m_ip2.GetAddress(t1,t2,t3,t4);//取得结束ip
	AfxBeginThread(Send,this);	//启动群发线程

}

void CFreeSenderDlg::OnOK() 
{
	

}

void CFreeSenderDlg::OnCancel() 
{
	
	CDialog::OnCancel();
}

void CFreeSenderDlg::OnOpenfile() 
{
	CFileDialog dlg(TRUE,"txt","*.txt");
	if(dlg.DoModal()!=IDOK)   //打开文件公用对话框
	{
		return;
	}	
	else
	{	byte buf[2];
		m_msg="";
		CString file=dlg.GetPathName();	//取得文件对话框返回的文件绝对路径
		
		CFile f;
		f.Open(file,CFile::modeRead);
		int filesize=f.GetLength();//用CFile方式获取取得文件大小；
		f.Close();
		
		FILE *rd;
		rd=fopen(file,"r+b");//用文件流 二进制读方式打开
		for(int i=0;i<filesize;i++)
		{fread(buf,1,1,rd);
		 m_msg+=buf[0];	//将文本读到EDIT控件对应的变量中。
		}
		fclose(rd);
		UpdateData(0);//变量－>控件 数据交换。
	}

}

void CFreeSenderDlg::OnChangeEdit3() 
{
	
	
}

void CFreeSenderDlg::OnAdd() 
{
	UpdateData(1);
	m_ip1.GetAddress(f1,f2,f3,f4);
	m_ip2.GetAddress(t1,t2,t3,t4);


}