首页 > 代码库 > netty-socketio
netty-socketio
一、简介
netty-socketio是一个开源的Socket.io服务器端的一个java的实现，它基于Netty框架。项目地址为：https://github.com/mrniko/netty-socketio 。socket.io是一个跨浏览器使用websocket为实时实时应用提供服务。本例子使用maven构建，依赖如下：
<dependency> <groupId>com.corundumstudio.socketio</groupId> <artifactId>netty-socketio</artifactId> <version>1.6.5</version></dependency>
客户端使用的是socket.io-client，下载地址为:https://github.com/Automattic/socket.io-client。
二、相关代码
服务器端：
消息实体
1 package com.test.socket; 2 3 public class ChatObject { 4 5 private String userName; 6 private String message; 7 8 public ChatObject() { 9 }10 11 public ChatObject(String userName, String message) {12 super();13 this.userName = userName;14 this.message = message;15 }16 17 public String getUserName() {18 return userName;19 }20 21 public void setUserName(String userName) {22 this.userName = userName;23 }24 25 public String getMessage() {26 return message;27 }28 29 public void setMessage(String message) {30 this.message = message;31 }32 33 }
监听器
1 package com.test.socket; 2 3 import com.corundumstudio.socketio.AckRequest; 4 import com.corundumstudio.socketio.SocketIOClient; 5 import com.corundumstudio.socketio.SocketIOServer; 6 import com.corundumstudio.socketio.listener.DataListener; 7 8 public class CharteventListener implements DataListener<ChatObject> { 9 10 SocketIOServer server;11 12 public void setServer(SocketIOServer server) {13 this.server = server;14 }15 16 public void onData(SocketIOClient client, ChatObject data,17 AckRequest ackSender) throws Exception {18 //chatevent为 事件的名称，data为发送的内容19 this.server.getBroadcastOperations().sendEvent("chatevent", data);20 }21 22 }
服务器端启动代码
1 package com.test.socket; 2 3 import com.corundumstudio.socketio.Configuration; 4 import com.corundumstudio.socketio.SocketIOServer; 5 6 public class SocketServer { 7 public static void main(String[] args) throws InterruptedException { 8 9 Configuration config = new Configuration();10 config.setHostname("localhost");11 config.setPort(9092);12 13 SocketIOServer server = new SocketIOServer(config); 14 15 CharteventListener listner = new CharteventListener();16 listner.setServer(server);17 // chatevent为事件名称18 server.addEventListener("chatevent", ChatObject.class, listner); 19 //启动服务20 server.start();21 22 Thread.sleep(Integer.MAX_VALUE);23 24 server.stop();25 }26 27 }28
运行该类，服务器端即可启动
客户端message.html代码如下:
1 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 2 <html> 3 <head> 4 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 5 <title>Insert title here</title> 6 <script src="./jquery-1.9.1.js" type="text/javascript"></script> 7 <script type="text/javascript" src="./socket.io/socket.io.js"></script> 8 <style> 9 body { 10 padding:20px;11 }12 #console { 13 height: 400px; 14 overflow: auto; 15 }16 .username-msg {color:orange;}17 .connect-msg {color:green;}18 .disconnect-msg {color:red;}19 .send-msg {color:#888}20 </style>21 </head>22 <body>23 <h1>Netty-socketio示例</h1>24 <br/>25 <div id="console" class="well">26 </div>27 <form class="well form-inline" onsubmit="return false;">28 <input id="name" class="input-xlarge" type="text" placeholder="用户名称..."/>29 <input id="msg" class="input-xlarge" type="text" placeholder="发送内容..."/>30 <button type="button" onClick="sendMessage()" class="btn">Send</button>31 <button type="button" onClick="sendDisconnect()" class="btn">Disconnect</button>32 </form>33 </body>34 <script type="text/javascript">35 var socket = io.connect(‘http://localhost:9092‘);36 37 socket.on(‘connect‘, function() {38 output(‘<span class="connect-msg">Client has connected to the server!</span>‘);39 });40 41 socket.on(‘chatevent‘, function(data) {42 output(‘<span class="username-msg">‘ + data.userName + ‘:</span> ‘ + data.message);43 });44 45 socket.on(‘disconnect‘, function() {46 output(‘<span class="disconnect-msg">The client has disconnected!</span>‘);47 });48 function sendDisconnect() {49 socket.disconnect();50 }51 52 function sendMessage() {53 var userName = $("#name").val()54 var message = $(‘#msg‘).val();55 $(‘#msg‘).val(‘‘);56 socket.emit(‘chatevent‘, {userName: userName, message: message});57 }58 59 function output(message) {60 var currentTime = "<span class=‘time‘>" + new Date() + "</span>";61 var element = $("<div>" + currentTime + " " + message + "</div>");62 $(‘#console‘).prepend(element);63 }64 </script>65 </html>
客户端需要引入jquery与socket.io.js文件。
在浏览器打开该html文件,输入用户名称以及消息内容发送，服务器端获取到发送的内容之后，会将该消息发送会客户端，客户端接收到从服务器端返回的消息或，将该消息添加到页面并显示。运行效果如下图:
netty-socketio
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。