TCP网络连接及mysql数据库数据处理

【实例截图】

【核心代码】

// CtcpserverDlg 消息处理程序

BOOL CtcpserverDlg::OnInitDialog()
{
CDialogEx::OnInitDialog();

// 将“关于...”菜单项添加到系统菜单中。

// IDM_ABOUTBOX 必须在系统命令范围内。
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000);

CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
BOOL bNameValid;
CString strAboutMenu;
bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
ASSERT(bNameValid);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
}

// 设置此对话框的图标。  当应用程序主窗口不是对话框时，框架将自动
//  执行此操作
SetIcon(m_hIcon, TRUE); // 设置大图标
SetIcon(m_hIcon, FALSE); // 设置小图标

// TODO: 在此添加额外的初始化代码
//1.初始化网络套接字的库，前面已经勾选，已经自动初始化了。
//2.创建套接字
s1 = socket(AF_INET, SOCK_STREAM, 0);
//3.处理地址
addr.sin_family = AF_INET;
addr.sin_port = htons(10001);//监听端口
addr.sin_addr.S_un.S_addr = INADDR_ANY;
//4.绑定端口和IP
bind(s1, (sockaddr *)&addr, sizeof(addr));
listen(s1,5);
//设置套接字为异步套接字
WSAAsyncSelect(s1,this->m_hWnd,WM_SOCKET,FD_ACCEPT | FD_READ);
//修改监听状态



//把接收设置为不能修改
GetDlgItem(IDC_STATIC_ADDRESS)->SetWindowTextA("服务器监听已经启动");


return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}

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

// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。

void CtcpserverDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // 用于绘制的设备上下文

SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);

// 使图标在工作区矩形中居中
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;

// 绘制图标
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialogEx::OnPaint();
}
}

//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CtcpserverDlg::OnQueryDragIcon()
{
return static_cast<HCURSOR>(m_hIcon);
}



afx_msg LRESULT CtcpserverDlg::OnSocket(WPARAM wParam, LPARAM lParam)
{

//异步套接字
CString str = "";
char cs[100] = "";
switch (lParam)
{
case FD_ACCEPT:
{
int length = sizeof(clientaddr);
s2 = accept(s1, (sockaddr*)&clientaddr, &length);
clientnumber = clientnumber 1;
str.Format("有 %d 个客户端已经连接上了", clientnumber);
str = inet_ntoa(clientaddr.sin_addr);
str = "\r\n登陆\r\n";
GetDlgItem(IDC_EDIT_RECEIVE)->SetWindowTextA(str);
}
break;
case FD_READ:
{
CString num = "";
recv(s2,cs,100,0);
GetDlgItem(IDC_EDIT_RECEIVE)->GetWindowTextA(num);
num = "\r\n";
num = "客户端";
num = (LPTSTR)cs;
GetDlgItem(IDC_EDIT_RECEIVE)->SetWindowTextA(num);
}
break;
}

return 0;
}


void CtcpserverDlg::OnBnClickedButtonSend()
{
// TODO: 在此添加控件通知处理程序代码
CString str = "";
GetDlgItem(IDC_EDIT_SEND)->GetWindowTextA(str);
if (str == "")
{
MessageBox("消息不能为空!");
}
else
{
char sendstr[20] = {0,1,2,3,4,5,6,7,8,9,0x0a,0x0b};//测试报文
const char *consendstr= nullptr;
consendstr = sendstr;
if (send(s2, consendstr, 15, 0) != SOCKET_ERROR)//send(s2, str.GetBuffer(1), str.GetLength(), 0)
{
GetDlgItem(IDC_EDIT_RECEIVE)->GetWindowTextA(str);
str = "发送成功！\r\n";
GetDlgItem(IDC_EDIT_RECEIVE)->SetWindowTextA(str);
}
else
{
GetDlgItem(IDC_EDIT_RECEIVE)->SetWindowTextA("消息发送失败！");
}
}
}