Project1

标题: C开发网络化插件问题 [打印本页]

---

作者: wolves    时间: 2015-3-17 00:38
标题: C开发网络化插件问题


用C语言编译一个网络化的小插件，但是在制作过程中发现了些问题没办法解决：
1. recv函数默认是阻塞的，如果调用时没收到数据会一直等待，造成RM调用卡死。如果设置成非阻塞的话很可能会丢失数据。
2. 服务端收到客户端的数据后没有办法连续发送这个数据，否则会接收不到这条信息后的数据
下面是C#的dll代码：
（link库里要加一个ws2_32.lib，否则连接会出错）

1. #include <Winsock2.h>
   
2. #include <stdio.h>
   
3. 
   
4. char s[100],*mes=s;
   
5. char t[20],*ip=t;
   
6. extern "C" char __declspec(dllexport) *sendmes(char *mes,char *ip,long port)
   
7. {
   
8.     //固定格式
   
9.     WORD wVersionRequested;
   
10.     WSADATA wsaData;
    
11.     int err;
    
12.    
    
13.     wVersionRequested = MAKEWORD( 1, 1 );
    
14.    
    
15.     err = WSAStartup( wVersionRequested, &wsaData );
    
16.     if ( err != 0 ) {
    
17.         return "{Error}";
    
18.     }
    
19.    
    
20. 
    
21.     if ( LOBYTE( wsaData.wVersion ) != 1 ||
    
22.         HIBYTE( wsaData.wVersion ) != 1 ) {
    
23.         WSACleanup( );
    
24.         return "{Error}";
    
25.     }
    
26. 
    
27.     //建立通讯socket
    
28.     SOCKET sockClient=socket(AF_INET,SOCK_STREAM,0);
    
29. 
    
30.     SOCKADDR_IN addrSrv;
    
31.     addrSrv.sin_addr.S_un.S_addr=inet_addr(ip);//设定需要连接的服务器的ip地址
    
32.     addrSrv.sin_family=AF_INET;
    
33.     addrSrv.sin_port=htons(port);//设定需要连接的服务器的端口地址
    
34.     connect(sockClient,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));//与服务器进行连接
    
35.    
    
36.    
    
37.     //发送信息
    
38.     send(sockClient,mes,strlen(mes)+1,0);
    
39.     //接
    
40.     char recvBuf[100];
    
41.     recv(sockClient,recvBuf,100,0);
    
42.         strcpy(mes,recvBuf);
    
43.         return mes;
    
44.     closesocket(sockClient);
    
45.     WSACleanup();
    
46. }
    
47. extern "C" char __declspec(dllexport) *getmes(char *ip,long port)
    
48. {
    
49.     //固定格式
    
50.     WORD wVersionRequested;
    
51.     WSADATA wsaData;
    
52.     int err;
    
53.    
    
54.     wVersionRequested = MAKEWORD( 1, 1 );
    
55.    
    
56.     err = WSAStartup( wVersionRequested, &wsaData );
    
57.     if ( err != 0 ) {
    
58.         return "{Error}";
    
59.     }
    
60.    
    
61. 
    
62.     if ( LOBYTE( wsaData.wVersion ) != 1 ||
    
63.         HIBYTE( wsaData.wVersion ) != 1 ) {
    
64.         WSACleanup( );
    
65.         return "{Error}";
    
66.     }
    
67. 
    
68.     //建立通讯socket
    
69.     SOCKET sockClient=socket(AF_INET,SOCK_STREAM,0);
    
70. 
    
71.         int nNetTimeout=2000;
    
72.         setsockopt(sockClient,SOL_SOCKET,SO_RCVTIMEO,(char*)&nNetTimeout,sizeof(int));
    
73. 
    
74.     SOCKADDR_IN addrSrv;
    
75.     addrSrv.sin_addr.S_un.S_addr=inet_addr(ip);//设定需要连接的服务器的ip地址
    
76.     addrSrv.sin_family=AF_INET;
    
77.     addrSrv.sin_port=htons(port);//设定需要连接的服务器的端口地址
    
78.     connect(sockClient,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));//与服务器进行连接
    
79. 
    
80.     //接
    
81.     char recvBuf[100];
    
82.     if(recv(sockClient,recvBuf,100,0)>0)
    
83.                 strcpy(mes,recvBuf);
    
84.         else
    
85.                 strcpy(mes,"{Error}");
    
86.     closesocket(sockClient);
    
87.     WSACleanup();
    
88.         return mes;
    
89. }

复制代码

服务端代码：

1. #include <Winsock2.h>
   
2. #include <stdio.h>
   
3. 
   
4. void main()
   
5. {
   
6.     // 以下的几句都是固定的
   
7.     WORD wVersionRequested;
   
8.     WSADATA wsaData;
   
9.     int err;
   
10.    
    
11.     wVersionRequested = MAKEWORD( 1, 1 );
    
12.    
    
13.     err = WSAStartup( wVersionRequested, &wsaData );//该函数的功能是加载一个Winsocket库版本
    
14.     if ( err != 0 ) {
    
15.         return;
    
16.     }
    
17.    
    
18. 
    
19.     if ( LOBYTE( wsaData.wVersion ) != 1 ||
    
20.         HIBYTE( wsaData.wVersion ) != 1 ) {
    
21.         WSACleanup( );
    
22.         return;
    
23.     }
    
24. 
    
25.     unsigned short port;
    
26.     //真正socket编程部分
    
27.     SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,0);//面向连接的可靠性服务SOCK_STRAM
    
28. 
    
29.     SOCKADDR_IN addrSrv;//存放本地地址信息的
    
30.     addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);//htol将主机字节序long型转换为网络字节序
    
31.     addrSrv.sin_family=AF_INET;
    
32.         printf("请输入端口号");
    
33.         scanf("%u",&port);
    
34.     addrSrv.sin_port=htons(port);//htos用来将端口转换成字符，1024以上的数字即可
    
35. 
    
36.     bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));//将socket绑定到相应地址和端口上
    
37. 
    
38.     listen(sockSrv,5);//等待队列中的最大长度为5
    
39. 
    
40.     SOCKADDR_IN addrClient;
    
41.     int len=sizeof(SOCKADDR);
    
42.     printf("\n服务器已开启，信息如下：\n");
    
43.     while(1)
    
44.     {
    
45.         SOCKET sockConn=accept(sockSrv,(SOCKADDR*)&addrClient,&len);//建立一个新的套接字用于通信，不是前面的监听套接字
    
46. 
    
47.         char recvBuf[100];
    
48.         recv(sockConn,recvBuf,101,0);//服务器从客户端接受数据
    
49.         printf("\n%s\n",recvBuf);
    
50.         
    
51.                 char sendBuf[100];
    
52.                 sendBuf[0]='\0';
    
53.         strcpy(sendBuf,recvBuf);
    
54.         send(sockConn,sendBuf,strlen(sendBuf)+1,0);//服务器向客户端发送数据
    
55.                 closesocket(sockConn);//关闭socket
    
56.     }
    
57. }

复制代码

求助
@RyanBern @myownroc  

---

作者: wolves    时间: 2015-3-17 17:59
终于解决了，谢谢晴兰

---

欢迎光临 Project1 (https://rpg.blue/)

Powered by Discuz! X3.1