电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛

标题: 创建基于 Ajax 的 IM 客户端（5）发送消息 [打印本页]

作者: look_w 时间: 2018-8-9 10:16 标题: 创建基于 Ajax 的 IM 客户端（5）发送消息

发送消息有了相关的 Chat 对象后，发送信息十分简单（参见清单 5）：
清单 5. 发送消息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

....
public static void main (String args[]){

      ChatBot test = new ChatBot();
      test.go();
      test.startNew();
      test.sendMessage("myFriend@myjabberserver.net", "Hey there!");

}
....
XMPPConnection conn;

public void sendMessage(String targetUser, String theMessage){
      Chat theChat = (Chat)chatSessions.get(targetUser);
      try {
         theChat.sendMessage(theMessage);
      } catch (Exception e){
         e.printStackTrace();
      }
}

private void createConversation(String target){
....

这里，向 main() 方法添加了一条语句，告知此对象一旦完成了自身初始化，它就应该发送一条文本消息给 myfriend@myjabberserver.net，地址与之前初始 Chat 所用的相同。发送后，bot 的 sendMessage() 方法就会寻找相关的 Chat 对象 —，记得么，最初是基于地址将其添加到 Hashtable 的。一旦找到了 Chat 对象，它就可以发送消息。
若要测试，可以使用 Spark 登录到发送消息的那个帐号并运行应用程序。应该可以看到弹出一个消息窗口，其上显示文本 “Hey there!”。
接收消息但如果好友回发消息又该如何呢？消息会回到 Chat，然后呢？还不尽然。我们需要告诉 MessageListener 的 processMessage() 方法去处理此事，如清单 6 所示：
清单 6. 接收消息

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

....
private void createConversation(String target){
      try {
         chatQueues.put(target, "");

         Chat chat = conn.getChatManager().createChat(target,
                  new MessageListener() {
            public void processMessage(Chat chat, Message message) {
                  try {
                     chat.sendMessage("Got "+message.getBody());}
                  catch (Exception e){
                     e.printStackTrace();
                  }

                  String currentQueue = chatQueues.get(chat.getParticipant());
                  chatQueues.put(chat.getParticipant(), currentQueue
                  + "<br />" + message.getBody());
                  S ystem.out.println(chat.getParticipant() + " said " +
                  message.getBody());
            }
         }
         );

         chatSessions.put(target, chat);
      } catch (Exception e){
         System.out.println("Create Conversation Exception");
         e.printStackTrace();
      }
}
....

现在，当用户从 Spark（或任何其他客户端）发送消息时，会发生两件事情。首先，检索消息主体 — 他/她究竟说了什么 — 并将其发送回给他/她。当然，这不是正常的会话协议，但它会让您在构建应用程序的时候知道收听者的工作。
第二，基于发出消息的那个用户（“参与者”）从队列检索应用程序的当前文本、向其添加当前消息并将其放回队列。
最后，同样，还是可以查看其工作、输出一个语句说明所发生的事情。
保存、编译并运行此应用程序。这次，当谈话窗口弹出时，试着将文本发回。应该可以在谈话窗口本身以及 Java 控制台看到这样做的效果。
现在我们需要将此转变成一个 Web 应用程序。

欢迎光临电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)