[转]Socket实现C++与Flex通信_C/C++

您所在的位置：程序员俱乐部 > 编程开发 > C/C++ > [转]Socket实现C++与Flex通信

[转]Socket实现C++与Flex通信

2013/11/1 21:19:01 hszhl 程序员俱乐部我要评论(0)

摘要：下面是在flex下的客户端：Java代码<?xmlversion="1.0"encoding="utf-8"?><mx:Applicationxmlns:mx="http://www.adobe.com/2006/mxml"layout="absolute"creationComplete="initApp()"><mx:Script><![CDATA[importflash.events.SecurityErrorEvent;importflash
标签：实现 c++ socket Flex

下面是在flex下的客户端：

Java代码

class="star">spinner">

<?xml?version="1.0"?encoding="utf-8"?>??
<mx:Application?xmlns:mx="http://www.adobe.com/2006/mxml"?layout="absolute"?creationComplete="initApp()">??
??
??
<mx:Script>??
?<![CDATA[??
??import?flash.events.SecurityErrorEvent;??
??import?flash.events.IOErrorEvent;??
??import?flash.events.ProgressEvent;??
????
??import?flash.net.Socket;??
????
??import?flash.utils.ByteArray;??
????
??private?var?socket:Socket?=?new?Socket();??
??internal?function?initApp():void??
??{??
???socket.addEventListener(Event.CLOSE,closeHandler);??
???socket.addEventListener(Event.CONNECT,connectHandler);??
???socket.addEventListener(IOErrorEvent.IO_ERROR,ioErrorHandler);??
???socket.addEventListener(SecurityErrorEvent.SECURITY_ERROR,securityErrorHandler);??
???socket.addEventListener(ProgressEvent.SOCKET_DATA,socketDataHandler);??
??}??
????
??internal?function?closeHandler(evt:Event):void??
??{??
???output("connect?fail?and?close");??
??}??
????
??internal?function?connectHandler(evt:Event):void??
??{??
???output("connect?success");??
??}??
????
??internal?function?ioErrorHandler(evt:IOErrorEvent):void??
??{??
???output("io?error:"+evt.text);??
??}??
????
??internal?function?securityErrorHandler(evt:SecurityErrorEvent):void??
??{??
???output("security?error?:"+evt.text);??
??}??
????
??internal?function?doConnect():void??
??{??
???var?server:String?=?server_txt.text;??
???var?port:Number?=Number(port_txt.text);??
?????
???socket.connect(server,port);??
?????
??}??
????
??internal?function?socketDataHandler(evt:ProgressEvent):void??
??{??
???var?msg:String;??
???while(socket.bytesAvailable)??
???msg+=socket.readMultiByte(socket.bytesAvailable,"utf8");??
???var?arr:Array?=?msg.split('\n');??
???for(var?i:int=0;i<arr.length;i++)??
???{??
????if(arr[i].length>1)??
????{??
?????var?myPattern:RegExp=/\r/;??
?????arr[i]=arr[i].replace(myPattern,'');??
?????output(arr[i]);??
????}??
???}??
??}??
????
??internal?function?sendMessage(msg:String):void??
??{??
???var?message:ByteArray?=?new?ByteArray();??
???message.writeUTFBytes(msg+"\r\n");??
????socket.writeBytes(message);??
????socket.flush();??
??}??
????
??internal?function?output(msg:String):void??
??{??
???msg=msg+"\n";??
???output_txt.text+=msg;??
??}??
????
?]]>??
</mx:Script>??
<mx:Panel?x="368"?y="25"?width="360"?height="336"?layout="absolute"?title="输出信息">??
?<mx:TextArea?x="10"?y="77"?width="100%"?height="213"?id="output_txt"/>??
?<mx:TextInput?x="23"?y="37"?id="input_txt"?text="输入信息"?enter="sendMessage(input_txt.text)"/>??
?<mx:Button?x="246"?y="37"?label="发送"?click="sendMessage(input_txt.text)"/>??
???
</mx:Panel>??
?<mx:Panel?x="40"?y="78"?width="250"?height="200"?layout="absolute"?title="登陆窗口">??
??<mx:Label?x="10"?y="10"?text="服务器地址"/>??
??<mx:TextInput?x="73"?y="8"?width="147"?id="server_txt"?text="127.0.0.1"/>??
??<mx:Label?x="10"?y="51"?text="端口"/>??
??<mx:TextInput?x="73"?y="49"?width="147"?id="port_txt"?text="80"/>??
??<mx:Button?x="73"?y="109"?label="连接"?click="doConnect()"/>??
?</mx:Panel>??
</mx:Application>?

下面是c++服务器端：

Cpp代码

//?server.cpp?:?定义控制台应用程序的入口点。??
//??
??
#include?"stdafx.h"??
??
??
#include?<winsock2.h>??
??
??
#include?<windows.h>??
??
#include?<iostream>??
??
using?namespace?std;??
??
#pragma?comment(lib,"ws2_32.lib")??
??
???
??
void?main(){???
??
?WORD?wVersionRequested;??
??
?WSADATA?wsaData;??
??
?int?err;??
??
?short?port=80;//端口号??
??
???
??
?wVersionRequested?=?MAKEWORD(?1,?1?);??
??
???
??
?err?=?WSAStartup(?wVersionRequested,?&wsaData?);//初始化套接字??
??
?if?(?err?!=?0?)??
??
?{??
??
????return;??
??
?}??
??
???
??
?if?(?LOBYTE(?wsaData.wVersion?)?!=?1?||?HIBYTE(?wsaData.wVersion?)?!=?1?)??
??
?{??
??
????WSACleanup(?);??
??
????return;??
??
?}??
??
???
??
?SOCKET?sockSrv=socket(AF_INET,SOCK_STREAM,0);//创建套接字??
??
?SOCKET?sockConn;//用来和客户端通信的套接字??
??
???
??
?SOCKADDR_IN?addrSrv;//用来和客户端通信的套接字地址??
??
???
??
?addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);??
??
?addrSrv.sin_family=AF_INET;??
??
?addrSrv.sin_port=htons(port);??
??
???
??
?bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));//绑定端口??
??
???
??
?listen(sockSrv,5);//侦听??
??
???
??
printf("Server?%d?is?listening......\n",port);??
??
???
??
?SOCKADDR_IN?addrClient;??
??
???
??
?int?len=sizeof(SOCKADDR);??
??
???
??
char?buf[4096];//接收的数据??
??
char?rbuf[100]="成功";//返回的数据??
??
???
??
?while(1)??
??
?{??
??
????????//接受连接??
??
?????????sockConn=accept(sockSrv,(SOCKADDR*)&addrClient,&len);??
??
?????????printf("Accept?connection?from?%s\n",inet_ntoa(addrClient.sin_addr));??
??
???
??
?????????//接收数据??
??
?????????int?bytes;??
??
?????????if((bytes=recv(sockConn,buf,sizeof(buf),0))==SOCKET_ERROR){??
??
??????????????printf("接收数据失败!\n");??
??
??????????????exit(-1);??
??
?????????}??
??
?????????buf[bytes]='\0';??
??
?????????printf("Message?from?%s:?%s\n",inet_ntoa(addrClient.sin_addr),buf);??
??
???
??
?????????//发送数据??
??
????????if(send(sockConn,rbuf,strlen(rbuf)+1,0)==SOCKET_ERROR){??
??
??????????????printf("发送数据失败！");??
??
??????????????exit(-1);??
??
?????????}??
??
????????printf("Message?to?%s:?%s\n",inet_ntoa(addrClient.sin_addr),rbuf);??
??
???
??
????????//清理套接字占用的资源??
??
????????closesocket(sockConn);??
??
?}??
??
} ?