局域网TCP代码,Java代码库,德仔网

代码语言
代码分类
【Java】局域网TCP
作者:BeGit / 发布于2014/11/13/ 412
局域网TCP windows vs2008 本来添加文件传输的写了一半只写了TCP接收信息的框架

	/*******************************************************************************
	* @file
	* @author def< qq group: 324164944 >
	* @blog http://www.cnblogs.com/itdef/
	* @brief
	/*******************************************************************************/
	
	#include "stdafx.h"
	#include "SocketClass.h"
	
	#pragma comment(lib,"ws2_32")
	
	BOOL CBasicTcpSocket::BasicTcpSocketInit(u_short port)
	{
	 BOOL bRet = FALSE;
	 struct sockaddr_in srv_addr;
	 int addr_len = sizeof(srv_addr);
	 int result;
	
	 try{
	 sock_=::socket(AF_INET, SOCK_STREAM, 0);
	 if(INVALID_SOCKET==sock_){
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s socket() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 throw exception(buf);
	 }
	 srv_addr.sin_family = AF_INET;
	 srv_addr.sin_port = htons(port);
	 srv_addr.sin_addr.s_addr = INADDR_ANY;
	
	 result = bind(sock_,(struct sockaddr*)&srv_addr,addr_len);
	 if(result == SOCKET_ERROR)
	 {
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s bind() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 throw exception(buf);
	 }
	 if( 0 != listen(sock_,SOMAXCONN) )
	 {
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s listen() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 throw exception(buf);
	 }
	
	
	 bRet = TRUE;
	 }catch(exception& e)
	 {
	 cout << e.what() << endl;
	 }
	
	 return bRet;
	}
	
	
	BOOL CTcpSocket::Start()
	{
	 BOOL bRet = FALSE;
	 InterlockedExchange(&threadRunFlag_,1);
	
	 fd_set read_all;
	
	
	 FD_ZERO(&read_all);
	 FD_SET(sock_,&read_all);
	 fd_set read_set;
	
	 while(threadRunFlag_)
	 {
	 //cout << "Enter recv loop" << endl;
	 try{
	 read_set = read_all;
	 int ready_cnt = select(0,&read_set,NULL,NULL,NULL);
	 if(ready_cnt == SOCKET_ERROR)
	 {
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s select() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 throw exception(buf);
	 }
	 if(FD_ISSET(sock_,&read_set))
	 {
	 struct sockaddr_in faddr;
	 int addr_len = sizeof(faddr);
	 // 遍历sock组 找出未使用sock来使用
	 int idx = 0;
	 for(idx= 0;idx < MAX_SOCKET_COUNT;idx++)
	 {
	 if(recvSock_[idx]==INVALID_SOCKET)
	 {
	 break;
	 }
	 }
	 if(MAX_SOCKET_COUNT == idx)
	 {
	 cout << "too much connect" << endl;
	 continue;
	 }
	 recvSock_[idx] = accept(sock_,(struct sockaddr*)&faddr,&addr_len);
	
	 if(recvSock_[idx] == INVALID_SOCKET)
	 {
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s accept() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 cout << buf <<endl;
	
	 FD_CLR(recvSock_[idx],&read_all);
	 FD_CLR(recvSock_[idx],&read_set);
	 recvSock_[idx] = INVALID_SOCKET;
	 continue;
	 }
	 FD_SET(recvSock_[idx],&read_all);
	 }
	
	 for(int i = 0 ; i < MAX_SOCKET_COUNT;i++)
	 {
	 char buf[100] = {0};
	 if(!FD_ISSET(recvSock_[i],&read_set))
	 {
	 continue;
	 }
	 int result = recv(recvSock_[i],buf,100,NULL);
	 if(result != SOCKET_ERROR && 0 != result)
	 {
	 printf("recv: %s\n",buf);
	 }else
	 {
	 char buf[100] = {0};
	 FormatMsg(buf, sizeof(buf) ,"%s recv() error.Error code %d", \
	 __FUNCTION__,GetLastError());
	 cout << buf <<endl;
	
	 FD_CLR(recvSock_[i],&read_all);
	 FD_CLR(recvSock_[i],&read_set);
	 recvSock_[i] = INVALID_SOCKET;
	 continue;
	 }
	 }
	
	 bRet = TRUE;
	 }catch(exception& e)
	 {
	 cout << e.what() << endl;
	 }
	 }
	
	 return bRet;
	}
试试其它关键字
　局域网　　 TCP　
同语言下
可能有用的
BeGit贡献的其它代码(1)
.局域网TCP