快捷導(dǎo)航

簡(jiǎn)單的socket編程入門(mén)示例

更新時(shí)間：2014年03月30日 09:40:32 作者：

這篇文章主要介紹了簡(jiǎn)單的socket編程入門(mén)示例,簡(jiǎn)單實(shí)現(xiàn)client輸入內(nèi)容發(fā)送到server端輸出,需要的朋友可以參考下

功能簡(jiǎn)單實(shí)現(xiàn)client輸入內(nèi)容發(fā)送到server端輸出

#include <stdio.h>
#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib")
using namespace std;
int main()
{
// 初始化 Winsock.
WSADATA wsaData;
int iResult = WSAStartup( MAKEWORD(2,2), &wsaData );
if ( iResult != NO_ERROR )
{
cout<<"failed to initialize!"<<endl;
return 0;
}

// 建立socket socket.
SOCKET client;
client = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
if ( client == INVALID_SOCKET )
{
  cout<<"failed to create client socket!"<<endl;
  WSACleanup();
  return 0;
}

// 連接到服務(wù)器.
sockaddr_in clientService;
clientService.sin_family = AF_INET;
clientService.sin_addr.s_addr = inet_addr( "127.0.0.1" );
clientService.sin_port = htons( 13579 );

if ( connect( client, (SOCKADDR*) &clientService, sizeof(clientService) ) == SOCKET_ERROR)
{
  cout<<"Failed to connect"<<endl;
  closesocket(client);
  WSACleanup();
  return 0;
}

// 發(fā)送數(shù)據(jù).
int bytesSent;
char sendbuf[4096] = "Client: Sending data.";
while(TRUE)
{
bytesSent = send( client, sendbuf, strlen(sendbuf), 0 );
gets_s(sendbuf, 4096);
}

closesocket(client);
WSACleanup();
return 0;
}

復(fù)制代碼代碼如下:

#include <iostream>
#include <WinSock2.h>
#pragma comment(lib, "ws2_32.lib")

using namespace std;

int main()
{
WSADATA wsaData;

int iInit = WSAStartup(MAKEWORD(2, 2), &wsaData);
if (iInit != NO_ERROR)
{
cout<<"failed to initialize!"<<endl;
return 0;
}

SOCKET server = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (server == INVALID_SOCKET)
{
  cout<<"failed to create server socket!"<<endl;
  WSACleanup();
  return 0;
}

sockaddr_in bindinfo;
bindinfo.sin_family = AF_INET;
bindinfo.sin_addr.s_addr = inet_addr( "127.0.0.1" );
bindinfo.sin_port = htons(13579);
if ( bind( server, (SOCKADDR*) &bindinfo, sizeof(bindinfo) ) == SOCKET_ERROR )
{
  cout<<"failed to bind!"<<endl;
  closesocket(server);
  WSACleanup();
  return 0;
}

//listen
if (listen(server, 1) == SOCKET_ERROR) {
  cout<<"listen failed"<<endl;
  closesocket(server);
  WSACleanup();
  return 0;
}

//accept and block
SOCKET socketWork = accept(server, NULL, NULL);
if (socketWork == INVALID_SOCKET) {
  wprintf(L"accept failed with error: %ld\n", WSAGetLastError());
  closesocket(server);
  WSACleanup();
  return 0;
}

int byteRecv = SOCKET_ERROR;
char recvBuf[4096] = "";

while(TRUE)
{
  byteRecv = recv(socketWork, recvBuf, 4096, 0);
  if (byteRecv == 0)
  {
   break;
  }
  recvBuf[byteRecv] = 0;
  cout<<recvBuf<<endl;
}

closesocket(server);
WSACleanup();
return 0;
}

您可能感興趣的文章: