質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

89.63%

Websockeによるチャットアプリにルーム機能を付けたい

解決済

回答 1

投稿

  • 評価
  • クリップ 0
  • VIEW 1,581

asakura

score 24

Websocketを使ったチャットアプリを作ってます。
クライアントから任意の文字列をサーバ側に渡し、チャットルームを生成したいのですが、
任意の文字列はサーバ側に送っていてチャットルームが生成されているものの、
サーバから入力したメッセージは、接続しているすべてのクライアントに送信されてしまい、
意図している挙動になりません。

どのように対処すれば解決するか、教えて頂けないでしょうか。
よろしくお願い致します。

実際のチャットアプリのコードを以下に添付します。

// chatサーバ
var socketio = require('socket.io');
var io;

exports.listen = function(server) {
    io = socketio.listen(server);
    io.sockets.on('connection', function(clientSocket) {
        console.log("WebSocket接続");

        // クライアントから送られて来たルーム値でルームを開設
        var room = "";
        clientSocket.on("from_client", function(data) {
            room = data.value;
            console.log("クライアントから送信されたroom: %s", room);
            joinRoom(clientSocket, room);
        });

        // チャットメッセージを書き込むと処理する
        handleMessageBroadcasting(clientSocket);

        // クライアントから送られてきたメッセージ受け取り
        clientSocket.on("from_client", function(name, message) {
            console.log("クライアントから送信されたname: %s", name);
            console.log("クライアントから送信されたmessage: %s", message);
            io.sockets.emit('receiveMessage', { name: name, message: message });
        });
    });
};

function joinRoom(clientSocket, room) {
    // ユーザーをルームに参加させる
    clientSocket.join(room);
    // ユーザに新しいルームに入ったことを知らせる
    clientSocket.emit('joinResult', { room: room });
}

function handleMessageBroadcasting(clientSocket) {
    clientSocket.on('newChatMessage', function(name, message) {
        console.log("サーバから送信されたname: %s", name);
        console.log("サーバから送信されたmessage: %s", message);
        // チャットに書き込んだメッセージをクライアントに通知
        io.emit('from_server', { name: name, message: message })
    });
}
// chatサーバのUI生成

// チャットメッセージの書き込み
function updateChatMessage(chatApp, name, message) {
    if (name == "山田 太郎") {
        var messageElement = $("<il><p class='sender_name me'>" + name + "</p><p class='right_balloon'>" + message + "</p><p class='clear_balloon'></p></il>");
        // クライアントに通知
        chatApp.sendMessage(name, message);
    } else {
        var messageElement = $("<il><p class='sender_name'>" + name + "</p><p class='left_balloon'>" + message + "</p><p class='clear_balloon'></p></il>");
    }
    // チャットボードに書き込み
    $('#messages').append(messageElement);
    $('#messages').scrollTop($('#messages').prop('scrollHeight'));
    $('#send-message').val('');
}
var socket = io.connect('http://localhost:3000');

$(document).ready(function() {
    var chatApp = new Chat(socket);
    // ルームに参加
    socket.on('joinResult', function(result) {
        console.log("ルームへ入室", result.room)
        $("#room").text("接続しているルーム: " + result.room);
    });

    // クライアントから来たメッセージの受信
    socket.on('receiveMessage', function(data) {
        updateChatMessage(chatApp, data.name, data.message);
    });

    $("#send-message").focus();
    // 「送信」ボタンをクリック
    $('#send-button').click(function() {
        // フォームに入力したメッセージを取得
        var message = $('#send-message').val();
        updateChatMessage(chatApp, "山田 太郎", message);
    });
});
// chatクラス生成
var Chat = function(socket) {
    this.socket = socket;
};
// クライアントに書き込んだメッセージ内容を返す
Chat.prototype.sendMessage = function(name, message) {
    this.socket.emit('newChatMessage', name, message);
}
// ChatクライアントUI生成

