Here is my code:
1.
Version 1:
------------
Client side code (BTClient):
int main(int argc , char* argv[])
{
CBTClientSocket btsock;
if (!btsock.InitSocket())
{
printf("WSAStartup error\n");
return 0;
}
// parse the specified Bluetooth address
if (argc < 2)
{
fprintf(stderr, "usage: rfcomm-client <addr>\n"
"\n addr must be in the form
(XX:XX:XX:XX:XX:XX)");
return 0;
}
if (!btsock.CreateSocket())
{
printf("Socket creation failed, error %d\n", WSAGetLastError());
return 0;
}
if (!btsock.MakeConnection(argv[1]))
{
printf("Socket connect error %d\n", WSAGetLastError());
return 0;
}
SOCKET sock = btsock.GetSocket();
send(sock, "hello!", 6, 0);
MyThread* szal = new MyThread(sock);
try{
szal->start();
}
catch (CreateThreadError)
{
printf("Create thread error.\n");
};
btsock.CloseConnection();
}
bool CBTClientSocket::InitSocket()
{
// initialize windows sockets
WORD wVersionRequested;
WSADATA wsaData;
wVersionRequested = MAKEWORD(2, 2);
if (WSAStartup(wVersionRequested, &wsaData) != 0)
{
//printf("WSAStartup error\n");
return false;
}
return true;
}
bool CBTClientSocket::CreateSocket()
{
// create the socket
sock = socket(AF_BTH, SOCK_STREAM, BTHPROTO_RFCOMM);
if (SOCKET_ERROR == sock)
{
//printf("Socket creation failed, error %d\n", WSAGetLastError());
return false;
}
return true;
}
bool CBTClientSocket::FillSockAddress(const char* addr)
{
int sa_len = sizeof(sa);
if (SOCKET_ERROR == WSAStringToAddress(const_cast<char*>(addr), AF_BTH, NULL,
(LPSOCKADDR)&sa, &sa_len))
{
printf("WSAStringToAddress error %d\n", WSAGetLastError());
return false;
}
// fill in the rest of the SOCKADDR_BTH struct
sa.port = SDPGetPort(addr, (LPGUID)&SAMPLE_UUID);
if (sa.port == 0)
{
printf("SDPGetPort error\n");
return false;
}
return true;
}
bool CBTClientSocket::MakeConnection(const char* addr)
{
int sa_len = sizeof(sa);
if (!FillSockAddress(addr))
return false;
if (SOCKET_ERROR == connect(sock, (LPSOCKADDR)&sa, sa_len))
{
//printf("Socket connect error %d\n", WSAGetLastError());
return false;
}
return true;
}
int CBTClientSocket::SDPGetPort(const char *addr, LPGUID guid)
{
int port = 0;
HANDLE h;
WSAQUERYSET *qs;
DWORD flags = 0;
DWORD qs_len;
bool done;
qs_len = sizeof(WSAQUERYSET);
qs = (WSAQUERYSET* )malloc(qs_len);
ZeroMemory(qs, qs_len);
qs->dwSize = sizeof(WSAQUERYSET);
qs->lpServiceClassId = guid;
qs->dwNameSpace = NS_BTH;
qs->dwNumberOfCsAddrs = 0;
qs->lpszContext = (LPSTR) addr;
flags = LUP_FLUSHCACHE | LUP_RETURN_ADDR;
if (SOCKET_ERROR == WSALookupServiceBegin(qs , flags, &h))
{
return -1;
}
done = false;
while (!done)
{
if (SOCKET_ERROR == WSALookupServiceNext(h, flags, &qs_len, qs))
{
int error = WSAGetLastError();
if (error == WSAEFAULT)
{
free(qs);
qs = (WSAQUERYSET* )malloc(qs_len);
} else
if (error == WSA_E_NO_MORE)
{
done = true;
} else
{
return -1;
}
} else
{
SOCKADDR_BTH *sa = (SOCKADDR_BTH* )qs->lpcsaBuffer-
>RemoteAddr.lpSockaddr;
port = sa->port;
}
}
free(qs);
WSALookupServiceEnd(h);
return port;
}
void MyThread::run()
{
int received = 0;
char recvbuf[BUFF_SIZE];
int recvbuflen = BUFF_SIZE;
do {
received = recv(m_socket, recvbuf, recvbuflen, 0);
if ( received > 0 )
{
recvbuf[received]='\0';
printf( "received: %s\n", recvbuf);
//printf("Bytes received: %d\n", iResult);
}
else if ((received == SOCKET_ERROR) && (WSAGetLastError () ==
WSAEWOULDBLOCK))
{
//wait
received = 0;
Sleep(10);
}
else if ( received == 0 )
{
//printf("Connection closed\n");
}
else
{
printf("recv failed: %d\n", WSAGetLastError());
return;
}
} while (( received > 0 )&& running );
}
Server side code:
int main(int argc, char* argv[])
{
CBTServerSocket btsock;
if (btsock.InitSocket())
{
if (btsock.CreateListenSocket())
{
if (btsock.BindSocket())
{
if (!btsock.ListenToSocket())
{
printf("Error listening on socket: %d\n",
WSAGetLastError());
}
else
{
int port = btsock.GetListenPort();
if (port > 0)
{
printf("Listening on RFCOMM port: %d\n",
port);
}
else
printf("Getsockname error %d\n",
WSAGetLastError());
if (!btsock.ServiceAdvertise())
printf("WSASetService() error %d\n",
WSAGetLastError());
}
}
else
printf("Socket bind() error %d\n", WSAGetLastError());
}
else
printf("Socket creation failed, error %d\n", WSAGetLastError());
}
else
printf("WSAStartup() error\n");
char* buf = new char[1025];
while (!kbhit())
{
if (btsock.CreateAcceptSocket())
{
MyThread* szal = new MyThread(btsock.GetAcceptSocket());
try{
szal->start();
}
catch (CreateThreadError)
{
printf("Create thread error.\n");
};
Sleep(100);
}
else{
//printf("accept() failed: %d\n", WSAGetLastError());
printf("Socket accept, error %d\n", WSAGetLastError());
}
}
btsock.CloseConnection();
delete[] buf;
return 0;
}
bool CBTServerSocket::InitSocket()
{
// initialize windows sockets
WORD wVersionRequested;
WSADATA wsaData;
wVersionRequested = MAKEWORD(2, 2);
if (WSAStartup(wVersionRequested, &wsaData) != 0)
{
//printf("WSAStartup error\n");
return false;
}
return true;
}
bool CBTServerSocket::CreateListenSocket()
{
// create the server socket
server = socket(AF_BTH, SOCK_STREAM, BTHPROTO_RFCOMM);
if (SOCKET_ERROR == server)
{
//printf("Socket creation failed, error %d\n", WSAGetLastError());
return false;
}
return true;
}
bool CBTServerSocket::BindSocket()
{
// bind the server socket to an arbitrary RFCOMM port
sa.addressFamily = AF_BTH;
sa.btAddr = 0;
sa.port = BT_PORT_ANY;
if (SOCKET_ERROR == bind (server, (const sockaddr*)&sa, sizeof(SOCKADDR_BTH)))
{
//printf("Socket bind, error %d\n", WSAGetLastError ());
closesocket(server);
return false;
}
return true;
}
bool CBTServerSocket::ListenToSocket()
{
//listen to the socket
if (SOCKET_ERROR == listen(server, 1))
{
//printf("Socket listen, error %d\n", WSAGetLastError ());
closesocket(server);
return false;
}
return true;
}
int CBTServerSocket::GetListenPort()
{
int sa_len = sizeof(sa);
// check which port we’re listening on
if (SOCKET_ERROR == getsockname (server, (SOCKADDR*)&sa, &sa_len))
{
//printf("Getsockname error %d\n", WSAGetLastError ());
closesocket(server);
return -1;
}
//printf("Listening on RFCOMM port: %d\n", sa.port);
return sa.port;
}
bool CBTServerSocket::ServiceAdvertise()
{
// advertise the service
CSADDR_INFO sockInfo;
sockInfo.iProtocol = BTHPROTO_RFCOMM;
sockInfo.iSocketType = SOCK_STREAM;
sockInfo.LocalAddr.lpSockaddr = (LPSOCKADDR)&sa;
sockInfo.LocalAddr.iSockaddrLength = sizeof(sa);
sockInfo.RemoteAddr.lpSockaddr = (LPSOCKADDR)&sa;
sockInfo.RemoteAddr.iSockaddrLength = sizeof(sa);
WSAQUERYSET svcInfo = {0};
svcInfo.dwSize = sizeof(svcInfo);
svcInfo.dwNameSpace = NS_BTH;
svcInfo.lpszServiceInstanceName = "Win32 Sample Bluetooth Service";
svcInfo.lpszComment = "Description of service...";
svcInfo.lpServiceClassId = (LPGUID)&SAMPLE_UUID;
svcInfo.dwNumberOfCsAddrs = 1;
svcInfo.lpcsaBuffer = &sockInfo;
if (SOCKET_ERROR == WSASetService(&svcInfo, RNRSERVICE_REGISTER, 0))
{
//printf("WSASetService error %d\n", WSAGetLastError ());
closesocket(server);
return false;
}
return true;
}
bool CBTServerSocket::CreateAcceptSocket()
{
int ca_len = sizeof(ca);
char buf[1024] = {0};
DWORD buf_len = sizeof(buf);
client = accept(server, (LPSOCKADDR)&ca, &ca_len);
if (SOCKET_ERROR == client)
{
//printf("Socket accept, error %d\n", WSAGetLastError ());
closesocket(server);
return false;
}
WSAAddressToString((LPSOCKADDR)&ca, (DWORD)ca_len, NULL, buf, &buf_len);
return true;
}
void MyThread::run()
{
int received = 0;
char recvbuf[BUFF_SIZE];
int recvbuflen = BUFF_SIZE;
do {
received = recv(m_socket, recvbuf, recvbuflen, 0);
printf( "received: %d\n", received);
if ( received > 0 )
{
recvbuf[received]='\0';
printf( "received: %s\n", recvbuf);
//printf("Bytes received: %d\n", iResult);
int v = send(m_socket,"Data received",9,0);
printf("Sent: %d\n",v);
}
else if ((received == SOCKET_ERROR) && (WSAGetLastError () ==
WSAEWOULDBLOCK))
{
//wait
received = 0;
Sleep(10);
}
else if ( received == 0 )
{
//printf("Connection closed\n");
}
else
{
printf("recv failed: %d\n", WSAGetLastError());
return;
}
} while (( received > 0 )&& running );
}
Client program output:
received: -1
recv failed: 10093
Server program output:
Listening on RFCOMM port: 1
received: hello!
Sent: 9
Version 2:
----------
I modified the MyThread:run() on the client side and server side too:
void MyThread::run()
{
//----------------------
// Initialize Winsock
WSADATA wsaData;
int iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
if (iResult != NO_ERROR)
printf("Error at WSAStartup()\n");
//.....................
//The rest is the same (client side, server side).
}
Then I got the outputs:
Client side:
received: -1
recv failed: 10038
Server side:
Listening on RFCOMM port: 1
received: hello!
Sent: 9
2.
Computer 1: OS = Windows Vista Basic (laptop computer)
Computer 2: OS = Windows XP (desktop computer)
3.
Computer 1: Fujitsu Siemens Bluetooth USB Stick V2.0
Computer 2: Fujitsu Siemens Bluetooth USB Stick V2.0