设为首页 加入收藏

TOP

用Java分别实现WebSocket客户端与服务端(一)
2019-02-10 22:08:46 】 浏览:194
Tags:Java 分别 实现 WebSocket 客户端 服务

 


最近公司在搞一个项目刚好需要用到WebSocket技术来实现实时数据的传输,因为之前也没接触过,所以捣鼓了好些天,最近恰巧有空就写写。有误的地方还请大牛们能及时指正。


 


项目背景:基于spring+spring MVC+mybatis框架的maven项目


 


服务端:


 


1、添加Jar包依赖:


 


<dependency>
  <groupId>javax.websocket</groupId>
  <artifactId>javax.websocket-api</artifactId>
  <version>1.1</version>
  <scope>provided</scope>
</dependency>


 


2、创建一个WebSocket服务端类MyWebSocketServer,并在类前添加@ServerEndpoint(value = "/websocket")注解,@ServerEndpoint(value = "/websocket")注释端点表示将 WebSocket 服务端运行在 ws://[Server 端 IP 或域名]:[Server 端口]/项目名/websocket 的访问端点


 


3、实现onOpen、onClose、onMessage、onError等方法


 


实例代码:


 


MyWebSocketServer 类


 


import java.io.IOException;
import javax.websocket.EncodeException;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import net.sf.json.JSONObject;


 


@ServerEndpoint(value = "/websocket")
public class MyWebSocketServer {


 


  private Logger logger = Logger.getLogger(MyWebSocketServer.class);
  private Session session;


 


  /**
   * 连接建立后触发的方法
   */
  @OnOpen
  public void onOpe

n(Session session){
    this.session = session;
    logger.info("onOpen"+session.getId());
    WebSocketMapUtil.put(session.getId(),this);
  }


 



  /**
   * 连接关闭后触发的方法
   */
  @OnClose
  public void onClose(){
    //从map中删除
    WebSocketMapUtil.remove(session.getId());
    logger.info("====== onClose:"+session.getId()+" ======");
  }


 



  /**
   * 接收到客户端消息时触发的方法
   */
  @OnMessage
  public void onMessage(String params,Session session) throws Exception{
    //获取服务端到客户端的通道
    MyWebSocketServer myWebSocket = WebSocketMapUtil.get(session.getId());
    logger.info("收到来自"+session.getId()+"的消息"+params);
    String result = "收到来自"+session.getId()+"的消息"+params;
    //返回消息给Web Socket客户端(浏览器)
    myWebSocket.sendMessage(1,”成功!”,result);
  }


 



  /**
   * 发生错误时触发的方法
   */
  @OnError
  public void onError(Session session,Throwable error){
    logger.info(session.getId()+"连接发生错误"+error.getMessage());
    error.printStackTrace();
  }


 


  public void sendMessage(int status,String message,Object datas) throws IOException{
    JSONObject result = new JSONObject();
    result.put("status", status);
    result.put("message", message);
    result.put("datas", datas);
        this.session.getBasicRemote().sendText(result.toString());
    }


 


}


 


WebSocketMapUtil 工具类


 


import java.util.Collection;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;


 


public class WebSocketMapUtil {


 


  public static ConcurrentMap<String, MyWebSocketServer> webSocketMap = new ConcurrentHashMap<>();


 


  public static void put(String key, MyWebSocketServer myWebSocketServer){
      webSocketMap.put(key, myWebSocketServer);
    }


 


    public static MyWebSocketServer get(String key){
  &nbs
编程开发网

首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇ThinkPHP+JQuery实现文件的异步上.. 下一篇Java WebSocket 使用时需要注意的..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(217) }