日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

Java EE 7已經(jīng)在今年正式發(fā)布了，新增加了很多新的功能和特性，如新增或更新了不少的JSR標(biāo)準(zhǔn)。其中特別受到關(guān)注的是Websockets。它的一個好處之一是減少了不必要的網(wǎng)絡(luò)流量。它主要是用于在客戶機和服務(wù)器之間建立單一的雙向連接。這意味著客戶只需要發(fā)送一個請求到服務(wù)端，那么服務(wù)端則會進行處理，處理好后則將其返回給客戶端，客戶端則可以在等待這個時間繼續(xù)去做其他工作，整個過程是異步的。在本系列教程中，將指導(dǎo)用戶如何在JAVA EE　7的容器GlassFish 4中，使用JAVA EE 7中的全新的解析Json API(JSR-353)，以及綜合運用jQuery和Bootstrap。本文要求讀者有一定的HTML 5 Websocket的基礎(chǔ)原理知識。

按需定制設(shè)計可以根據(jù)自己的需求進行定制，成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)構(gòu)思過程中功能建設(shè)理應(yīng)排到主要部位公司成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)的運用實際效果公司網(wǎng)站制作網(wǎng)站建立與制做的實際意義

效果圖

我們先來看下在完成這個教程后的效果圖，如下所示：

準(zhǔn)備工作

我們使用的是JDK 7 和MAVN 3進行庫的構(gòu)建工作，首先看pom.xml中關(guān)于Jave EE 7的部分：

 
 
 
 

  
  
  
  
 
  
  
  
  
    ${project.build.directory}/endorsed
  
  
  
  
    UTF-8
  
  
  
  

  
  
  
  
 
  
  
  
  

  
  
  
  
    
  
  
  
  
        javax
  
  
  
  
        javaee-api
  
  
  
  
        7.0
  
  
  
  
        provided
  
  
  
  
    
  
  
  
  

  
  
  
  
 
  
  
  
  

  
  
  
  
    
  
  
  
  
        
  
  
  
  
            org.apache.maven.plugins
  
  
  
  
            maven-compiler-plugin
  
  
  
  
            3.1
  
  
  
  
            
  
  
  
  
                1.7
  
  
  
  
                1.7
  
  
  
  
                
  
  
  
  
                    ${endorsed.dir}
  
  
  
  
                
  
  
  
  
            
  
  
  
  
        
  
  
  
  
        
  
  
  
  
            org.apache.maven.plugins
  
  
  
  
            maven-war-plugin
  
  
  
  
            2.3
  
  
  
  
            
  
  
  
  
                false
  
  
  
  
            
  
  
  
  
        
  
  
  
  
        
  
  
  
  
            org.apache.maven.plugins
  
  
  
  
            maven-dependency-plugin
  
  
  
  
            2.6
  
  
  
  
            [..]
  
  
  
  
        
  
  
  
  
    
  
  
  
  

 
 
 
 

同時，為了能使用GlassFish 4，需要增加如下的插件：

 
 
 
 

  
  
  
  
plugin>
  
  
  
  
    org.glassfish.embedded
  
  
  
  
    maven-embedded-glassfish-plugin
  
  
  
  
    4.0
  
  
  
  
    
  
  
  
  
        embedded-glassfish
  
  
  
  
        ${basedir}/target/${project.artifactId}-${project.version}.war
  
  
  
  
        true
  
  
  
  
        8080
  
  
  
  
        ${project.artifactId}
  
  
  
  
        hascode
  
  
  
  
    
  
  
  
  
    
  
  
  
  
        
  
  
  
  
            
  
  
  
  
                deploy
  
  
  
  
            
  
  
  
  
        
  
  
  
  
    
  
  
  
  

 
 
 
 

設(shè)置Websocket的Endpoint

我們先來看服務(wù)端Websocket的代碼如下，然后再做進一步解析：

 
 
 
 

  
  
  
  
package com.hascode.tutorial;
  
  
  
  
 
  
  
  
  
import java.io.IOException;
  
  
  
  
import java.util.logging.Level;
  
  
  
  
import java.util.logging.Logger;
  
  
  
  
 
  
  
  
  
