KO | EN

GitLite

Minimalist Open Source Repository Search Engine

gitlite — search

#dsh #dsh-plugin #ai-agent #developer-tools #codex #typescript #cli #deepseek-harness #claude-code #ai-agents #mcp #rust

gopush-cluster-sdk

★ 37 Open GitHub ↗

gopush cluster sdk(java)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

## Terry-Mao/gopush-cluster-sdk
`Terry-Mao/gopush-cluster-sdk` is an java sdk for [gopush-cluster](https://github.com/Terry-Mao/gopush-cluster)

## Requeriments
Java and maven is required

## Installation
Just pull `Terry-Mao/gopush-cluster-sdk` from github using:

```sh
# download the code
$ git clone github.com/Terry-Mao/gopush-cluster-sdk
```

## Junit Test && Usage

```java
package com.ks.gopush.cli;

import java.util.ArrayList;
import java.util.concurrent.TimeUnit;

import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;

public class GoPushCliTest {
    @Before
    public void init() {
        local.set(new GoPushCli("42.96.200.187", 8090, "Terry-Mao", 30, 0, 0,
                new Listener() {
                    @Override
                    public void onOpen() {
                        System.err.println("dang dang dang dang~");
                    }

@Override
                    public void onOnlineMessage(Message message) {
                        System.err.println("online message: "
                                + message.getMsg());
                    }

@Override
                    public void onOfflineMessage(ArrayList<Message> messages) {
                        if (messages != null)
                            for (Message message : messages) {
                                System.err.println("offline message: "
                                        + message.getMsg());
                            }
                    }

@Override
                    public void onError(Throwable e, String message) {
                        Assert.fail(message);
                    }

@Override
                    public void onClose() {
                        System.err.println("pu pu pu pu~");
                    }
                }));
    }

// @Test
    public void testNoSync() {
        GoPushCli cli = local.get();
        cli.start(false);

Assert.assertTrue("获取节点失败", cli.isGetNode());
        Assert.assertTrue("握手失败", cli.isHandshake());
        cli.destory();
    }

@Test
    public void testSync() {
        final GoPushCli cli = local.get();
        new Thread() {
            public void run() {
                cli.start(true);
            }
        }.start();
        try {
            TimeUnit.SECONDS.sleep(10000000);
        } catch (InterruptedException e) {
        }
        Assert.assertTrue("获取节点失败", cli.isGetNode());
        Assert.assertTrue("握手失败", cli.isHandshake());
        cli.destory();
    }

private ThreadLocal<GoPushCli> local = new ThreadLocal<GoPushCli>();
}

```

### 感谢
感谢@腹黑猫(QQ: 153996072)同学的代码，我只是小小的修改了一下。

gopush-cluster-sdk

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README