pom.xml (虽然配置了maven tomcat7插件,但是直接从maven中启动web服务，websocket服务启动不了。要将web服务部署到tomcat7 server上。可以直接打包war，也可以在开发工具中引入tomcat7)

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
< project  xmlns = "http://maven.apache.org/POM/4.0.0"  xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd" >
     < modelVersion >4.0.0</ modelVersion >
     < groupId >web</ groupId >
     < artifactId >web</ artifactId >
     < packaging >war</ packaging >
     < version >1.0-SNAPSHOT</ version >
     < name >web Maven Webapp</ name >
     < url >http://maven.apache.org</ url >
     < dependencies >
         < dependency >
             < groupId >javax.websocket</ groupId >
             < artifactId >javax.websocket-api</ artifactId >
             < version >1.1</ version >
             < scope >provided</ scope >
         </ dependency >
     </ dependencies >
     < build >
         < finalName >web</ finalName >
 
         < plugins >
             < plugin >
                 < groupId >org.apache.tomcat.maven</ groupId >
                 < artifactId >tomcat7-maven-plugin</ artifactId >
                 < version >2.1</ version >
                 < configuration >
                     < port >8077</ port >
                     < path >/web</ path >
                     < uriEncoding >UTF-8</ uriEncoding >
                     < finalName >web</ finalName >
                     < server >tomcat7</ server >
                 </ configuration >
             </ plugin >
         </ plugins >
     </ build >
 
</ project >

websocket.server.SimpleServer

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
package  websocket.server;
 
import  javax.websocket.*;
import  javax.websocket.server.ServerEndpoint;
import  java.io.IOException;
import  java.util.logging.Logger;
 
/**
  * Created by Administrator on 2016/4/17.
  */
@ServerEndpoint ( "/SimpleWebSocket" )
public  class  SimpleServer {
 
     private  Logger logger = Logger.getLogger( this .getClass().getName());
 
     @OnOpen
     public  void  onOpen(Session session){
         logger.info( "websocket open ... " );
         System.out.println(session);
     }
 
     /**
      * 连接关闭调用的方法
      */
     @OnClose
     public  void  onClose(){
         logger.info( "websocket close .... " );
     }
 
     @OnError
     public  void  onError(Throwable e){
         logger.severe( "error～～～～" +e.getMessage());
     }
 
     /**
      * 收到客户端消息后调用的方法
      * @param message 客户端发送过来的消息
      * @param session 可选的参数
      */
     @OnMessage
     public  void  onMessage(String message, Session session)  throws  IOException {
         logger.info( "receive the message from client [" +message+ "]" );
 
         session.getBasicRemote().sendText( "服务器收到客户端的信息:" +message);
     }
}

simple.html

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
<!DOCTYPE html>
< html >
< head >
     < title >Testing websockets</ title >
</ head >
< body >
 
     < input  type = "text"  id = "input" />
     < input  type = "button"  id = "button"  value = "send" />
 
< script  type = "text/javascript" >
     var webSocket =  new WebSocket('ws://localhost:8077/web/SimpleWebSocket');
 
     webSocket.onerror = function(event) {
         console.log("error ... ");
         console.log(event.data);
     };
 
     webSocket.onopen = function(event) {
         console.log("open ... ");
         console.log(event.data)
     };
 
     webSocket.onmessage = function(event) {
         console.log("[message]:"+event.data);
     };
 
     var btn = document.getElementById("button");
     var input = document.getElementById("input");
     btn.onclick = function(){
         var value = input.value;
         webSocket.send(value);
         input.value="";
     };
</ script >
</ body >
</ html >