在C++ Builder中用socket api来写网络通讯程序(同时支持TCP和UDP协议)
原文: http://www.csdn.net/develop/read_article.asp?id=19883
在7月4日看完sockcomp.pas后,我决定用socket api来写一个客户端和服务器并且同时支持TCP,UDP协议,于是我就去做,现将代码贴出来(已调试通过)
Socket api Client:
#ifndef UDPClientH
#define UDPClientH
#include <Classes.hpp>
#include <Controls.hpp>
#include <StdCtrls.hpp>
#include <Forms.hpp>
#include <stdio.h>
#include "CCEdit.h"
#define WM_SOCK WM_USER+100
class TLANForm : public TForm
{
__published: // IDE-managed Components
TEdit *Port;
TLabel *Label1;
TLabel *Label2;
TComboBox *Prot;
TButton *Button1;
TLabel *Label3;
TEdit *Addr;
TCCEdit *TxtEdit;
void __fastcall FormCreate(TObject *Sender);
void __fastcall Button1Click(TObject *Sender);
void __fastcall FormDestroy(TObject *Sender);
private: // User declarations
void __fastcall OnRecv(TMessage &Message);
public: // User declarations
__fastcall TLANForm(TComponent* Owner);
BEGIN_MESSAGE_MAP //建立消息映射表
VCL_MESSAGE_HANDLER(WM_SOCK,TMessage,OnRecv);//指定消息处理函数
END_MESSAGE_MAP(TForm);//映射表结束
};
extern PACKAGE TLANForm *LANForm;
#endif
.cpp File
#include <vcl.h>
#pragma hdrstop
#include "UDPClient.h"
#include "WinSock.h"
#pragma package(smart_init)
#pragma link "CCEdit"
#pragma resource "*.dfm"
TLANForm *LANForm;
enum PROTO {TCP=0,UDP=1};//枚举,socket协议类型
SOCKET m_Socket=INVALID_SOCKET; //定义一个socket对象
PROTO m_Protocol=TCP; //socket类型变量
__fastcall TLANForm::TLANForm(TComponent* Owner)
: TForm(Owner)
{
}
void __fastcall TLANForm::FormCreate(TObject *Sender)
{
::SendMessage(Prot->Handle,CB_SETCURSEL,0,0);
}
void __fastcall TLANForm::OnRecv(TMessage &Message)
{
char buf[4096];
int nLen;
struct sockaddr_in from;
int nLength=sizeof(struct sockaddr_in);//结构长度
switch(WSAGETSELECTEVENT(Message.LParam))
{
case FD_READ://收到消息
switch(m_Protocol)
{
case TCP:
nLen=recv(m_Socket,buf,4096,0);//接收
if(nLen>0){
buf[nLen]='\0';
TxtEdit->Text="Received Length:"+String(nLen)+"\r\n"+StrPas(buf);
}
break;
case UDP:
nLen=recvfrom(m_Socket,buf,4096,0,(struct sockaddr*)&from,&nLength);
if(nLen>0){
buf[nLen]='\0';
TxtEdit->Text="Received Length:"+String(nLen)+"\r\n"+StrPas(buf);
}
break;
}
break;
case FD_CLOSE://关闭连接消息
closesocket(m_Socket);
break;
}
}
void __fastcall TLANForm::Button1Click(TObject *Sender)
{
char szTmp[256],buf[4096];
int nSize=0;
UINT m_Port;
AnsiString addr;
addr=Addr->Text.Trim();
if(addr.IsEmpty()){//IP为空结束
::MessageBox(0,"Please enter the server IP!","Error",MB_OK+MB_ICONERROR);
return;
}
unsigned long nAddr=inet_addr(addr.c_str());
if(nAddr==INADDR_NONE){//IP地址无效
::MessageBox(0,"Bad Internet IP!","Error",MB_OK+MB_ICONERROR);
return;}
try
{
m_Port=Port->Text.ToInt();//得到端口
}
catch(Exception &e)
{
::MessageBox(0,e.Message.c_str(),"Error",MB_OK+MB_ICONERROR);
return;
}
switch(Prot->ItemIndex)//得到协议类型
{
case 0:
m_Protocol=TCP;
break;
case 1:
m_Protocol=UDP;
break;
}
if(TxtEdit->Text.IsEmpty()){//发送内容
::MessageBox(0,"Please enter the text you want to send!","Error",MB_OK+MB_ICONERROR);
return;}
//1.初始化Winsock
WSAData wsaData;
::ZeroMemory(&wsaData,sizeof(WSAData)); //0填充
WORD version=MAKEWORD(2,0);
if(::WSAStartup(version,&wsaData)){ //初始化
sprintf(szTmp,"Failed to initial winsock enviroment!,error no:%d",::WSAGetLastError());
return;}
//Obtain the active connection
char ComputerName[255];
gethostname(ComputerName,255);
struct hostent* he=gethostbyname(ComputerName);
if(!he){
sprintf(szTmp,"Failed to get information to host!","Error",MB_OK+MB_ICONERROR);
::WSACleanup();
return;
}
//2.建立新socket
m_Socket=INVALID_SOCKET;
switch(m_Protocol)
{
case TCP:
m_Socket=socket(AF_INET,SOCK_STREAM,0);
break;
case UDP:
m_Socket=socket(AF_INET,SOCK_DGRAM,0);
break;
}
if(m_Socket==INVALID_SOCKET){//建立socket失败
sprintf(szTmp,"Failed to create a new socket!,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
::WSACleanup();
return;
}
//3.绑定SOCKET
struct sockaddr_in client;
unsigned long nClient;
memcpy(&nClient,he->h_addr_list[0],sizeof(int));
if(nClient==INADDR_NONE){
sprintf(szTmp,"Failed to obtain the local machine's IP!","Error",MB_OK+MB_ICONERROR);
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
closesocket(m_Socket);
::WSACleanup();
return;
}
client.sin_family=AF_INET;
client.sin_port=0;
client.sin_addr.S_un.S_addr=(int)nClient;
if(bind(m_Socket,(struct sockaddr*)&client,sizeof(struct sockaddr))){
sprintf(szTmp,"Failed to bind socket!","Error",MB_OK+MB_ICONERROR);
closesocket(m_Socket);
::WSACleanup();
return;}
struct sockaddr_in To;
To.sin_family=AF_INET;
To.sin_port=htons(m_Port);
To.sin_addr.S_un.S_addr=(int)nAddr;
fd_set FDSET;
FD_ZERO(&FDSET);
FD_SET(m_Socket,&FDSET);
//4.连接远程主机
if(m_Protocol==TCP){
if(connect(m_Socket,(struct sockaddr*)&To,sizeof(struct sockaddr))){
sprintf(szTmp,"Failed to connect the object!,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
closesocket(m_Socket);
::WSACleanup();
return;
}
int nError=select(1,0,&FDSET,0,0);
if(nError<=0){
sprintf(szTmp,"Failed to select socket!,error no:%d",::WSAGetLastError());
closesocket(m_Socket);
::WSACleanup();
return;}
}
//5.发送数据
int nLen=TxtEdit->Text.Length();
if(nLen>4096){
sprintf(szTmp,"The buffer is too size to send,it shoud not be more than 4096 bytes!");
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
closesocket(m_Socket);
::WSACleanup();
return;
}
strncpy(buf,TxtEdit->Text.c_str(),nLen);
switch(m_Protocol)
{
case TCP:
nSize=send(m_Socket,buf,nLen,0);
//ShowMessage(nSize);
break;
case UDP:
nSize=sendto(m_Socket,buf,nLen,0,(struct sockaddr*)&To,sizeof(struct sockaddr));
//ShowMessage(nSize);
break;
}
if(::WSAAsyncSelect(m_Socket,Handle,WM_SOCK,FD_READ|FD_CLOSE)){
sprintf(szTmp,"Failed to register socket event!,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
closesocket(m_Socket);
::WSACleanup();
return;}
}
void __fastcall TLANForm::FormDestroy(TObject *Sender)//断开连接
{
closesocket(m_Socket);
::WSACleanup();
}
Socket api Server:
.h File
#ifndef UDPServerH
#define UDPServerH
#include <Classes.hpp>
#include <Controls.hpp>
#include <StdCtrls.hpp>
#include <Forms.hpp>
#include <stdio.h>
#include "WinSock.h"
/*#define WM_SOCKET WM_USER+1000
#define INITSOCKETSUCCESS 0
#define INITSOCKETFAILURE 1
#define CREATELISTENSOCKETSUCCESS 2
#define CREATELISTENSOCKETFAILURE 3
#define SETLISTENSOCKETSUCCESS 4
#define SETLISTENSOCKETFAILURE 5
#define BINDLISTENSOCKETSUCCESS 6
#define BINDLISTENSOCKETFAILURE 7
#define LISTENSOCKETSUCCESS 8
#define LISTENSOCKETFAILURE 9
#define ACCEPTSOCKETSUCCESS 10
#define ACCEPTSOCKETFAILURE 11
*/
class TPSTNForm : public TForm
{
__published: // IDE-managed Components
TEdit *Port;
TLabel *Label1;
TMemo *Memo1;
TButton *Button1;
TButton *Button2;
TLabel *Label2;
TComboBox *Prot;
void __fastcall Button1Click(TObject *Sender);
void __fastcall Button2Click(TObject *Sender);
void __fastcall FormCreate(TObject *Sender);
void __fastcall FormDestroy(TObject *Sender);
private: // User declarations
public: // User declarations
__fastcall TPSTNForm(TComponent* Owner);
};
enum PROTO {TCP,UDP};
class TCommunication:public TThread //Communication Thread
{
private:
SOCKET m_AcceptSocket;
char szTmp[256];//ERROR MESSAGE
public:
__fastcall TCommunication(SOCKET m_Socket,bool CreateSuspended);
__fastcall ~TCommunication();
protected:
virtual void __fastcall Execute();
};
class TListenThread:public TThread //Listen Thread
{
private:
WSAData wsaData;
struct sockaddr_in server;
fd_set FDS;
UINT m_Port;
PROTO m_Protocol;
char szTmp[256];//Error Message
public:
SOCKET m_Socket;
void __fastcall DoError();
void __fastcall InitSocket();
void __fastcall CreateListenSocket();
void __fastcall SetListenSocket();
void __fastcall BindListenSocket();
void __fastcall ListenSocket();
public:
__fastcall TListenThread(PROTO m_ProtocolA,UINT m_PortA,bool CreateSuspended);
virtual __fastcall ~TListenThread();
protected:
virtual void __fastcall Execute();
};
extern PACKAGE TPSTNForm *PSTNForm;
#endif
.cpp File
#include <vcl.h>
#pragma hdrstop
#include "UDPServer.h"
#pragma package(smart_init)
#pragma resource "*.dfm"
TPSTNForm *PSTNForm;
TListenThread *pThread=0;
//******************************CLASS TCommunication For TCP****************************************************
__fastcall TCommunication::TCommunication(SOCKET m_Socket,bool CreateSuspended):TThread(FALSE)
{
m_AcceptSocket=m_Socket;
szTmp[0]='\0';
FreeOnTerminate=true;
}
__fastcall TCommunication::~TCommunication()
{
// closesocket(m_AcceptSocket);
}
void __fastcall TCommunication::Execute()
{
char buf[4096];
int nSize=0;
nSize=recv(m_AcceptSocket,(char FAR*)buf,4096,0);
if(nSize>0)
{
buf[nSize]='\0';
//Display
PSTNForm->Memo1->Lines->Add("Received Length:"+String(nSize));
PSTNForm->Memo1->Lines->Add("Received:"+StrPas(buf));
//Deliver
::Sleep(100);
send(m_AcceptSocket,buf,nSize,0);
}
}
//******************************CLASS TListenThread*****************************************************
__fastcall TListenThread::TListenThread(PROTO m_ProtocolA,UINT m_PortA,bool CreateSuspended):TThread(FALSE)
{
m_Socket=INVALID_SOCKET;
m_Port=m_PortA;
m_Protocol=m_ProtocolA;
szTmp[0]='\0';
::ZeroMemory(&wsaData,sizeof(WSAData));
::ZeroMemory(&server,sizeof(struct sockaddr_in));
FreeOnTerminate=TRUE;//Automatically delete while terminating.
}
__fastcall TListenThread::~TListenThread()
{
closesocket(m_Socket);
::WSACleanup();
m_Socket=INVALID_SOCKET;
m_Port=0;
m_Protocol=TCP;
szTmp[0]='\0';
::ZeroMemory(&wsaData,sizeof(WSAData));
::ZeroMemory(&server,sizeof(struct sockaddr_in));
}
void __fastcall TListenThread::DoError()
{
if(m_Socket!=INVALID_SOCKET) closesocket(m_Socket);
WSACleanup();
return;
}
void __fastcall TListenThread::InitSocket()
{
WORD version=MAKEWORD(2,0);
if(::WSAStartup(version,&wsaData)){
sprintf(szTmp,"Failed to intiailize socket,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
return;
}
}
void __fastcall TListenThread::CreateListenSocket()
{
switch(m_Protocol)
{
case UDP:
m_Socket=socket(AF_INET,SOCK_DGRAM,0);
break;
case TCP:
m_Socket=socket(AF_INET,SOCK_STREAM,0);
break;
default:
sprintf(szTmp,"Error protocol!");
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
break;
}
if(m_Socket==INVALID_SOCKET){
sprintf(szTmp,"Failed to create socket!");
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
return;
}
}
void __fastcall TListenThread::SetListenSocket()
{
server.sin_family=AF_INET;
server.sin_port=htons(m_Port);
server.sin_addr.S_un.S_addr=INADDR_ANY;
int NewOpenType=SO_SYNCHRONOUS_NONALERT;
if(setsockopt(INVALID_SOCKET,SOL_SOCKET,SO_OPENTYPE,(char*)&NewOpenType,4)){
sprintf(szTmp,"Set socket option error,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
return;
}
}
void __fastcall TListenThread::BindListenSocket()
{
if(bind(m_Socket,(sockaddr*)&server,sizeof(struct sockaddr_in))){
sprintf(szTmp,"Failed to bind socket,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
return;
}
}
void __fastcall TListenThread::ListenSocket()
{
if(listen(m_Socket,SOMAXCONN)){
sprintf(szTmp,"listen error,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
return;
}
//Determine whether there is any connection
FD_ZERO(&FDS);
FD_SET(m_Socket,&FDS);
}
void __fastcall TListenThread::Execute()
{
char buf[4096];
struct sockaddr_in from; //for UDP
int nLen=sizeof(from),nSize=0; //for UDP
InitSocket();
CreateListenSocket();
SetListenSocket();
BindListenSocket();
if(m_Protocol==UDP){
while(!Terminated){
int nSize=recvfrom(m_Socket,buf,4096,0,(struct sockaddr*)&from,&nLen);
if(nSize>0){
buf[nSize]='\0';
PSTNForm->Memo1->Lines->Add("Received Length:"+String(nSize));
PSTNForm->Memo1->Lines->Add("Received:"+StrPas(buf));
::Sleep(100);
sendto(m_Socket,buf,nSize,0,(struct sockaddr*)&from,sizeof(struct sockaddr_in));
}
else return;
}
}
ListenSocket();
struct sockaddr_in client;
int nLength=sizeof(struct sockaddr_in);
while(!Terminated){
int nError=select(1,&FDS,0,0,0);
if(nError<=0) Terminate();
SOCKET m_AcceptSocket=accept(m_Socket,(struct sockaddr*)&client,&nLength);
if(m_AcceptSocket==INVALID_SOCKET){
sprintf(szTmp,"Failed to execute accept,error no:%d",::WSAGetLastError());
::MessageBox(0,szTmp,"Error",MB_OK+MB_ICONERROR);
DoError();
Terminate();
return;
}
TCommunication *pCThread=new TCommunication(m_AcceptSocket,FALSE);
pCThread->Terminate();
pCThread->WaitFor();
}
}
//************************PSTNForm*********************************************//
__fastcall TPSTNForm::TPSTNForm(TComponent* Owner)
: TForm(Owner)
{
}
void __fastcall TPSTNForm::Button1Click(TObject *Sender)
{
Close();
}
void __fastcall TPSTNForm::Button2Click(TObject *Sender)
{
if(pThread){
pThread->Suspend();
pThread->Terminate();
delete pThread;
pThread=0;
}
UINT m_Port;
try
{
m_Port=Port->Text.ToInt();
}
catch(Exception &e)
{
::MessageBox(0,e.Message.c_str(),"Error",MB_OK+MB_ICONERROR);
return;
}
PROTO m_Protocol;
switch(Prot->ItemIndex)
{
case 0:
m_Protocol=TCP;
break;
case 1:
m_Protocol=UDP;
break;
default:
break;
}
pThread=new TListenThread(m_Protocol,m_Port,FALSE);
//pThread->Terminate();
}
void __fastcall TPSTNForm::FormCreate(TObject *Sender)
{
::SendMessage(Prot->Handle,CB_SETCURSEL,0,1);
}
void __fastcall TPSTNForm::FormDestroy(TObject *Sender)
{
if(pThread){
pThread->Suspend();
pThread->Terminate();}
}
转载于:https://www.cnblogs.com/nemolog/archive/2005/10/29/264351.html
在C++ Builder中用socket api来写网络通讯程序(同时支持TCP和UDP协议)相关推荐
- TCP与UDP协议,socket套接字编程,通信相关操作
文章目录 TCP与UDP协议 TCP协议 ==三次握手== ==四次挥手== UDP协议 TCP与UDP的区别 应用层 socket套接字 代码优化 循环通信 半连接池 粘包问题 TCP与UDP协议 ...
- socket编程之二:两种链接类型tcp和udp
前面一篇文章说到了一些计算机网络的基础知识.引入了socket.从这节開始,就进入正题了. 一 概述 TCP:Transimission Control Protocol传输控制协议. UPD:Use ...
- android socket 发送byte_如何正确地创建和销毁网络通讯程序中的Socket类的对象实例...
软件项目实训及课程设计指导--如何正确地创建和销毁软件应用系统中网络通讯中的Socket类的对象实例 1.基于TCP/IP协议的Socket通信相关的基础知识 (1)TCP/IP(Transmissi ...
- udp协议没有粘包问题、基于socketserver实现并发的socket(基于tcp、udp协议)、基于udp协议的套接字、操作系统原理以及进程知识
基于udp协议的套接字通信服务端 from socket import *server=socket(AF_INET,SOCK_DGRAM) #数据报协议->udp server.bind((' ...
- Socket、TCP和UDP协议、端口含义
1.如何理解Socket 两台计算机相互通讯靠的就是Socket,类似于2个人通讯要靠电话,也就是说Socket就是程序之间的电话.Socket英文意思是孔.插座,作为进程通讯机制,取后一种意思,通常 ...
- TCP与UDP协议、socket套接字编程、通信相关操作(cs架构软件)、TCP黏包问题及解决思路
OSI七层协议 传输层 1.PORT协议:前面讲过 2.TCP协议与UDP协议:规定了数据传输所遵循的规则(数据传输能够遵循的协议有很多,TCP和UDP是较为常见的两个) TCP协议 基于TCP传输数 ...
- Node.js与网络:Node.js对TCP、UDP、Socket、HTTP等协议的实现和支持
转自:https://itbilu.com/nodejs/core/VkcdcFq9.html OSI七层模型是不同计算机或通信系统间互联的标准体系和框架,在OSI中包括一系列标准和协议,如:TCP/ ...
- 利用TCP和UDP协议,实现基于Socket的小聊天程序(初级版)
TCP TCP (Transmission Control Protocol)属于传输层协议.其中TCP提供IP环境下的数据可靠传输,它提供的服务包括数据流传送.可靠性.有效流控.全双工操作和多路复用 ...
- python编写爬虫的步骤-python学习: 写网络爬虫程序的三个难点
写爬虫,是一个非常考验综合实力的活儿.有时候,你轻而易举地就抓取到了想要的数据:有时候,你费尽心思却毫无所获. 好多Python爬虫的入门教程都是一行代码就把你骗上了"贼船",等上 ...
最新文章
- Python使用Redis实现IP代理池
- Stephen Wolfram专访Judea Pearl:从贝叶斯网络到元胞自动机
- python项目2019_2019 年 11 月精选 GitHub 上 几个牛逼 Python 的项目
- linux 自动备份脚本
- python的回溯信息_基于Python的回溯算法
- 1276: 求和游戏
- event auto模式的问题
- java fxml教程_JavaFX 初学入门(一):FXML嵌套与原始控件继承
- Java多线程学习三十八:你知道什么是 CAS 吗
- 伺服驱动器cn1引脚定义_英威腾伺服
- 进销存财务管理重要性
- 使用微 PE(U盘)安装 Windows 10 操作系统
- BuBu笔记——Mybatis入门(秃头BUBu的超详细备注,一定要看哦)
- SQL经典50查询语句案例_5(查询没学过“叶平”老师课的同学的学号、姓名)
- Spring Cloud Gateway 3.1.1基于redis实现动态路由和管理功能
- 用pageOffice插件实现 word文档在线填充指定数据
- 2018 Arab Collegiate Programming Contest (ACPC 2018) H - Hawawshi Decryption 数学 + BSGS
- 公司寄件管理平台必要性分析
- 四年级计算机下册word教学设计,小学教学四年级教案下册计算机教案-20210723143637.docx-原创力文档...
- 【分布式监控系统】第3章——监控客户端开发
热门文章
- SQL Server 数据库所有者
- centos下wget时提示unable to resolve host address ...
- FLASH开发[02]
- php使用supervisor管理进程脚本
- django2中关于时间处理策略
- Windows Azure Cloud Service (23) 使用Full IIS模式部署多站点和虚拟目录
- Rider EAP17带来了许多改进但缺乏.NET Core调试功能
- Spring @Aspect切面参数传递
- iOS动画:UIView动画和CALayer动画(CABasicAnimation、CAKeyframeAnimation的使用)
- MSP430G2553需要注意的一些参数