分析:
(一)客户端
客户端运行初期完成所设定的一定量的socket创建和相应的处理线程的创建,然后使用条件变量来完成线程同步,直到最后一个线程创建完成,才向所有线程发出广播通知,让所有线程并发调用connect,连接成功则关闭连接,失败则返回,如下代码所示。
socket创建和线程创建:
int testCount=300//并发用户数
/*
每个进程需要自己独立的栈空间,linux下默认栈大小是10M,在32位的机子上一个进程需要4G的内存空间,去掉自己的栈空间全局程序段空间,一般只有3G内存可以用,创建线程时就需要从这3G的空间中分配10M出来,所以最多可以分配300个线程。当然这里还可以使用多个进程,每个进程300个线程的方式来进一步扩大并发量。
*/
int sockfd[testCount]
pthread_t ntid[testCount]
bzero(&servaddr,sizeof(servaddr))
servaddr.sin_family=AF_INET
servaddr.sin_port=htons(SERVER_PORT)
inet_pton(AF_INET,argv[1],&servaddr.sin_addr)
int testCaseIndex=0
for(testCaseIndex=0testCaseIndex<testCounttestCaseIndex++)
{
sockfd[testCaseIndex]=socket(AF_INET,SOCK_STREAM,0)
//为每个并发客户端创建一个socket
if(sockfd[testCaseIndex]==-1)
{
printf("socket established error: %s\n",(char*)strerror(errno))
return -1
}
if( pthread_create(&ntid[testCaseIndex],NULL,handleFun,&sockfd[testCaseIndex])!=0)
{
printf("create thread error :%s\n",strerror(errno))
return -1
}
//为每个并发客户端创建一个线程来执行connect
}
printf("%d client has initiated\n",testCaseIndex)
并发客户端的线程实现:线程阻塞在条件变量上(只有条件满足了并且发起唤醒动作,线程才开始执行)。
int sockfd=*((int*)arg)
{
pthread_cond_wait(&cond,&mut)
//在条件变量上等待条件满足!
//阻塞返回后立即解锁,防止互斥量加锁带来的阻塞
pthread_mutex_unlock(&mut)
int conRes=0
conRes=connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr))
//线程执行connect连接,每个线程在接到唤醒信号后,才可以执行该语句,来模拟多个线程的并发调用。
if(conRes==-1)
{
printf("connect error: %s\n",strerror(errno))
return 0
}
}
当条件满足时,唤醒阻塞在条件变量上的线程:
while(1)
{
sleep(2)
pthread_cond_broadcast(&cond)//在所有线程创建完成后才进行唤醒。
\oracle\product\10.2.0\db_1\NETWORK\ADMIN\tnsnames.ora中直接添加配置来完成,或者通过命令:开始--运行--cmd---netca,弹出的窗口中选择本地net服务名配置,按照提示配置就OK.方法有很多种.客户端之间的通讯有两个办法。1. 服务器中转
2. 服务器上注册后,客户端之间直接通信。
对于第一种方法,大多比较简单。查一下socket的文章,还有大把现成的代码给你看。
第二个方法就稍微复杂一些。
但原理都一样。客户端A,链接服务器后,地址信息就保存到了服务器上。除了保持与服务器的通信外。另外开启一个 Socket,绑定到另一个端口,并且一直监听此端口。
客户端B连接服务器,从服务器上获取客户端A的地址信息。把客户端A当成服务器,连接A。
欢迎分享,转载请注明来源:夏雨云
评论列表(0条)