消息机制代码,Java代码库,德仔网

代码语言

代码分类

【Java】消息机制

作者:枯心人 / 发布于2016/1/11/ 618

package com.zhjh.push.test;
  
import com.zhjh.push.auth.AuthenticatePool;
import com.zhjh.push.auth.Authentication;
import com.zhjh.push.auth.IAuthenticate;
import com.zhjh.push.message.PushMessage;
import com.zhjh.push.server.OfflineMessageManager;
import com.zhjh.push.server.PushServer;
  
public class TestPushServer {
    public static void main(String[] args) throws Exception {
        OfflineMessageManager offlineMessageManager = new OfflineMessageManager(5, 1);
        PushServer pushServer = new PushServer(8080, new AuthenticatePool(new IAuthenticate() {
              
            public boolean authenticate(Authentication authentication) {
                return true;
            }
        }), offlineMessageManager);
        pushServer.start();
        PushMessage pushMessage = new PushMessage();
        pushMessage.addUser("user1");
        pushMessage.addUser("user2");
        pushMessage.addUser("user3");
        pushMessage.addUser("user4");
        pushMessage.setMessage("Hello, This is PushServer!");
        while(true) {
            pushServer.push(pushMessage);
            Thread.sleep(1000);
        }
    }
} 
package com.zhjh.push.test;
  
import com.zhjh.push.client.IPushClientProcess;
import com.zhjh.push.client.PushClient;
  
public class TestPushClient {
    public static void main(String[] args) {
        PushClient client = new PushClient("127.0.0.1", 8080, "user1", null, new IPushClientProcess() {
              
            public void onMessage(String message) {
                System.out.println("收到消息：" + message);
            }
              
            public void onSuccess() {
                System.out.println("login success");
            }
              
            public void onError(String error) {
                System.out.println("Error: " + error);
            }
        });
        client.start();
    }
}

试试其它关键字

　消息机制　

同语言下

可能有用的

枯心人贡献的其它代码(1)

.消息机制