import javax.websocket.EncodeException;
  
  
  
  
import javax.websocket.OnMessage;
  
  
  
  
import javax.websocket.OnOpen;
  
  
  
  
import javax.websocket.Session;
  
  
  
  
import javax.websocket.server.PathParam;
  
  
  
  
import javax.websocket.server.ServerEndpoint;
  
  
  
  
 
  
  
  
  
@ServerEndpoint(value = "/chat/{room}", encoders = ChatMessageEncoder.class, decoders = ChatMessageDecoder.class)
  
  
  
  
public class ChatEndpoint {
  
  
  
  
    private final Logger log = Logger.getLogger(getClass().getName());
  
  
  
  
 
  
  
  
  
    @OnOpen
  
  
  
  
    public void open(final Session session, @PathParam("room") final String room) {
  
  
  
  
        log.info("session openend and bound to room: " + room);
  
  
  
  
        session.getUserProperties().put("room", room);
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @OnMessage
  
  
  
  
    public void onMessage(final Session session, final ChatMessage chatMessage) {
  
  
  
  
        String room = (String) session.getUserProperties().get("room");
  
  
  
  
        try {
  
  
  
  
            for (Session s : session.getOpenSessions()) {
  
  
  
  
                if (s.isOpen()
  
  
  
  
                        && room.equals(s.getUserProperties().get("room"))) {
  
  
  
  
                    s.getBasicRemote().sendObject(chatMessage);
  
  
  
  
                }
  
  
  
  
            }
  
  
  
  
        } catch (IOException | EncodeException e) {
  
  
  
  
            log.log(Level.WARNING, "onMessage failed", e);
  
  
  
  
        }
  
  
  
  
    }
  
  
  
  
}
 
 
 
 

#p#

面分析下上面的代碼：

使用@ ServerEndpoint定義一個新的endpoint，其中的值指定了URL并且可以使用PathParams參數(shù)，就象在JAX-RS中的用法一樣。

所以值“/chat/{room}”允許用戶通過如下形式的URL去連接某個聊天室：ws://0.0.0.0:8080/hascode/chat/java

在大括號中的值（即room），可以通過使用javax.websocket.server.PathParam，在endpoint的生命周期回調(diào)方法中以參數(shù)的方式注入。

此外，我們要使用一個編碼和解碼的類，因為我們使用的是一個DTO形式的類，用于在服務(wù)端和客戶端傳送數(shù)據(jù)。

當(dāng)用戶第一次連接到服務(wù)端，輸入要進入聊天室的房號，則這個房號以參數(shù)的方式注入提交，并且使用session.getUserProperties將值保存在用戶的屬性map中。

當(dāng)一個聊天參與者通過tcp連接發(fā)送信息到服務(wù)端,則循環(huán)遍歷所有已打開的session,每個session被綁定到指定的聊天室中,并且接收編碼和解碼的信息。

如果我們想發(fā)送簡單的文本信息或和二進制格式的信息，則可以使用session.getBasicRemote().sendBinary() 或session.getBasicRemote().sendText()

接下來我們看下用于代表信息傳遞實體(DTO:Data Transfer Object)的代碼，如下：

 
 
 
 

  
  
  
  
package com.hascode.tutorial;
  
  
  
  
 
  
  
  
  
import java.util.Date;
  
  
  
  
 
  
  
  
  
public class ChatMessage {
  
  
  
  
    private String message;
  
  
  
  
    private String sender;
  
  
  
  
    private Date received;
  
  
  
  
 
  
  
  
  
