C# socket多线程源代码(带数据库连接)

发送端:

CFileDialog Dlg(TRUE)

if(Dlg.DoModal()!=IDOK)

return

CFile myFile

if(!myFile.Open(Dlg.GetPathName(), CFile::modeRead | CFile::typeBinary))

{

AfxMessageBox("文件不存在!",MB_OK|MB_ICONERROR)

return

}

CSocket sockSrvr

sockSrvr.Create(800)

sockSrvr.Listen()

CSocket sockRecv

sockSrvr.Accept(sockRecv)

SOCKET_STREAM_FILE_INFO StreamFileInfo

WIN32_FIND_DATA FindFileData

FindClose(FindFirstFile(Dlg.GetPathName(),&FindFileData))

//FindClose(FindFirstFile("G:\\maindir",&FindFileData))

memset(&StreamFileInfo,0,sizeof(SOCKET_STREAM_FILE_INFO))

strcpy(StreamFileInfo.szFileTitle,myFile.GetFileTitle())

StreamFileInfo.dwFileAttributes = FindFileData.dwFileAttributes

StreamFileInfo.ftCreationTime = FindFileData.ftCreationTime

StreamFileInfo.ftLastAccessTime = FindFileData.ftLastAccessTime

StreamFileInfo.ftLastWriteTime = FindFileData.ftLastWriteTime

StreamFileInfo.nFileSizeHigh= FindFileData.nFileSizeHigh

StreamFileInfo.nFileSizeLow = FindFileData.nFileSizeLow

sockRecv.Send(&StreamFileInfo,sizeof(SOCKET_STREAM_FILE_INFO))

UINT dwRead=0

while(dwRead<StreamFileInfo.nFileSizeLow)

{

byte* data = new byte[1024]

UINT dw=myFile.Read(data, 1024)

sockRecv.Send(data, dw)

dwRead+=dw

}

myFile.Close()

sockRecv.Close()

AfxMessageBox("发送完毕！")

接收端:

AfxSocketInit(NULL)

CSocket sockClient

sockClient.Create()

CString szIP

GetDlgItemText(IDC_EDIT_IPADDRESS,szIP)

if(!sockClient.Connect((LPCTSTR)szIP, 800))

{

AfxMessageBox("连接到对方机器失败!")

return

}

SOCKET_STREAM_FILE_INFO StreamFileInfo

sockClient.Receive(&StreamFileInfo,sizeof(SOCKET_STREAM_FILE_INFO))

CString strtitle,str

strtitle.Format(StreamFileInfo.szFileTitle)

str.Format("G:\\maindir\\cxb\\cxf\\%s",strtitle)

//CFile destFile(StreamFileInfo.szFileTitle, CFile::modeCreate | CFile::modeWrite | CFile::typeBinary)

DWORD dwAttr = GetFileAttributes("G:\\maindir\\cxb\\cxf")

if(dwAttr == 0xFFFFFFFF) //文件夹不存在

CreateDirectory("G:\\maindir\\cxb\\cxf",NULL)

CFile destFile(str, CFile::modeCreate | CFile::modeWrite | CFile::typeBinary)

UINT dwRead = 0

while(dwRead<StreamFileInfo.nFileSizeLow)

{

byte* data = new byte[1024]

memset(data,0,1024)

UINT dw=sockClient.Receive(data, 1024)

destFile.Write(data, dw)

dwRead+=dw

}

SetFileTime((HANDLE)destFile.m_hFile,&StreamFileInfo.ftCreationTime,

&StreamFileInfo.ftLastAccessTime,&StreamFileInfo.ftLastWriteTime)

destFile.Close()

SetFileAttributes(StreamFileInfo.szFileTitle,StreamFileInfo.dwFileAttributes)

sockClient.Close()

AfxMessageBox("接收完毕！")

}

void CClientDlg::OnChangeEditIpaddress()

