随着互联网的发展,http的协议有些时候不能满足需求,比如在现聊天的实现.如果使用http协议必须轮训,或者使用长链接.必须要一个request,这样后台才能发送信息到前端.
后台不能主动找客户端通信.而且每次请求heard都带有很多的信息.这样也很占用宽带.这是websocket.
因为主要是为了学习,所以前台很粗糙.没有css.
1.后台实现
后台一共有两个类 一个是个imessage类,就是一个信息的bean.另一个类是socket,这个类主要是处理信息的发送.
Message.java如下:
1 package com.socket; 2 3 public class Message { 4 private String id; 5 private String msg; 6 private String from; 7 private String to; 8 9 10 public String getFrom() {11 return from;12 }13 14 public void setFrom(String from) {15 this.from = from;16 }17 18 public String getTo() {19 return to;20 }21 22 public void setTo(String to) {23 this.to = to;24 }25 26 public String getId() {27 return id;28 }29 30 public void setId(String id) {31 this.id = id;32 }33 34 public String getMsg() {35 return msg;36 }37 38 public void setMsg(String msg) {39 this.msg = msg;40 }41 42 } socket.Java代码如下:
1 package com.socket; 2 3 import java.io.IOException; 4 import java.util.HashMap; 5 import java.util.Map; 6 import java.util.Set; 7 8 import javax.websocket.OnMessage; 9 import javax.websocket.OnOpen;10 import javax.websocket.Session;11 import javax.websocket.server.ServerEndpoint;12 13 import com.google.gson.Gson;14 15 @ServerEndpoint("/websocket")16 public class Socket {17 public static Map sessionMap = new HashMap ();18 private Session session;19 20 @OnOpen21 public void startSocket(Session session) {22 this.session = session;23 System.out.println("链接成功");24 if (sessionMap.size() == 0) {25 return ;26 }27 Set userIds = sessionMap.keySet();28 StringBuffer sBuffer = new StringBuffer();29 for (Object str : userIds) {30 sBuffer.append(str.toString() + ":");31 }32 Gson gson = new Gson();33 try {34 Message message = new Message();35 message.setFrom("系统");36 message.setMsg(sBuffer.toString());37 session.getBasicRemote().sendText(gson.toJson(message),true);38 } catch (IOException e) {39 // TODO Auto-generated catch block40 e.printStackTrace();41 }42 }43 44 @OnMessage45 public void getMessgae(Session session, String str, boolean last) {46 if (session.isOpen()) {47 try {48 System.out.println(str);49 Gson gson = new Gson();50 Message msg = gson.fromJson(str, Message.class);51 Message toMessage = msg;52 toMessage.setFrom(msg.getId());53 toMessage.setTo(msg.getTo());54 55 if (msg.getMsg().equals("newUser")) {56 if (sessionMap.containsKey(msg.getId())) {57 sessionMap.remove(msg.getId());58 }59 sessionMap.put(msg.getId(), session);60 } else {61 Session toSession = sessionMap.get(msg.getTo());62 if (toSession != null && toSession.isOpen()) {63 toSession.getBasicRemote().sendText(gson.toJson(toMessage).toString(), last);64 } else {65 toMessage.setMsg("用户不存在");66 toMessage.setFrom("系统");67 session.getBasicRemote().sendText(gson.toJson(toMessage).toString(), last);68 }69 }70 } catch (IOException e) {71 // TODO Auto-generated catch block72 e.printStackTrace();73 }74 75 } else {76 System.out.println("session is closed");77 }78 }79 } 2 前端代码
前台主要使用的是Jquery库来操作一些dom. 后台开启的是 8889端口，所以前端要调用 ws://localhost:8889/webChat/websocket，如果自己实现请改自己的端口
js和html如下:
Test WebSocket ID: toUser:内容:
以上的这些就是简单的实现一个在线web聊天.