请大家讨论一下如何同步两个异地进程

wawxdyy

我现在的做法是，创建一个单独的线程，然后通过socket的send/recv来发送/接收一些整数，代码如下：

1. 
   
2. 2355 static int cma_remsync_send(node_t *node, sync_no_t sync_no)
   
3. 2356 {
   
4. 2357         int                     ret;
   
5. 2358
   
6. 2359         ret = send(test->conn_sock, (void *)&sync_no, sizeof (sync_no_t), 0);
   
7. 2360         if (ret < 0) {
   
8. 2361                 ERROR("cma_remsync_send: send sync_no failed %s (%d)\n",
   
9. 2362                     strerror(errno), errno);
   
10. 2363                 return 1;
    
11. 2364         }
    
12. 2365
    
13. 2366         return 0;
    
14. 2367 }
    
15. 2368
    
16. 2369 static int cma_remsync_recv(node_t *node, sync_no_t sync_no)
    
17. 2370 {
    
18. 2371         int                     ret;
    
19. 2372         sync_no_t               rsync_no = SYNC_NONE;
    
20. 2373
    
21. 2374         ret = recv(test->conn_sock, (void *)&rsync_no, sizeof (sync_no_t), 0);
    
22. 2375         if (ret < 0) {
    
23. 2376                 ERROR("cma_remsync_recv: recv sync_no failed %s (%d)\n",
    
24. 2377                     strerror(errno), errno);
    
25. 2378                 return 1;
    
26. 2379         }
    
27. 2380
    
28. 2381         if (rsync_no != sync_no) {
    
29. 2382                 ERROR("cma_remsync_recv: recv'd sync_no (%d) isn't as expected "
    
30. 2383                     "(%d)\n", rsync_no, sync_no);
    
31. 2384                 return 1;
    
32. 2385         }
    
33. 2386
    
34. 2387         return 0;
    
35. 2388 }
    
36. 2389
    
37. 2390 int cma_remsync(node_t *node, sync_no_t no)
    
38. 2391 {
    
39. 2392         sync_no_t               sync_no = no;
    
40. 2393         int                     errors = 0;
    
41. 2394
    
42. 2395         if (test->cm_test_type == CM_TEST_SERVER) {
    
43. 2396                 errors += cma_remsync_send(node, sync_no);
    
44. 2397                 errors += cma_remsync_recv(node, sync_no);
    
45. 2398         } else {
    
46. 2399                 errors += cma_remsync_recv(node, sync_no);
    
47. 2400                 errors += cma_remsync_send(node, sync_no);
    
48. 2401         }
    
49. 2402
    
50. 2403         return errors;
    
51. 2404 }
    
52. 
    

复制代码

sync_no_t是我定义的一组枚举变量。

但是我觉得实现不太好，首先很明显的就是客户端必须先到达各个同步点，否则服务器端的send就会失败；另外recv应该也会有个超时的问题吧。

希望大家能指点一下，如何完善上面这个函数，越简单越好。

如果觉得我这个实现方案就不对，那有没有更好的实现方法呢，或者现成的库函数（不能额外安装包）

[ 本帖最后由 wawxdyy 于 2009-7-14 18:36 编辑 ]

wawxdyy

奇怪啊，怎么<code></code>不好用啊

swxlion

原帖由 wawxdyy 于 2009-7-14 17:08 发表
奇怪啊，怎么<code></code>不好用啊

把尖角磨平了就好用了

wawxdyy

果然，谢啦，我忘掉了

rollin7

如果怕超时或发送失败的话，可以用UDP来试一下，但有个问题，UDP不可靠，有可能丢数据包，因此得进行超时重发，否则进程会一直在那挂到22世纪

epegasus

看了半天不知道LZ同步是指什么.
>>>客户端必须先到达各个同步点

克拉玛依

同步长连接、同步短连接？