// チャットメッセージの書き込み
function clientChatMessage(chatApp, name, message) {
    if (name == "山田 次郎") {
        var messageElement = $("<il><p class='sender_name me'>" + name + "</p><p class='right_balloon'>" + message + "</p><p class='clear_balloon'></p></il>");

        // クライアントからメッセージの送信
        socket.emit('from_client', name, message);

    } else {
        var messageElement = $("<il><p class='sender_name'>" + name + "</p><p class='left_balloon'>" + message + "</p><p class='clear_balloon'></p></il>");
    }
    // チャットボードに書き込み
    $('#messages').append(messageElement);
    $('#messages').scrollTop($('#messages').prop('scrollHeight'));
    $('#send-message').val('');
}
var socket = io.connect('http://localhost:3000');

$(document).ready(function() {
    var chatApp = new Chat(socket);

    // ルーム情報を送信
    var selectRoom = 'testroom';
    socket.emit('from_client', { value: selectRoom });
    console.log("ルーム情報を配信: " + selectRoom);

    // ルームに参加
    socket.on('joinResult', function(result) {
        console.log("ルームへ入室", result.room)
        $("#room").text("接続しているルーム: " + result.room);
    });

    // サーバから来たメッセージの受信
    socket.on('from_server', function(data) {
        clientChatMessage(chatApp, data.name, data.message);
    });

    $("#send-message").focus();
    // 「送信」ボタンをクリック
    $('#send-button').click(function() {
        // フォームに入力したメッセージを取得
        var message = $('#send-message').val();
        clientChatMessage(chatApp, "山田 次郎", message);
    });
});
// Chatクライアント
<!DOCTYPE html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <title>chat</title>
    <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.2/css/bootstrap.min.css">
    <link rel="stylesheet" type="text/css" href="css/chatStyle.css">
    <script src="/socket.io/socket.io.js" type="text/javascript"></script>
    <script src="http://code.jquery.com/jquery-1.8.0.min.js" type="text/javascript"></script>
    <script src="js/chat.js" type="text/javascript"></script>
    <script src="js/chat_ui_client.js" type="text/javascript"></script>
</head>

<body>
    <div class="panel-default">
        <div class="panel-heading">
            <p>チャットサンプル クライアント</p>
        </div>
        <div id='room'></div>
        <div id="scroller" class="panel-body">
            <ul id='messages'></ul>
        </div>
        <form id="send-form">
            <div class="form-group">
                <label>メッセージ</label>
                <input class="span11" id="send-message" type="text" placeholder="メッセージ内容を入力してください。">
                <button class="btn btn-primary" id="send-button" type="button">送信</button>
            </div>
        </form>
    </div>
</body>

</html>
// chatサーバ画面
<!DOCTYPE html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <title>chat</title>
    <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.2/css/bootstrap.min.css">
    <link rel="stylesheet" type="text/css" href="css/chatStyle.css">
    <script src="/socket.io/socket.io.js" type="text/javascript"></script>
    <script src="http://code.jquery.com/jquery-1.8.0.min.js" type="text/javascript"></script>
    <script src="js/chat.js" type="text/javascript"></script>
    <script src="js/chat_ui.js" type="text/javascript"></script>
</head>

<body>
    <div class="panel-default">
        <div class="panel-heading">
            <p>チャットサンプル</p>
        </div>
        <div id='room'></div>
        <div id="scroller" class="panel-body">
            <ul id='messages'></ul>
        </div>
        <form id="send-form">
            <div class="form-group">
                <label>メッセージ</label>
                <input class="span11" id="send-message" type="text" placeholder="メッセージ内容を入力してください。">
                <button class="btn btn-primary" id="send-button" type="button">送信</button>
            </div>
        </form>
    </div>
</body>

</html>
  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 過去に投稿した質問と同じ内容の質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

checkベストアンサー

+1

io.sockets.emit('receiveMessage', { name: name, message: message });

これは全員に送信するので、特定のroomにだけ送るには次のようにします。

clientSocket.to(room).emit('receiveMessage', { name: name, message: message });

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

  • 2017/09/04 21:02

    ご指摘ありがとうございます。
    指摘の通り、修正した所、想定通り特定のroomのみ送信ができました。

    キャンセル

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 89.63%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる