Maison du Libre | Brest

Outils pour utilisateurs

Outils du site

Piste : • stagejava
projets:2018:stagejava

Différences

Ci-dessous, les différences entre deux révisions de la page.

Lien vers cette vue comparative

Les deux révisions précédentesRévision précédente
Prochaine révision		Révision précédente
projets:2018:stagejava [2019/03/02 14:33] – christian.jacolotprojets:2018:stagejava [2024/04/16 22:26] (Version actuelle) – modification externe 127.0.0.1
Ligne 531: Ligne 531:
 </project> </project>
 </code> </code>
 +
 +
 +class ChatWebsocket.java
 +<code>
 +/*
 + *  Licensed to the Apache Software Foundation (ASF) under one or more
 + *  contributor license agreements.  See the NOTICE file distributed with
 + *  this work for additional information regarding copyright ownership.
 + *  The ASF licenses this file to You under the Apache License, Version 2.0
 + *  (the "License"); you may not use this file except in compliance with
 + *  the License.  You may obtain a copy of the License at
 + *
 + *      http://www.apache.org/licenses/LICENSE-2.0
 + *
 + *  Unless required by applicable law or agreed to in writing, software
 + *  distributed under the License is distributed on an "AS IS" BASIS,
 + *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + *  See the License for the specific language governing permissions and
 + *  limitations under the License.
 + */
 +package net.mdl29.websocket;
 +
 +import java.io.IOException;
 +import java.util.Set;
 +import java.util.concurrent.CopyOnWriteArraySet;
 +import java.util.concurrent.atomic.AtomicInteger;
 +
 +import javax.websocket.OnClose;
 +import javax.websocket.OnError;
 +import javax.websocket.OnMessage;
 +import javax.websocket.OnOpen;
 +import javax.websocket.Session;
 +import javax.websocket.server.ServerEndpoint;
 +
 +@ServerEndpoint(value = "/websocket/chat")
 +public class ChatWebsocket {
 +
 +    private static final String GUEST_PREFIX = "Guest";
 +    private static final AtomicInteger connectionIds = new AtomicInteger(0);
 +    private static final Set<ChatWebsocket> connections =
 +            new CopyOnWriteArraySet<>();
 +
 +    private final String nickname;
 +    private Session session;
 +
 +    public ChatWebsocket() {
 +        nickname = GUEST_PREFIX + connectionIds.getAndIncrement();
 +    }
 +
 +
 +    @OnOpen
 +    public void start(Session session) {
 +        this.session = session;
 +        connections.add(this);
 +        String message = String.format("* %s %s", nickname, "has joined.");
 +        broadcast(message);
 +    }
 +
 +
 +    @OnClose
 +    public void end() {
 +        connections.remove(this);
 +        String message = String.format("* %s %s",
 +                nickname, "has disconnected.");
 +        broadcast(message);
 +    }
 +
 +
 +    @OnMessage
 +    public void incoming(String message) {
 +        // Never trust the client
 +        String filteredMessage = String.format("%s: %s",
 +                nickname, filter(message.toString()));
 +        broadcast(filteredMessage);
 +    }
 +
 +
 +
 +
 +    @OnError
 +    public void onError(Throwable t) throws Throwable {
 +        System.out.println("Chat Error: " + t.toString());
 +    }
 +
 +
 +    private static void broadcast(String msg) {
 +        for (ChatWebsocket client : connections) {
 +            try {
 +                synchronized (client) {
 +                    client.session.getBasicRemote().sendText(msg);
 +                }
 +            } catch (IOException e) {
 +            System.out.println("Chat Error: Failed to send message to client " + e);
 +                connections.remove(client);
 +                try {
 +                    client.session.close();
 +                } catch (IOException e1) {
 +                    // Ignore
 +                }
 +                String message = String.format("* %s %s",
 +                        client.nickname, "has been disconnected.");
 +                broadcast(message);
 +            }
 +        }
 +    }
 +    
 +    public static String filter(String message) {
 +
 +        if (message == null)
 +            return null;
 +
 +        char content[] = new char[message.length()];
 +        message.getChars(0, message.length(), content, 0);
 +        StringBuilder result = new StringBuilder(content.length + 50);
 +        for (int i = 0; i < content.length; i++) {
 +            switch (content[i]) {
 +            case '<':
 +                result.append("&lt;");
 +                break;
 +            case '>':
 +                result.append("&gt;");
 +                break;
 +            case '&':
 +                result.append("&amp;");
 +                break;
 +            case '"':
 +                result.append("&quot;");
 +                break;
 +            default:
 +                result.append(content[i]);
 +            }
 +        }
 +        return result.toString();
 +    }
 +    
 +}
 +</code>
 +
 +Web client chat.xhtml:
 +<code>
 +<?xml version="1.0" encoding="UTF-8"?>
 +<!--
 +  Licensed to the Apache Software Foundation (ASF) under one or more
 +  contributor license agreements.  See the NOTICE file distributed with
 +  this work for additional information regarding copyright ownership.
 +  The ASF licenses this file to You under the Apache License, Version 2.0
 +  (the "License"); you may not use this file except in compliance with
 +  the License.  You may obtain a copy of the License at
 +
 +      http://www.apache.org/licenses/LICENSE-2.0
 +
 +  Unless required by applicable law or agreed to in writing, software
 +  distributed under the License is distributed on an "AS IS" BASIS,
 +  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 +  See the License for the specific language governing permissions and
 +  limitations under the License.
 +-->
 +<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
 +<head>
 +    <title>Apache Tomcat WebSocket Examples: Chat</title>
 +    <style type="text/css"><![CDATA[
 +        input#chat {
 +            width: 410px
 +        }
 +
 +        #console-container {
 +            width: 400px;
 +        }
 +
 +        #console {
 +            border: 1px solid #CCCCCC;
 +            border-right-color: #999999;
 +            border-bottom-color: #999999;
 +            height: 170px;
 +            overflow-y: scroll;
 +            padding: 5px;
 +            width: 100%;
 +        }
 +
 +        #console p {
 +            padding: 0;
 +            margin: 0;
 +        }
 +    ]]></style>
 +    <script type="application/javascript"><![CDATA[
 +        "use strict";
 +
 +        var Chat = {};
 +
 +        Chat.socket = null;
 +
 +        Chat.connect = (function(host) {
 +            if ('WebSocket' in window) {
 +                Chat.socket = new WebSocket(host);
 +            } else if ('MozWebSocket' in window) {
 +                Chat.socket = new MozWebSocket(host);
 +            } else {
 +                Console.log('Error: WebSocket is not supported by this browser.');
 +                return;
 +            }
 +
 +            Chat.socket.onopen = function () {
 +                Console.log('Info: WebSocket connection opened.');
 +                document.getElementById('chat').onkeydown = function(event) {
 +                    if (event.keyCode == 13) {
 +                        Chat.sendMessage();
 +                    }
 +                };
 +            };
 +
 +            Chat.socket.onclose = function () {
 +                document.getElementById('chat').onkeydown = null;
 +                Console.log('Info: WebSocket closed.');
 +            };
 +
 +            Chat.socket.onmessage = function (message) {
 +                Console.log(message.data);
 +            };
 +        });
 +
 +        Chat.initialize = function() {
 +            if (window.location.protocol == 'http:') {
 +                Chat.connect('ws://' + window.location.host + '/examples/websocket/chat');
 +            } else {
 +                Chat.connect('wss://' + window.location.host + '/examples/websocket/chat');
 +            }
 +        };
 +
 +        Chat.sendMessage = (function() {
 +            var message = document.getElementById('chat').value;
 +            if (message != '') {
 +                Chat.socket.send(message);
 +                document.getElementById('chat').value = '';
 +            }
 +        });
 +
 +        var Console = {};
 +
 +        Console.log = (function(message) {
 +            var console = document.getElementById('console');
 +            var p = document.createElement('p');
 +            p.style.wordWrap = 'break-word';
 +            p.innerHTML = message;
 +            console.appendChild(p);
 +            while (console.childNodes.length > 25) {
 +                console.removeChild(console.firstChild);
 +            }
 +            console.scrollTop = console.scrollHeight;
 +        });
 +
 +        Chat.initialize();
 +
 +
 +        document.addEventListener("DOMContentLoaded", function() {
 +            // Remove elements with "noscript" class - <noscript> is not allowed in XHTML
 +            var noscripts = document.getElementsByClassName("noscript");
 +            for (var i = 0; i < noscripts.length; i++) {
 +                noscripts[i].parentNode.removeChild(noscripts[i]);
 +            }
 +        }, false);
 +
 +    ]]></script>
 +</head>
 +<body>
 +<div class="noscript"><h2 style="color: #ff0000">Seems your browser doesn't support Javascript! Websockets rely on Javascript being enabled. Please enable
 +    Javascript and reload this page!</h2></div>
 +<div>
 +    <p>
 +        <input type="text" placeholder="type and press enter to chat" id="chat" />
 +    </p>
 +    <div id="console-container">
 +        <div id="console"/>
 +    </div>
 +</div>
 +</body>
 +</html>
 +</code>
 +
 +Les sources complets avec pom, html, java: {{ :projets:2018:websocket-src.tar.gz |}}
 +
  
projets/2018/stagejava.1551533588.txt.gz · Dernière modification : 2024/04/16 22:26 (modification externe)
Donate Powered by PHP Valid HTML5 Valid CSS Driven by DokuWiki