Java WebSocket客户端java WebSocketClient，

Java WebSocket客户端java WebSocketClient，

一、java客户端实现代码

 

package ggmes.websocket.client;

import java.net.URI;
import java.net.URISyntaxException;
import java.util.Iterator;

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

public class MsgWebSocketClient extends WebSocketClient{

	public MsgWebSocketClient(String url) throws URISyntaxException {
		super(new URI(url));
		// TODO Auto-generated constructor stub
	}

	@Override
	public void onOpen(ServerHandshake shake) {
		// TODO Auto-generated method stub
		System.out.println("握手...");
		for(Iterator<String> it=shake.iterateHttpFields();it.hasNext();) {
			String key = it.next();
			System.out.println(key+":"+shake.getFieldValue(key));
		}
	}

	@Override
	public void onMessage(String paramString) {
		// TODO Auto-generated method stub
		System.out.println("接收到消息："+paramString);
	}

	@Override
	public void onClose(int paramInt, String paramString, boolean paramBoolean) {
		// TODO Auto-generated method stub
		System.out.println("关闭...");
	}

	@Override
	public void onError(Exception e) {
		// TODO Auto-generated method stub
		System.out.println("异常"+e);
		
	}
}

二、单例初始化类：

 

 

package ggmes.websocket.pusher;

import java.net.URI;
import java.net.URISyntaxException;

import ggmes.websocket.client.MsgWebSocketClient;
import ggmes.websocket.server.MsgWebSocketServer;
import utils.ObjectUtils;

public enum WebClientEnum {

	CLIENT;
	
	private static MsgWebSocketClient socketClient = null;
	
	public static void initClient(MsgWebSocketClient client) {
		socketClient = client;
		if(ObjectUtils.isNotNull(socketClient)) {
			socketClient.connect();
			socketClient.send("测试websocket。。。");
		}
		boolean flag = true;
		int i=1000;
		while(flag) {
			socketClient.send("测试websocket。。。"+(i--));
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			if(i == 0) {
				flag = false;
			}
		}
	}
	
}

三、启动主方法：

 

 

package ggmes.websocket.bootstrap;


import java.net.InetSocketAddress;
import java.net.URISyntaxException;
import java.util.HashMap;
import java.util.Map;

import ggmes.websocket.client.MsgWebSocketClient;
import ggmes.websocket.pusher.WebClientEnum;
import ggmes.websocket.pusher.WebServerEnum;
import ggmes.websocket.server.MsgWebSocketServer;
import play.mvc.Controller;

public class SocketClientEngine{


	public static void main(String[] args) {
		try {
			WebClientEnum.CLIENT.initClient(new MsgWebSocketClient("ws://192.168.152.73:8099"));
		} catch (URISyntaxException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}