{

// TODO: If this is a RICHEDIT control, the control will not

// send this notification unless you override the CDialog::OnInitDialog()

// function and call CRichEditCtrl().SetEventMask()

// with the ENM_CHANGE flag ORed into the mask.

// TODO: Add your control notification handler code here

CString szIpAddress

GetDlgItemText(IDC_EDIT_IPADDRESS,szIpAddress)

if(szIpAddress.IsEmpty())

GetDlgItem(IDC_BUTTON_SEND)->EnableWindow(FALSE)

else

GetDlgItem(IDC_BUTTON_SEND)->EnableWindow(TRUE)

线程

CreateThread(NULL,0,Thread,(LPVOID)&pathname,0,NULL)

{

}

通常使用CreateThread函数来创建新的线程.(Unix下使缺好用pthread_create函数)

首先指出,线程与线程之间,是并列关系,不会存在"父子线程"的概念.

在Windows平台下,CreateThread函数包含在 Windows.h 文件内,包含此文件即可正常使用.

以下为CreateThread函数的声明:

HANDLE CreateThread(

LPSECURITY_ATTRIBUTES lpThreadAttributes,//指向安全性属性描述结构体的

//指针,通常可以忽略的.

SIZE_T dwStackSize,//指定新线程初始的栈大小,若不关心,可以用0填充,来要求使用

//默认值

LPTHREAD_START_ROUTINE lpStartAddress,//用来充当线程的函数的指针.

LPVOID lpParameter,//要传递给函数的参数,这个值本身就是那个参数,而不是参数的地址

DWORD dwCreationFlags,//创建的数扮兆方式,0表示正常,创建后立即开始运行

LPDWORD lpThreadId//用来接受函数反馈的线程ID的指针.

)

用来充当新的线程的函数格式:

DWORD WINAPI ThreadProc(LPVOID)

CreateThread函数若成功了,返回新线程的句柄,若失败了,则返回NULL.

若用CREATE_SUSPENDED填充dwCreation Flags则创建的线程先挂起来,并不直接开始运行,要用ResumeThread函数恢复线程薯租,才能继续运行.

这是一个多线程例子，里面只有两个线程，是生产者/消费者模式，已编译通过，注释很详细，

如下：

/* 以生产者和消费者模型问题来阐述Linux线程的控制和通信你

生产者线程将生产的产品送入缓冲区，消费者线程则从中取出产品。

缓冲区有N个，是一个环形的缓冲池。

*/御散唯

#include <stdio.h>

#include <pthread.h>

#define BUFFER_SIZE 16

struct prodcons

{

int buffer[BUFFER_SIZE]/*实际存放镇培数据的数组*/

pthread_mutex_t lock/*互斥体lock，用于对缓冲区的互斥 *** 作*/

int readpos,writepos/*读掘指写指针*/

pthread_cond_t notempty/*缓冲区非空的条件变量*/

pthread_cond_t notfull/*缓冲区未满 的条件变量*/

}

/*初始化缓冲区*/

void pthread_init( struct prodcons *p)

{

pthread_mutex_init(&p->lock,NULL)

pthread_cond_init(&p->notempty,NULL)

pthread_cond_init(&p->notfull,NULL)

p->readpos = 0

p->writepos = 0

}

/*将产品放入缓冲区，这里是存入一个整数*/

void put(struct prodcons *p,int data)

{

pthread_mutex_lock(&p->lock)

/*等待缓冲区未满*/

if((p->writepos +1)%BUFFER_SIZE ==p->readpos)

{

pthread_cond_wait(&p->notfull,&p->lock)

}

p->buffer[p->writepos] =data

p->writepos++

if(p->writepos >= BUFFER_SIZE)

p->writepos = 0

pthread_cond_signal(&p->notempty)

pthread_mutex_unlock(&p->lock)

}

/*从缓冲区取出整数*/

int get(struct prodcons *p)

{

int data

pthread_mutex_lock(&p->lock)

/*等待缓冲区非空*/

if(p->writepos == p->readpos)

{

pthread_cond_wait(&p->notempty ,&p->lock)//非空就设置条件变量notempty

}

/*读书据，移动读指针*/

data = p->buffer[p->readpos]

p->readpos++

if(p->readpos == BUFFER_SIZE)

p->readpos = 0

/*设置缓冲区未满的条件变量*/

pthread_cond_signal(&p->notfull)

pthread_mutex_unlock(&p->lock)

return data

}

/*测试：生产站线程将1 到1000的整数送入缓冲区，消费者线程从缓冲区中获取整数，两者都打印信息*/

#define OVER (-1)

struct prodcons buffer

void *producer(void *data)

{

int n

for( n=0n<1000n++)

{

printf("%d ------>\n",n)

put(&buffer,n)

}

put(&buffer,OVER)

return NULL

}

void *consumer(void *data)

{

int d

while(1)

{

d = get(&buffer)

if(d == OVER)

break

else

printf("----->%d\n",d)

}

return NULL

}

int main()

{

pthread_t th_p,th_c

void *retval

pthread_init(&buffer)

pthread_create(&th_p,NULL,producer,0)

pthread_create(&th_c,NULL,consumer,0)

/*等待两个线程结束*/

pthread_join(th_p, &retval)

pthread_join(th_c,&retval)

return 0

}

---