TCP流式套接字的编程步骤:
服务器端程序:
1、加载套接字库
2、创建套接字(socket)。
3、将套接字绑定到一个本地地址和端口上(bind)。
4、将套接字设为监听模式,准备接收客户请求(listen)。
5、等待客户请求到来;当请求到来后,接受连接请求,返回一个新的对应于此次连接的套接字(accept)。
6、用返回的套接字和客户端进行通信(send/recv)。
7、返回,等待另一客户请求。
8、关闭套接字。
客户端程序:
1、加载套接字库
2、创建套接字(socket)。
3、向服务器发出连接请求(connect)。
4、和服务器端进行通信(send/recv)。
5、关闭套接字。
以上是Socket网络编程基本步骤,必须熟知!
更多linux服务器开发高阶知识Linux,Nginx,ZeroMQ,MySQL,redis,fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK等等学习资料请后台私信【学习资料】获取
下面就讲讲如何在MFC中进行Socket 编程。
首先新建一个基于对话框的工程取名为sFile,此工程作为服务器端。删除对话框中的中间代码和OK按钮。在新建的对话框中添加一个List Box控件作为显示窗口,并添加一个Edit control控件作为输入窗口,然后增加一个发送按钮:IDC_BtnSend。在List Box控件上右键点击选择——添加变量,将变量定义为控件类型并取名为m_listwords。
然后再建一个客户端对话框取名为cFile,删除对话框中的中间代码和OK按钮。在新建的对话框中添加一个List Box控件作为显示窗口,并添加一个Edit control控件作为输入窗口,然后增加两个按钮:一个为发送按钮IDC_BtnSend,另一个为连接按钮IDC_BtnConnect。在List Box控件上右键点击选择——添加变量,将变量定义为控件类型并取名为m_listwords。另外需要添加一个IP Adress control控件,然后按添加变量的方法将其关联为控件类型,并取名为m_ip。
服务器端具体步骤如下:
1、 在sFileDlg.h中添加public:void update(CString s);
private: CEdit* send_edit;
void CString2Char(CString str, char ch[]); //此函数为字符格式转换函数,后面会讲到
2、 新建两个socket套接字: SOCKET listen_sock;
SOCKET sock;
在sFileDlg.h中添加 CString IP; //定义为全局变量
并声明线程函数 UINT server_thd(LPVOID p);
3、在OnInitDialog()函数中添加:
send_edit = (CEdit *)GetDlgItem(IDC_EDIT1);
send_edit->SetFocus();
char name[128];
hostent* pHost;
gethostname(name, 128);//获得主机名
pHost = gethostbyname(name);//获得主机结构
IP = inet_ntoa(*(in_addr *)pHost->h_addr);
update(_T("本服务器IP地址:") + IP);
AfxBeginThread(server_thd, NULL);//创建线程
4、添加函数update():
void CSFileDlg::update(CString s)
{
m_listwords.AddString(s);
}
5、添加线程函数server_thd():
UINT server_thd(LPVOID p)//线程要调用的函数
{
WSADATA wsaData;
WORD wVersion;
wVersion = MAKEWORD(2, 2);
WSAStartup(wVersion, &wsaData);
// WSAStartup(0x0202, &wsaData);
SOCKADDR_IN local_addr;
SOCKADDR_IN client_addr;
int iaddrSize = sizeof(SOCKADDR_IN);
int res;
char msg[1024];
CsFileDlg * dlg = (CsFileDlg *)AfxGetApp()->GetMainWnd();
char ch_ip[20];
CString2Char(IP, ch_ip);//注意!这里调用了字符格式转换函数,此函数功能:CString类型转换为Char类型,实现代码在后面添加
//local_addr.sin_addr.s_addr = htonl(INADDR_ANY);//获取任意IP地址
local_addr.sin_addr.s_addr=inet_addr(ch_ip);
local_addr.sin_family = AF_INET;
local_addr.sin_port = htons(8888);
if ((listen_sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == INVALID_SOCKET)//创建套接字
{
dlg->update(_T("创建监听失败"));
}
if (bind(listen_sock, (struct sockaddr*) &local_addr, sizeof(SOCKADDR_IN)))//绑定套接字
{
dlg->update(_T("绑定错误"));
}
listen(listen_sock, 1);
if ((sock = accept(listen_sock, (struct sockaddr *)&client_addr, &iaddrSize)) == INVALID_SOCKET)//接收套接字
{
dlg->update(_T("accept 失败"));
}
else
{
CString port;
port.Format(_T("%d"), int(ntohs(client_addr.sin_port)));
dlg->update(_T("已连接客户端:") + CString(inet_ntoa(client_addr.sin_addr)) + " 端口:" + port);
}
////////////接收数据
while (1)
{
if ((res = recv(sock, msg, 1024, 0)) == -1)
{
dlg->update(_T("失去客户端的连接"));
break;
}
else
{
msg[res] = '