    // 其他getter,setter方法
  
  
  
  
}
 
 
 
 

聊天消息的轉(zhuǎn)換

在這個應(yīng)用中，將編寫一個編碼和解碼類，用于在聊天信息和JSON格式間進行轉(zhuǎn)換。

先來看下解碼類的實現(xiàn)，這將會把傳遞到服務(wù)端的聊天信息轉(zhuǎn)換為ChatMessage實體類。在這里，使用的是Java API for JSON Processing(JSR353)（參考：

http://jcp.org/en/jsr/detail?id=353）規(guī)范去將JSON格式的信息轉(zhuǎn)換為實體類，代碼如下，其中重寫的willDecode方法，這里默認返回為true。

 
 
 
 

  
  
  
  
package com.hascode.tutorial;
  
  
  
  
 
  
  
  
  
import java.io.StringReader;
  
  
  
  
import java.util.Date;
  
  
  
  
 
  
  
  
  
import javax.json.Json;
  
  
  
  
import javax.json.JsonObject;
  
  
  
  
import javax.websocket.DecodeException;
  
  
  
  
import javax.websocket.Decoder;
  
  
  
  
import javax.websocket.EndpointConfig;
  
  
  
  
 
  
  
  
  
public class ChatMessageDecoder implements Decoder.Text {
  
  
  
  
    @Override
  
  
  
  
    public void init(final EndpointConfig config) {
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @Override
  
  
  
  
    public void destroy() {
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @Override
  
  
  
  
    public ChatMessage decode(final String textMessage) throws DecodeException {
  
  
  
  
        ChatMessage chatMessage = new ChatMessage();
  
  
  
  
        JsonObject obj = Json.createReader(new StringReader(textMessage))
  
  
  
  
                .readObject();
  
  
  
  
        chatMessage.setMessage(obj.getString("message"));
  
  
  
  
        chatMessage.setSender(obj.getString("sender"));
  
  
  
  
        chatMessage.setReceived(new Date());
  
  
  
  
        return chatMessage;
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @Override
  
  
  
  
    public boolean willDecode(final String s) {
  
  
  
  
        return true;
  
  
  
  
    }
  
  
  
  
}
 
 
 
 

同樣再看下編碼類的代碼，這個類相反，是將ChatMessage類轉(zhuǎn)換為Json格式，代碼如下：

 
 
 
 

  
  
  
  
package com.hascode.tutorial;
  
  
  
  
 
  
  
  
  
import javax.json.Json;
  
  
  
  
import javax.websocket.EncodeException;
  
  
  
  
import javax.websocket.Encoder;
  
  
  
  
import javax.websocket.EndpointConfig;
  
  
  
  
 
  
  
  
  
public class ChatMessageEncoder implements Encoder.Text {
  
  
  
  
    @Override
  
  
  
  
    public void init(final EndpointConfig config) {
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @Override
  
  
  
  
    public void destroy() {
  
  
  
  
    }
  
  
  
  
 
  
  
  
  
    @Override
  
  
  
  
    public String encode(final ChatMessage chatMessage) throws EncodeException {
  
  
  
  
        return Json.createObjectBuilder()
  
  
  
  
                .add("message", chatMessage.getMessage())
  
  
  
  
                .add("sender", chatMessage.getSender())
  
  
  
  
                .add("received", chatMessage.getReceived().toString()).build()
  
  
  
  
                .toString();
  
  
  
  
    }
  
  
  
  
}
 
 
 
 

這里可以看到JSR-353的強大威力，只需要調(diào)用Json.createObjectBuilder就可以輕易把一個DTO對象轉(zhuǎn)化為JSON了。

#p#

通過Bootstrap、Javacsript搭建簡易客戶端

最后，我們綜合運用著名的Bootstrap、jQuery框架和Javascript設(shè)計一個簡易的客戶端。我們在src/main/weapp目錄下新建立index.html文件，代碼如下：

 
 
 
 

  
  
  
  

  
  
  
  

  
  
  
  

  
  
  
  
[..]
  
  
  
  

  
  
  
  

  
  
  
  
 
  
  
  
  

  
  
  
  
 
  
  
  
  
    
  
  
  
  
        
  
  
  
  
            Chat sign in
  
  
  
  
            Nickname 
  
  
  
  
                class="input-block-level" placeholder="Nickname" id="nickname">
  
  
  
  
            
  
  
  
  
                Chatroom 
  
  
  
  
                    id="chatroom">
  
  
  
  
                    arduino
  
  
  
  
                    java
  
  
  
  
                    groovy
  
  
  
  
                    scala