很早以前为了快速达到效果，使用轮询实现了在线聊天功能，后来无意接触了socket,关于socket我的理解是进程间通信，首先要有服务器跟客户端，服务的启动监听某ip端口定位该进程，客户端开启socket分配ip端口连接服务端ip端口，于是两个进程间便可以通信了。下面简单画个图理解。
but，今天还是准备分享websocket的使用，先上效果，再贴代码。
第一步启动socket服务。
然后连接客户端连接服务器，加入聊天室，分别使用googel（白玉京，沈浪），火狐（楚留香），ie（李寻欢）进行测试，效果如下。
*
*****************断开一下。
******************断开一下。
下面是本次测试源码。
服务端：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
public class testwebsocketcontroller : controller
{
websocketserver server;
list<sessioninfo> listsession = new list<sessioninfo>();
public actionresult index()
{
return view();
}
//服务启动
public string start()
{
var ip = "192.168.1.106";
var port = "1010";
server = new websocketserver();
if (!server.setup(ip, int.parse(port)))
{
return "websocket服务启动error";
}
//新的会话连接
server.newsessionconnected += sessionconnected;
//会话关闭
server.sessionclosed += sessionclosed;
//新的消息接收
server.newmessagereceived += messagereceived;
if (!server.start())
{
//处理监听失败消息
return "error";
}
return "success";
}
/// <summary>
/// 会话关闭
/// </summary>
/// <param name="session"></param>
/// <param name="value"></param>
private void sessionclosed(websocketsession session, supersocket.socketbase.closereason value)
{
debug.writeline("会话关闭，关闭原因：{0} 来自：{1} 时间:{2:hh:mm:ss}", value, session.remoteendpoint, datetime.now);
//sendmsgtoremotepoint(sessionid, sessionid + "已断开");
var sessionremove = listsession.firstordefault(s => s.sessionid == session.sessionid);
listsession.remove(sessionremove);
}
/// <summary>
/// 会话连接
/// </summary>
/// <param name="session"></param>
private void sessionconnected(websocketsession session)
{
debug.writeline("新的会话连接 来自：{0} sessionid:{1} 时间:{2:hh:mm:ss}", session.remoteendpoint, session.sessionid, datetime.now);
listsession.add(new sessioninfo { sessionid = session.sessionid, endpoint = session.remoteendpoint.tostring() });
}
/// <summary>
/// 消息接收
/// </summary>
/// <param name="session"></param>
/// <param name="value"></param>
private void messagereceived(websocketsession session, string value)
{
//反序列化消息内容
var message = jsonconvert.deserializeobject<messageinfo>(value);
foreach (var item in listsession)
{
///发送消息
sendmsg(item.sessionid, string.format("{0}发来消息：{1}", message.name, message.message));
}
}
// <summary>
/// 发送消息
/// </summary>
/// <param name="sessionid"></param>
/// <param name="msg"></param>
private void sendmsg(string sessionid, string msg)
{
var appsession = server.getappsessionbyid(sessionid);
if (appsession != null)
appsession.send(msg);
}
public class messageinfo
{
public string name { get; set; }
public string message { get; set; }
}
public class sessioninfo
{
public string sessionid { get; set; }
public string endpoint { get; set; }
//public string name { get; set; }
}
}
|
客户端：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
@{
viewbag.title = "index";
}
<h2>index</h2>
<script src="../scripts/jquery-1.8.2.js"></script>
<input type="text" id="txtname" />
<input type="button" value="加入聊天室" id="btnconnection" />
<input type="button" value="离开聊天室" id="btndisconnection" />
<input type="text" id="txtinput" />
<input type="button" value="发送" id="btnsend" />
<div id="msg"></div>
<script language="javascript" type="text/javascript">
var ws;
var url = "ws://192.168.1.106:1010"
$("#btnconnection").click(function () {
if ("websocket" in window) {
ws = new websocket(url);
}
else if ("mozwebsocket" in window) {
ws = new mozwebsocket(url);
}
else
alert("浏览器版本过低，请升级您的浏览器");
//注册各类回调
ws.onopen = function () {
$("#msg").append($("#txtname").val() + "加入聊天室<br />");
}
ws.onclose = function () {
$("#msg").append($("#txtname").val() + "离开聊天室<br />");
}
ws.onerror = function () {
$("#msg").append("数据传输发生错误<br />");
}
ws.onmessage = function (receivemsg) {
$("#msg").append(receivemsg.data + "<br />");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function () {
ws.close();
}
});
//$("#btndisconnection").click(function () {
// $("#msg").append($("#txtname").val() + "离开聊天室<br />");
// ws.close();
//});
$("#btnsend").click(function () {
if (ws.readystate == websocket.open) {
var message = "{\"name\":\"" + $("#txtname").val() + "\",\"message\":\"" + $("#txtinput").val() + "\"}";
ws.send(message);
}
else {
$("#msg").text("connection is closed!");
}
});
</script>
|
总结
以上所述是小编给大家介绍的java中使用websocket实现在线聊天功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！
原文链接：http://www.cnblogs.com/baiyujing/p/8458567.html