基于balckfin架構(gòu)下的socket通信-服務(wù)器端程序設(shè)計(jì),昨晚新鮮出爐。。。!
我們將PC機(jī)作為服務(wù)端,balckfin作為客戶端。在服務(wù)器上編寫(xiě)TCPServer(語(yǔ)言為C++),編寫(xiě)完畢后編譯、生成可執(zhí)行文件TCPServer.exe。在客戶端,我們先在PC機(jī)上在ucLINUX系統(tǒng)下寫(xiě)好代碼,然后通過(guò)交叉編譯環(huán)境GCC交叉編譯,最后將其掛載到balckfin上。
發(fā)送方的工作流程為:首先初始化Winsock庫(kù),創(chuàng)建套接字,綁定套接字到一個(gè)本地地址,然后進(jìn)入監(jiān)聽(tīng)模式,當(dāng)接收到一個(gè)連接,經(jīng)過(guò)確認(rèn)后,即開(kāi)始發(fā)送數(shù)據(jù),數(shù)據(jù)發(fā)送完畢后關(guān)閉套接字。
接收方的工作流程為:在新的文件傳送過(guò)程建立后,讀取最先收到的數(shù)據(jù)并且保存,它是待接收文件的數(shù)據(jù)字節(jié)數(shù);然后判斷可讀取的數(shù)據(jù)字節(jié)數(shù)是否已經(jīng)達(dá)到文件的數(shù)據(jù)字節(jié)數(shù),如果未達(dá)到則繼續(xù)等待,直到收到全部文件數(shù)據(jù)后才讀取出Winsock中的數(shù)據(jù),進(jìn)行處理。
在balckfin上我們使用Qtopia的解決方案。Qtopia 是Trolltech 公司為采用嵌入式ucLinux 操作系統(tǒng)的消費(fèi)電子設(shè)備而開(kāi)發(fā)的綜合應(yīng)用平臺(tái), Qtopia包含完整的應(yīng)用層、靈活的用戶界面、窗口操作系統(tǒng)、應(yīng)用程序啟動(dòng)程序以及開(kāi)發(fā)框架。
// TCPServer.cpp文件
#include "../skts/InitSock.h"
#include <stdio.h>
#include <conio.h>
CInitSock initSock; // 初始化Winsock庫(kù)
int main()
{
// 創(chuàng)建套接字
SOCKET sListen = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if(sListen == INVALID_SOCKET)
{
printf("Failed socket() \n");
return 0;
}
// 填充sockaddr_in結(jié)構(gòu)
sockaddr_in sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(3490);
sin.sin_addr.S_un.S_addr = inet_addr("192.168.1.196");
// 綁定這個(gè)套接字到一個(gè)本地地址
if(::bind(sListen, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR)
{
printf("Failed bind() \n");
return 0;
}
// 進(jìn)入監(jiān)聽(tīng)模式
if(::listen(sListen, 2) == SOCKET_ERROR)
{
printf("Failed listen() \n");
return 0;
}
// 循環(huán)接受客戶的連接請(qǐng)求
sockaddr_in remoteAddr;
int nAddrLen = sizeof(remoteAddr);
SOCKET sClient;
char szText[256] = "TCP Server Demo!";
while(TRUE)
{
// 接受一個(gè)新連接
sClient = ::accept(sListen, (SOCKADDR*)&remoteAddr, &nAddrLen);
if(sClient == INVALID_SOCKET)
{
printf("Failed accept()");
continue;
}
printf(" 接受到一個(gè)連接:%s \r\n", inet_ntoa(remoteAddr.sin_addr));
int i=0;
// 向客戶端發(fā)送數(shù)據(jù)
while (TRUE)
{
scanf("%s",szText);
::send(sClient, szText, strlen(szText), 0);
printf("%d send:%s\n",++i,szText);
if (szText[0]=='q')
break;
}
// 關(guān)閉同客戶端的連接
::closesocket(sClient);
// getch();
// break;
}
// 關(guān)閉監(jiān)聽(tīng)套節(jié)字
::closesocket(sListen);
return 0;
}
一晚上反復(fù)調(diào)試,其中建立連接,交換信息是關(guān)鍵,一晚上的成績(jī) ,明天開(kāi)始客戶端程序的設(shè)計(jì)了,呵呵。!