1

Javaでチャットサーバーを設計しています。通信は Http ベースであり、ソケット ベースではありません。クライアント側にはアプレットがあります。サーバー側にはサーブレットがあります。

アプレット: 受信メッセージをリッスンする新しいスレッドを作成します (GET メソッド)。メインスレッドは、メッセージ (POST メッセージ) の送信に使用されます。

部分的なコードは次のとおりです。

public void start() {
    System.out.println("Creating new thread");
    Thread thread = new Thread(this);
    thread.start();
}

private String getNewMessage() {
    System.out.println("Inside getNewMessage");
    String msg = null;
    try {
        while(msg == null) {
            System.out.println("Trying to listen to servlet");
            URL servlet = new URL(getCodeBase(), "NewServlet?mode=msg");
            URLConnection con = servlet.openConnection();

            con.setUseCaches(false);

            DataInputStream din = new DataInputStream(new BufferedInputStream(con.getInputStream()));
            msg = din.readUTF();
            System.out.println("message read :" + msg);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return msg + "\n";
}
public void run() {
    System.out.println("Inside new thread");
    while(true) {
        System.out.println("inside first while");
        String newMsg = getNewMessage();
        chatOutput.append(newMsg);
        System.out.println("Appended!!");
    }
}
private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {
    String message = chatInput.getText();
    chatInput.setText("");
    chatOutput.append(message + "\n");
    try {
        System.out.println("Trying to send msg :" + message);
        URL url = new URL(getCodeBase(), "NewServlet");
        URLConnection servletConnection = url.openConnection();

        servletConnection.setDoInput(true);
        servletConnection.setDoOutput(true);
        servletConnection.setUseCaches(false);
        servletConnection.setRequestProperty("Content-Type", "application/octet-stream");

        ObjectOutputStream out = new ObjectOutputStream(servletConnection.getOutputStream());
        out.writeObject(message);
        out.flush();
        out.close();

        System.out.println("Message sent!");
    } catch (Exception e) {
        e.printStackTrace();
    }

}

この次のコードは、サーブレット側のものです。Observable インターフェイスを使用して、メッセージを識別してクライアントに送信します。

public class NewServlet extends HttpServlet {
// getNextMessage() returns the next new message.  // It blocks until there is one.
public String getNextMessage() {
// Create a message sink to wait for a new message from the
// message source.
  System.out.println("inside getNextMessage");
return new MessageSink().getNextMessage(source);}

@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
    System.out.println("Inside Doget");
    response.setContentType("text/plain");
    PrintWriter out = response.getWriter();

    out.println(getNextMessage());
} 

// broadcastMessage() informs all currently listening clients that there
// is a new message. Causes all calls to getNextMessage() to unblock.
public void broadcastMessage(String message) {
// Send the message to all the HTTP-connected clients by giving the
// message to the message source
source.sendMessage(message);  }
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
    System.out.println("Inside DoPost");
    try {
    ObjectInputStream din= new ObjectInputStream(request.getInputStream());
    String message = (String)din.readObject();

        System.out.println("received msg");
    if (message != null) broadcastMessage(message);
        System.out.println("Called broadcast");
// Set the status code to indicate there will be no response
    response.setStatus(response.SC_NO_CONTENT);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

/** 
 * Returns a short description of the servlet.
 * @return a String containing servlet description
 */
@Override
public String getServletInfo() {
    return "Short description";
}

MessageSource source = new MessageSource();}

class MessageSource extends Observable {
public void sendMessage(String message) {
  System.out.println("inside sendMsg");
setChanged();
notifyObservers(message);
}
}

class MessageSink implements Observer {
String message = null;  // set by update() and read by getNextMessage()
// Called by the message source when it gets a new message
synchronized public void update(Observable o, Object arg) {
// Get the new message
message = (String)arg;
// Wake up our waiting thread
notify();
}
// Gets the next message sent out from the message source
synchronized public String getNextMessage(MessageSource source) {
// Tell source we want to be told about new messages
source.addObserver(this);
  System.out.println("AddedObserver");
// Wait until our update() method receives a message
while (message == null) {
  try { wait(); } catch (Exception ignored) { }
}
// Tell source to stop telling us about new messages
source.deleteObserver(this);
// Now return the message we received
// But first set the message instance variable to null
// so update() and getNextMessage() can be called again.
String messageCopy = message;
message = null;
  System.out.println("Returning msg");
return messageCopy;
}
}

ご覧のとおり、 System.out.println("Some message"); を含めました。いくつかの場所で。これはデバッグ目的のためだけのものでした。Java コンソールでは、次の出力が得られます。

新しいスレッドの作成 新しいスレッド
内。
最初のうちに。
getNewMessage の内部。
サーブレットをリッスンしようとしています。

サーブレット側では、Tomcat ログに次の出力が表示されます。

ドゲット内部。
getNextMessage 内。
オブザーバーを追加しました。

アプレットにメッセージを入力して送信すると、Java コンソールに次の出力が表示されます。

メッセージを送信しようとしています :you deR??
メッセージを送信しました！

しかし、サーブレット側では、ログに何も記録されません。O'Reily Java Servlet Programming を参照として使用しました (オブザーバー インターフェイスはそこから来ています)。しかし、2 つのクライアント間でチャット通信ができません。ログからわかるように、doPOSTメソッドは呼び出されません。これの理由は何ですか？

4

1 に答える 1

1

アプレット側でメッセージ（ステータスメッセージ）を送信した後、メッセージを受信することで問題を解決しました。サーブレット側では、メソッドで、メッセージを読んだ後にdoPostステータス メッセージ ( ) を送信しました。"1"

これで問題がどのように解決されたのか正確にはわかりませんが、setDoInput(true);.

とにかく、良いニュースは、少なくとも上記のデバッグ プロセスで望ましい結果が得られたことです。

また、メソッド内のObjectInputStream代わりに使用する必要がありました(メッセージは ObjectOutputStream によって送信されたため)。これで、チャット サーバーはスムーズに動作します。DataInputStreamgetNewMessage

于 2010-03-24T18:08:01.573 に答える