技术标签: 通讯 编程 socket sockets windows unix
图3 第二客户建立连接后的TCP服务器
图4 第二客户建立连接后的数据结构
服务器在指定的端口上监听,每当一个套接口接收到信息,都将会把接收到的信息发送给每一个Client 。其主要源程序如下:
int main(int argc,char **argv)
{
int i,maxi,maxfd,listenfd,connfd,sockfd;
int nready,client;
ssize_t n;
fd_set rset,allset;
char line[MAXLNE];
socklen_t clilen;
struct sockaddr_in cliaddr,servaddr;
const int on=1;
listenfd=Socket(AF_INET,SOCK_STREAM,0);
if(setsockopt (listenfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on))=-1); err_ret(″setsockopt error″);
bzero(&servaddr,sizeof(servaddr));
servaddr.sin_family =AF_INET;
servaddr.sin_addr.s_addr =htonl(INADDR_ANY);
servaddr.sin_port =htons(SERV_PORT);
Bind(listenfd,(SA*)&servaddr,sizeof(servaddr));
Listen(listenfd,LISTENQ);
maxfd =listenfd; //初始化
maxi = -1; //最大下标
for(i=0;i<FD_SETSIZE;i++)
client[i]=-1; //-1表示可用
FD_ZERO(&allset);
FD_SET(listenfd,&allset);
for(;;){
rset=allset; //结构赋值
nready=Select(maxfd+1,&rset,NULL,NULL,NULL);
if (FD_ISSET(listenfd,&rset)){ //有用户连接
clilen=sizeof(cliaddr);
connfd=Accept(listenfd,(SA*)&cliaddr,&clilen);
for(i=0;i<FD_SETSIZE;i++)
if(client[i]< 0 {
client[i]=connfd;//保存套接字
break;
}
if(i=FD_SETSIZE);
err_quit(″too many clients″);
FD_SET (connfd,&allset); //增加套接字到读描述字集
if(connfd>maxfd);
maxfd=connfd;
if(i>maxi);
maxi=i;
if(--nready<=0)
continue;
}
for (i=0;i<=maxi;i++){ //检查所有用户连接
if((sockfd=client[i])<0)
continue;
if(FD_ISSET(sockfd,&rset))
{
if((n=Readline(sockfd,line,MAXLINE))=0)
{ //用户关闭连接
Close(sockfd);
FD_CLR(sockfd,&allset);
client[i]=-1
}else
printf(″%s″,line);
Broadcast(client,maxi,line,n);
if (--nready<=0)
break;
}
}
}
}
//将聊天内容发送到所有已连接的用户
Broadcast(int client,int maxi,char*str,size_t n)
{
int i;
int sockfd;
for(i=0;i<maxi,i++){
if((sockfd=client[i])<0)
continue;
writen(sockfd,str,n);
}
}
2.客户端
为了实现非阻塞通信,利用异步选择函数 WSAAsynSelect() 将网络事件与 WinSock 消息联系起来,由该函数注册一些用户感兴趣的网络事件(如接收缓冲区满,允许发送数据,请求连接等)。当这些被注册的网络事件发生时,应用程序的相应函数将接收到有关消息。
应用程序在使用Windows Sockets DLL 之前必须先调用启动函数WSAStartup() ,该函数的功能有两点:一是由应用程序指定所要求Windows Sockets DLL 版本;二是获得系统 Windows Sockets DLL的一些技术细节。每一个WSAStartup()函数必须和一个WSACleanup()函数对应,当应用程序终止时,必须调用 WSACleanup()将自己从OLL 中注销。
客户端程序用 VC++6.0在Windows98 操作系统下设计,程序主框架由 AppWizard 生成,客户端核心代码在 CTalkDialog类中。只有一个 socket 变量m_hSocket 与服务端进行连接。连接建立好后,通过此 SOCKET发送和接收信息。
手工加入CTalkDialog::OnSockConnect() ,完成基本套接字编程,为客户程序申请一个套接字,并将该套接字与指定服务器绑定,然后向服务器发出连接请求,启动异步选择函数等待服务器的响应。
void CTalkDialog:″OnSockConnect()
{
struct sockaddr_in servaddr;
WSADATA wsaData;
if(WSAStartup(WINSOCK_VERSION,&wsaData));
{
MessageBox(″Could not load Windows Sockets DLL,″,NULL,MB_Ok);
return;
}
m_hSocket=socket(AF_INET,SOCK_STREAM,0);
memset(&servaddr,0,sizeof(servaddr));
servaddr.sin_family=AF_INET;
//m_iPort,m_csIP 为通过注册对话框返回的端口号和IP地址
servaddr.sin_port=htons(m_iport);
servaddr.sin_addr.S_un.S_addr=inet_addr(m_csIP);
if (connect(m_hSocket,(SA*)& servaddr,sizeof (servaddr))!=0){
AfxMessageBox(″连接服务器失败!″);
GetDlgItem(IDC_BUTTON_OUT)->EnableWindow(FALSE);
GetDlgItem(IDC_BUTTON_IN)->EnableWindowTRUE
GetDlgItem(IDC_EDIT-SEND)->EnableWindow(FALSE);
UpdateData(FALSE);
}
else{
GetDlgItem(IDC_BUTTON_IN)->EnableWindow(FALSE);
GetDlgItem(IDC_BUTTON_OUT)->EnableWindow(TRUE);
GetDlgItem(IDC_EDIT-SEND)->EnableWindow(TRUE);
int iErrorCode=WSAAsyncSelect(m_hSocket,m_hWnd,WM_SOCKET_READ, FD_READ);
if(iErrorCode=SOCKET_ERROR)
MessageBox(″WSAAsyncSelect failed on socket″,NULL,MB_OK);
}
} 手工加入CTalkDialog::OnSockRead(), 响应WinSock 发来的消息
LRESULT CTalkDialog::OnSockRead(WPARAM wParamLPARAM 1Param)
{
int iRead;
int iBufferLength;
int iEnd;
int iSpaceRemain;
char chIncomingData[100];
iBufferLength=iSpaceRemain=sizeof (chIncomingData);
iEnd=0;
iSpaceRemain-=iEnd;
iRead=recv(m_hSocket,(LPSTR)(chIncomingData+iEnd),iSpaceRemain,0);
iEnd+=iRead;
if (iRead=SOCKET_ERROR)
AfxMessageBox(″接收数据错误!″);
chIncomingData[iEnd]=‘/0’;
if(lstrlen(chIncomingData)!=0)
{
m_csRecv=m_csRecv+chIncomingData;
GetDlgItem(IDC_EDIT_RECV)->SetWindowText((LPCSTR)m_csRecv);
CEdit*pEdit;
pEdit=(CEdit*)GetDlgItem(IDC_EDIT_RECV);
int i=pEdit->GetLineCount();
pEdit->LineScroll(i,0);
}
return(OL);
}
手工加入CTalkDialog::OnSend(),将指定缓冲区中的数据发送出去。
void CTalkDialog::OnSend()
{
UpdateData();
m_csSend.TrimLeft();
m_csSend.TrimRight();
if(!m_csSend.IsEmpty())
{
m_csSend=m_csName+″:″+m_csSend+″/r/n″;
int nCharSend=send(m_hSocket,m_csSend,m_csSend.GetLength(),0);
if(nCharSend=SOCKET_ERROR)
MessageBox(″ 发送数据错误!″,NULL,MB_OK);
}
m_csSend=″″;
UpdateData(FALSE);
CWnd *pEdit=GetDlgItem(IDC_EDIT_SEND);
pEdit->SetFocus();
return;
}
通过ClassWizard 增加 virtual function PreTranslateMessage(), 控制当按回车键时调用OnSend(),而不是执行缺省按钮的动作。
BOOL CTalkDialog::PreTranslateMessage(MSG*pMsg)
{
if(pMsg-> message==WM_KEYDOWN && pMsg-> wParam=VK_RETURN){
OnSend();
}
return CDialog::PreTranslateMessage(pMsg);
}
为了简化设计,用户名在客户端控制,服务端只进行简单的接收信息和“广播”此信息,不进行名字校验,也就是说,可以有同名客户登录到服务端。这个程序设计虽然简单,但是已经具备了聊天室的最基本的功能。服务端程序在SCO OpenServer 5.0.5 下编译通过,客户端程序在VC++6.0 下编译通过,在使用TCP/IP 协议的局域网上运行良好。
上述实例仅用于说明通过 Socket 编程接口能方便地实现跨系统通讯,而这种跨系统通讯在金融行业中有着越来越广泛的应用,利用它可以实现各种多媒体查询,数据传输,网络通讯等功能。因此对跨系统通讯的探讨是非常必要和有意义的,希望上述探讨对大家能有所启发。
文章浏览阅读529次。百分百题库提供建筑八大员(材料员)考试试题、建筑八大员(材料员)考试预测题、建筑八大员(材料员)考试真题、建筑八大员(材料员)证考试题库等,提供在线做题刷题,在线模拟考试,助你考试轻松过关。310项目经理部应编制机械设备使用计划并报()审批。A监理单位B企业C建设单位D租赁单位答案:B311对技术开发、新技术和新工艺应用等情况进行的分析和评价属于()。A人力资源管理考核B材料管理考核C机械设备管理考核D技术管理考核答案:D312建筑垃圾和渣土._料账的试题
文章浏览阅读614次。本文由chatgpt生成,文章没有在chatgpt生成的基础上进行任何的修改。以上只是chatgpt能力的冰山一角。作为通用的Aigc大模型,只是展现它原本的实力。对于颠覆工作方式的ChatGPT,应该选择拥抱而不是抗拒,未来属于“会用”AI的人。AI职场汇报智能办公文案写作效率提升教程 专注于AI+职场+办公方向。下图是课程的整体大纲下图是AI职场汇报智能办公文案写作效率提升教程中用到的ai工具。_python自动打开浏览器
文章浏览阅读545次。Linux中安装JDK-RPM方式_linux 安装jdk rpm
文章浏览阅读25次。免费领取项目源码,请关注赞收藏并私信博主,谢谢-高校志愿者管理系统主要功能模块包括页、个人资料(个人信息。修改密码)、公共管理(轮播图、系统公告)、用户管理(管理员、志愿用户)、信息管理(志愿资讯、资讯分类)、活动分类、志愿活动、报名信息、活动心得、留言反馈,采取面对对象的开发模式进行软件的开发和硬体的架设,能很好的满足实际使用的需求,完善了对应的软体架设以及程序编码的工作,采取SQL Server 作为后台数据的主要存储单元,采用Asp.Net技术进行业务系统的编码及其开发,实现了本系统的全部功能。
文章浏览阅读122次。原标题:小米OV对于是否采用鸿蒙保持沉默,原因是中国制造需要它们目前华为已开始对鸿蒙系统大规模宣传,不过中国手机四强中的另外三家小米、OPPO、vivo对于是否采用鸿蒙系统保持沉默,甚至OPPO还因此而闹出了一些风波,对此柏铭科技认为这是因为中国制造当下需要小米OV几家继续将手机出口至海外市场。 2020年中国制造支持中国经济渡过了艰难的一年,这一年中国进出口贸易额保持稳步增长的势头,成为全球唯一..._小米宣布用鸿蒙系统
文章浏览阅读1.3k次。1.Kafka Eagle实现kafka消息监控的代码细节是什么?2.Kafka owner的组成规则是什么?3.怎样使用SQL进行kafka数据预览?4.Kafka Eagle是否支持多集群监控?1.概述在《Kafka 消息监控 - Kafka Eagle》一文中,简单的介绍了 Kafka Eagle这款监控工具的作用,截图预览,以及使用详情。今天_kafka eagle git
文章浏览阅读1.1k次,点赞29次,收藏19次。Eva.js 是一个专注于开发互动游戏项目的前端游戏引擎。:Eva.js 提供开箱即用的游戏组件供开发人员立即使用。是的,它简单而优雅!:Eva.js 由高效的运行时和渲染管道 (Pixi.JS) 提供支持,这使得释放设备的全部潜力成为可能。:得益于 ECS(实体-组件-系统)架构,你可以通过高度可定制的 API 扩展您的需求。唯一的限制是你的想象力!_eva.js
文章浏览阅读1k次。Objective-C概述Objective-C是一种面向对象的计算机语言,1980年代初布莱德.考斯特在其公司Stepstone发明Objective-C,该语言是基于SmallTalk-80。1988年NeXT公司发布了OC,他的开发环境和类库叫NEXTSTEP, 1994年NExt与Sun公司发布了标准的NEXTSTEP系统,取名openStep。1996_objective-c特点及应用领域
文章浏览阅读955次,点赞20次,收藏16次。TIM(Timer)定时器定时器可以对输入的时钟进行计数,并在计数值达到设定值时触发中断16位计数器、预分频器、自动重装寄存器的时基单元,在 72MHz 计数时钟下可以实现最大 59.65s 的定时,59.65s65536×65536×172MHz59.65s65536×65536×721MHz不仅具备基本的定时中断功能,而且还包含内外时钟源选择、输入捕获、输出比较、编码器接口、主从触发模式等多种功能。_stm32 tim寄存器详解
文章浏览阅读1.5k次。对于任何有兴趣学习前端 Web 开发的人来说,了解 HTML、CSS 和JavaScript 之间的区别至关重要。这三种前端语言都是您访问过的每个网站的用户界面构建块。而且,虽然每种语言都有不同的功能重点,但它们都可以共同创建令人兴奋的交互式网站,让用户保持参与。因此,您会发现学习所有三种语言都很重要。如果您有兴趣从事前端开发工作,可以通过多种方式学习这些语言——在艾编程就可以参与到学习当中来。在本文中,我们将回顾每种语言的特征、它们如何协同工作以及您可以在哪里学习它们。HTML vs C._艾编程学习资料
文章浏览阅读2.8k次。点云配准主要针对点云的:不完整、旋转错位、平移错位。因此要得到完整点云就需要对局部点云进行配准。为了得到被测物体的完整数据模型,需要确定一个合适的坐标系变换,将从各个视角得到的点集合并到一个统一的坐标系下形成一个完整的数据点云,然后就可以方便地进行可视化,这就是点云数据的配准。点云配准技术通过计算机技术和统计学规律,通过计算机计算两个点云之间的错位,也就是把在不同的坐标系下的得到的点云进行坐标变..._局部点云与全局点云配准
文章浏览阅读273次。提取码:0oorGoogle和YouTube由于Python的高可适应性、易于维护以及适合于快速开发而采用它。如果你想要编写高质量、高效的并且易于与其他语言和工具集成的代码,《Python学习手册:第4 版》将帮助你使用Python快速实现这一点,不管你是编程新手还是Python初学者。本书是易于掌握和自学的教程,根据作者Python专家Mark Lutz的著名培训课程编写而成。《Python学习..._零基础学pythonpdf电子书