gsop入门学习笔记（二）---gsop编程简述以及discover的实现

1.      int  main()

2.      {

3.      struct  soap *soap;

4.      ...

5.      soap =soap_new();//定义并初始化环境变量

6.      soap_init（soap）；

7.      soap_server（soap）；

8.      if(!soap)//如果不能定义，退出

9.      ...

10.  soap_call_ns__method1(soap,...);//调用远程函数

11.  ...

12.  soap_call_ns__method2(soap,...);//调用另一个远程函数

13.  ...

14.  soap_destroy(soap)；//cleanup allocated class instance

15.  soap_end(soap);//清除环境变量

16.  soap_done(soap)；//detachcontext (last use and no longer in scope)

17.  free(soap);//释放环境变量空间

18.   

19.  }

20.  int main()

21.  {

22.  struct soap soap1,soap2;

23.  pthread t tid;

24.  ...

25.  soapinit(&soap1);

26.  if (soapbind(&soap1, host, port, backlog) < 0) exit(1);

27.  if (soapaccept(&soap1) < 0) exit(1);

28.  pthreadcreate(&tid, NULL, (void*(*)(void*))soap serve, (void*)&soap1);

29.  ...

30.  soapinit(&soap2);

31.  soap call nsmethod(&soap2, ...); // make a remote call

32.  ...

33.  soapend(&soap2);

34.  ...

35.  pthread join(tid,NULL); // wait for thread to terminate

36.  soap end(&soap1);// release its data

37.  }

1.      int bind_server_udp1(int server_s) //将sock绑定到本机某端口上。

2.       

3.      { 

4.          struct sockaddr_in local_addr; 

5.      //这里申请了一个sockaddr_in类型的结构体，主要是我们填充本地地址信息

6.          memset(&local_addr,0,sizeof(local_addr)); 

7.      //对申请的本地信息结构体进行初始化

8.          local_addr.sin_family =AF_INET; 

9.      // 协议族，ipv4

10.      local_addr.sin_addr.s_addr= htonl(INADDR_ANY);

11.  //如果将sin_addr设置为INADDR_ANY，则表示所有的IP地址，也即所有的计算机。 

12.      local_addr.sin_port =htons(3702); 

13.  // 填充服务器端口的信息把服务器端口转换成网络字节序

14.      return bind(server_s,(struct sockaddr*)&local_addr,sizeof(local_addr)); 

15.   //实现和套接字的绑定

16.  } 

17.  static int create_server_socket_udp(void) //建立udp的套接字

18.  { 

19.      int server_udp; 

20.      unsigned char one = 1; 

21.      int sock_opt = 1; 

22.      

23.      //server_udp =socket(PF_INET, SOCK_DGRAM, 0); 

24.      server_udp =socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP); 

25.  //创建udp类型的套接字 udp使用SOCK_DGRAM第三个使用0是默认协议

26.      if (server_udp == -1) { 

27.         printf("unable to create socket\n"); 

28.      } 

29.   

30.      /* reuse socket addr*/ 

31.      if ((setsockopt(server_udp, SOL_SOCKET,SO_REUSEADDR, (void *) &sock_opt, sizeof (sock_opt)))== -1) { 

32.         printf("setsockopt\n"); 

33.      } //设置允许重用本地地址和端口

34.      if ((setsockopt(server_udp, IPPROTO_IP,IP_MULTICAST_LOOP,

35.   &one, sizeof (unsigned char))) == -1){ 

36.         printf("setsockopt\n"); 

37.      } //禁止多播数据回送到本地loop接口.

38.   

39.      struct ip_mreq mreq; 

40.      mreq.imr_multiaddr.s_addr= inet_addr("239.255.255.250"); 

41.  //设置多播组地址

42.      mreq.imr_interface.s_addr= htonl(INADDR_ANY); 

43.   //设置加入接口的ip地址，这里是所有计算机

44.      if(setsockopt(server_udp,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mreq,sizeof(mreq))==-1){ 

45.         perror("memberchip error\n"); 

46.      } //把一个socket加入到一个多播组

47.   

48.      return server_udp; 

49.  } 

1.      int main()                                                                                                                               

2.      {

3.               int server_udp;

4.               

5.               int retval=0;

6.               struct soap *soap_udp;

7.               int fault_flag = 0;

8.               

9.               server_udp = create_server_socket_udp();

10.  //创建udp套接字

11.           bind_server_udp1(server_udp);

12.  //绑定udp套接字

13.           while(1){

14.                   soap_udp=soap_new();

15.                   soap_init1(soap_udp,SOAP_IO_UDP);

16.  //定义并初始化新的环境变量

17.                   soap_udp->master = server_udp;

18.                   soap_udp->socket =server_udp;

19.  //这两个部分需填充的是socket,分别关联到port和send and reciver

20.                   soap_udp->errmode = 0;

21.                   soap_udp->bind_flags = 1;

22.                   if(!soap_valid_socket(soap_bind(soap_udp, NULL, 3702,)))

23.                   {       

24.                           soap_print_fault(soap_udp,stderr);

25.                   }

26.  //判断是不是有效地socket

27.                   fprintf(stderr,"soap_servestarting..\n");

28.                   retval = soap_serve(soap_udp);

29.  //阻塞在这里

30.                   fprintf(stderr,"retval=%d\n",retval);

31.                   if(retval &&!(fault_flag))

32.                   {

33.                          fault_flag = 1;

34.                   }

35.                   else if(!retval)

36.                  {

37.                          fault_flag = 0;

38.                   }

39.                   soap_destroy(soap_udp);

40.                   soap_end(soap_udp);

41.  //清楚环境变量

42.                   soap_done(soap_udp);

43.                   free(soap_udp);

44.  //释放环境变量

45.           }

46.  }