Web Browser and Android and iOS OkHttp3 Nodejs WebSocket SocketIO Starscream
https://github.com/JetBrains/kotlin
class WebSocketClient{
private val WS_IP_PORT = "192.168.5.101:8181"
private var client: OkHttpClient? = null
private var webSocket: WebSocket? = null
@Synchronized fun startRequest() {
if (null == client) {
client = OkHttpClient()
}
if (null == webSocket) {
val request = Request.Builder()
.url("ws://" + WS_IP_PORT + "/ws")
.addHeader("Origin", "http://" + WS_IP_PORT)
.build()
webSocket = client!!.newWebSocket(request, EchoWebSocketListener())
}
}
private fun sendMessage(webSocket: WebSocket?) {
webSocket!!.send("Hello!")
webSocket!!.send(ByteString.decodeHex("Hello!"))
}
fun closeWebSocket(){
if (null != webSocket) {
webSocket!!.close(NORMAL_CLOSURE_STATUS, "Goodbye!")
webSocket = null
}
}
fun destroy(){
if (null != client) {
client!!.dispatcher().executorService().shutdown()
client = null
}
}
fun resetWebSocket(){
synchronized(WebSocketClient::class.java) {
webSocket = null
}
}
inner class EchoWebSocketListener : WebSocketListener() {
override fun onOpen(webSocket: WebSocket?, response: Response?) {
super.onOpen(webSocket, response)
L.d("------------------------------------ onOpen")
sendMessage(webSocket!!)
}
override fun onClosed(webSocket: WebSocket?, code: Int, reason: String?) {
super.onClosed(webSocket, code, reason)
L.d("------------------------------------ onClosed")
}
override fun onClosing(webSocket: WebSocket?, code: Int, reason: String?) {
super.onClosing(webSocket, code, reason)
L.d("------------------------------------ onClosing")
}
override fun onFailure(webSocket: WebSocket?, t: Throwable?, response: Response?) {
super.onFailure(webSocket, t, response)
L.d("------------------------------------ onFailure ", t!!.message)
}
override fun onMessage(webSocket: WebSocket?, bytes: ByteString?) {
super.onMessage(webSocket, bytes)
L.d("------------------------------------ onMessage", bytes!!.toString())
}
override fun onMessage(webSocket: WebSocket?, text: String?) {
super.onMessage(webSocket, text)
L.d("------------------------------------ onMessage" + text!!)
}
}
}
var WebSocketServer = require('ws').Server,
wss = new WebSocketServer({ port: 8181 });
wss.on('connection', function (ws) {
console.log('client connect...');
//监听消息发送事件
ws.on('message', function (message) {
console.log("getMessage" + message);
});
//客户端关闭
ws.on('close', function () {
console.log('client disconnect...');
});
});
var Server = require('socket.io');
var _ = require("lodash");
var arrClient = [];
var io = null;
exports.init = function(server, isDebug){
io = new Server().listen(server);
//设置可以传输数据类型
io.set('transports', [
'websocket',
'flashsocket',
'htmlfile',
'polling'
]);
io.on('connection', function (socket) {
var client = {
socket : socket,
socketId: socket.id
};
//进入链接
socket.on('login', function(objUser){
console.log('user : ' + objUser.name + ' login ...');
client.user = objUser;
client.userId = objUser.id;
arrClient.push(client);
});
//监听退出事件
socket.on('disconnect', function () {
//去除掉线对象
_.remove(arrClient, function(obj) {
return obj.socketId === socket.id;
});
if(client.user){
console.log('user : 1' + client.user.name + ' disconnect ...');
}else{
console.log('user : 2 undefined disconnect ...');
}
});
});
};
node shell
npm install
node app.js
or
node app.js debug
debug http://ip:port/index.html
or
http://ip:port/index2.html
data server --> http --> pushData --> node WebSocketServer --> websocket --> client
public static String post(String request, List<BasicNameValuePair> params) {
String html = "";
try {
CloseableHttpClient httpclient = HttpClients.createDefault();
HttpPost httppost = new HttpPost(request);
UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8");
httppost.setEntity(formEntity);
HttpResponse response = httpclient.execute(httppost);
HttpEntity entity = response.getEntity();
html = EntityUtils.toString(entity);
httpclient.close();
} catch (Exception e) {
e.printStackTrace();
} finally {
}
return html;
}
public static void main(String[] args) {
int i = 0;
for (;;) {
i++;
String value = " Hello! " + i;
JSONObject data = new JSONObject();
data.put("data", value);
BasicNameValuePair basicNameValuePair = new BasicNameValuePair("data", data.toJSONString());
List<BasicNameValuePair> values = new ArrayList<BasicNameValuePair>(0);
values.add(basicNameValuePair);
state = post("http://192.168.5.101:8888/pushData", values);
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
Reference: https://github.com/nkzawa/socket.io-android-chat
class SocketIOClient {
private var socket: Socket? = null
fun connect() {//连接
socket = IO.socket("http://192.168.5.100:3000/");
socket!!.on(Socket.EVENT_CONNECT, object : Emitter.Listener {
override fun call(vararg p0: Any?) {
L.d("---------------------------------EVENT_CONNECT")
}
}).on(Socket.EVENT_ERROR, object : Emitter.Listener {
override fun call(vararg p0: Any?) {
L.d("---------------------------------EVENT_ERROR")
}
}).on(Socket.EVENT_RECONNECT_FAILED, object : Emitter.Listener {
override fun call(vararg p0: Any?) {
L.d("---------------------------------EVENT_RECONNECT_FAILED")
}
})
socket!!.connect()
}
}
//log
compile 'com.safframework.log:saf-log:1.0.5'
compile ('io.socket:socket.io-client:0.8.3') {
// excluding org.json which is provided by Android
exclude group: 'org.json', module: 'json'
}
#Web Client
var socket = io.connect('192.168.5.100:3000');
var receiveContent = $('#receiveContent');
//收到server的连接确认
//收到server的连接确认
socket.on('connect',function(){
$('#status').html('链接成功.......');
isConnected = true;
socket.emit('login', {
id: '0',
name: 'void'
});
console && console.log('connected is ok');
});
socket.on('message',function(param){
console.log(param);
receiveContent.html(param.message);
});
var websocket = null;
//判断当前浏览器是否支持WebSocket
if('WebSocket' in window){
websocket = new WebSocket("ws://192.168.5.101:8181/ws");
}
else{
alert('Not support websocket')
}
//连接发生错误的回调方法
websocket.onerror = function(){
setMessageInnerHTML("error");
};
//连接成功建立的回调方法
websocket.onopen = function(event){
setMessageInnerHTML("open");
}
//接收到消息的回调方法
websocket.onmessage = function(event){
setMessageInnerHTML(event.data);
}
//连接关闭的回调方法
websocket.onclose = function(){
setMessageInnerHTML("close");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function(){
websocket.close();
}
//将消息显示在网页上
function setMessageInnerHTML(innerHTML){
document.getElementById('message').innerHTML += innerHTML + '<br/>';
}
//关闭连接
function closeWebSocket(){
websocket.close();
}
//发送消息
function send(){
var message = document.getElementById('text').value;
websocket.send(message);
}
pod install
import Starscream
class ViewController: UIViewController, WebSocketDelegate {
var socket: WebSocket = WebSocket(url: URL(string: "ws://192.168.5.100:8181/ws")!)
override func viewDidLoad() {
super.viewDidLoad()
// Do any additional setup after loading the view, typically from a nib.
connect()
}
func connect(){
socket.delegate = self
socket.connect()
}
override func didReceiveMemoryWarning() {
super.didReceiveMemoryWarning()
// Dispose of any resources that can be recreated.
}
func websocketDidConnect(_ socket: WebSocket) {
print("------------------->> websocketDidConnect")
sendMessage()
}
func sendMessage(){
socket.write(string: "Hello World! ")
}
func websocketDidDisconnect(_ socket: WebSocket, error: NSError?) {
print("------------------->> websocketDidDisconnect")
}
func websocketDidReceiveData(_ socket: WebSocket, data: Data) {
print("------------------->> websocketDidReceiveData")
}
func websocketDidReceiveMessage(_ socket: WebSocket, text: String) {
print("------------------->> websocketDidReceiveMessage")
}
}