c++如何读取socket的buff的utf8字符串

时间:2023-01-10 17:33:20
如题

就是socket进行recv之后,往自己定义的recvbuff里面写入数据,int、short、bool什么的都没问题就是utf8的字符串不行

我用as3编写的客户端用writeUTF方法给服务端发送字符串,收出来老是乱码

查询了半天资料结果发现是编码的问题,结果又尝试解决了很久也没搞定

特来求助高手,希望能给出示例代码

感谢感谢

13 个解决方案

#1


  客户端用:
socket.writeBytes(buffer);
行不?

#2


你的程序如果是ansi编码,需要将utf8转码为gbk

转码可用iconv来做, libiconv字符集转换库使用方法

#3


以下代码希望能给你一些帮助

<?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++服务器端:

// 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);

 }

}



#4


先感谢eit520的回复

不过我发现我的意思你没理解
在as3的socket编程里面如果采用2进制方式传输
那肯定是用ByteArray的

所以你说的writeBytes肯定会用到
但是我们在构造一个包的时候不可避免要用到字符串发给服务端,比如聊天的时候
那么writeUTF就必不可少了
可参见adobe的官方说明


Kaile的回复我打不开啊,里面的链接好像是死的

#5


我已经都把utf8编码发来的字节长度都取出来了
就是不知道怎么能原样接受并打印在控制台上

哪位高手来指点一下啊

#6


internal function sendMessage(msg:String):void
  {
   var message:ByteArray = new ByteArray();
   message.writeUTFBytes(msg+"\r\n");
    socket.writeBytes(message);
    socket.flush();
  }

你的这个方法里面并没有告诉服务端你的字符串长度是多少
服务端没办法取啊

#7


该回复于2012-04-15 10:55:05被版主删除

#8


有人吗

#9


自己顶起来一下

希望能有人给说一下

#10


我只说一下我的做法:
1.我们强制规定,socket中传输的,一定是char*,则它必然以\0结尾。

2.为了使得char*能立刻传出,而不是等到缓冲区满了才传,强制要求字符串末尾处加上\r\n.

3.考虑到UNICODE编码,传入时使用T2A转换,传出时使用A2T转换。

#11


感谢回答
我看看T2A和A2T是什么

再次感谢

#12


引用 11 楼  的回复:
感谢回答
我看看T2A和A2T是什么

再次感谢


T2A和A2T是VC++中的两个宏,用来进行编码转换的.

#13


我查了一下
准备用iconv那个来进行转换
因为有可能要移植

感谢各位指点

没有求的代码就结贴了

#1


  客户端用:
socket.writeBytes(buffer);
行不?

#2


你的程序如果是ansi编码,需要将utf8转码为gbk

转码可用iconv来做, libiconv字符集转换库使用方法

#3


以下代码希望能给你一些帮助

<?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++服务器端:

// 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);

 }

}



#4


先感谢eit520的回复

不过我发现我的意思你没理解
在as3的socket编程里面如果采用2进制方式传输
那肯定是用ByteArray的

所以你说的writeBytes肯定会用到
但是我们在构造一个包的时候不可避免要用到字符串发给服务端,比如聊天的时候
那么writeUTF就必不可少了
可参见adobe的官方说明


Kaile的回复我打不开啊,里面的链接好像是死的

#5


我已经都把utf8编码发来的字节长度都取出来了
就是不知道怎么能原样接受并打印在控制台上

哪位高手来指点一下啊

#6


internal function sendMessage(msg:String):void
  {
   var message:ByteArray = new ByteArray();
   message.writeUTFBytes(msg+"\r\n");
    socket.writeBytes(message);
    socket.flush();
  }

你的这个方法里面并没有告诉服务端你的字符串长度是多少
服务端没办法取啊

#7


该回复于2012-04-15 10:55:05被版主删除

#8


有人吗

#9


自己顶起来一下

希望能有人给说一下

#10


我只说一下我的做法:
1.我们强制规定,socket中传输的,一定是char*,则它必然以\0结尾。

2.为了使得char*能立刻传出,而不是等到缓冲区满了才传,强制要求字符串末尾处加上\r\n.

3.考虑到UNICODE编码,传入时使用T2A转换,传出时使用A2T转换。

#11


感谢回答
我看看T2A和A2T是什么

再次感谢

#12


引用 11 楼  的回复:
感谢回答
我看看T2A和A2T是什么

再次感谢


T2A和A2T是VC++中的两个宏,用来进行编码转换的.

#13


我查了一下
准备用iconv那个来进行转换
因为有可能要移植

感谢各位指点

没有求的代码就结贴了