java - 在 Java 中从 Google Talk 检索离线消息和聊天历史记录

Question

我必须从 Google Talk 中检索与我进行过对话的特定客户( friend /XMPP 客户端)的离线消息。

此外，我想检索聊天记录。

现在，我正在使用 HashMap 来跟踪对话，并且无法获取离线消息。

我已与“talk.google.com”建立 XMPP 连接。我目前可以通过控制台向客户端发送消息。我已经实现了消息监听器接口(interface)，因此可以在我的控制台本身中接收消息。

我有另一个实现(使用 OfflineMessageManager)，我尝试提取离线消息 header 作为开始，不幸的是，它失败并出现 Null Exception。

我使用过smack-tcp版本4.0.3和smackx 3.1.0。

请在下面找到我迄今为止尝试过的内容...

工作实现:

公共(public)类 StartChatImpl 实现 startChat、MessageListener {

static XMPPConnection myXMPPConnection;
static ArrayList<String> myFriends = new ArrayList<String>();
ArrayList<Msg> messages;
HashMap<String,ArrayList> conversation = new HashMap<String, ArrayList>();

OfflineMessageManager offlineMessages;


@Override
public void engageChat(ChatRequest chatRequest) throws XMPPException {


    ConnectionConfiguration config = new ConnectionConfiguration("talk.google.com", 5222, "gmail.com");
    //config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
    config.setSendPresence(true);
    myXMPPConnection = new XMPPTCPConnection(config);


    try{

        System.out.println("Connecting to talk.google.com");
        myXMPPConnection.connect();

        System.out.println("Logging you in...");
        myXMPPConnection.login(chatRequest.getUsername(),chatRequest.getPassword());

        Presence pres = new Presence(Presence.Type.unavailable);

        myXMPPConnection.sendPacket(pres);

        offlineMessages = new OfflineMessageManager(myXMPPConnection);

        System.out.println("You have been successfully connected.");

    } catch (SmackException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    }


}

public void send (String message, String to) throws XMPPException
{
    Chat chat = ChatManager.getInstanceFor(myXMPPConnection).createChat(to, this);
    //System.out.println("********************************************");
    //System.out.println("CHAT ID: "+ chat.getThreadID());
    //System.out.println("Participant: "+chat.getParticipant());
    //System.out.println("********************************************");

    try {
        chat.sendMessage(message);

        String friendName = myXMPPConnection.getRoster().getEntry(chat.getParticipant()).getName();

        if(conversation.containsKey(friendName))
        {

            messages = conversation.get(friendName);
            Calendar calendar = Calendar.getInstance();
            java.util.Date now = calendar.getTime();
            java.sql.Timestamp currentTimestamp = new java.sql.Timestamp(now.getTime());
            message = "bot says: "+message;
            Msg actualMsg = new Msg(currentTimestamp,message,"bot");
            messages.add(actualMsg);
            //messages.add("bot says: "+message);

        }
        else
        {
            messages = new ArrayList<Msg>();
            //messages.add("Bot initiated the conversation on: "+new Date());
            //messages.add("bot says: "+message);
            Calendar calendar = Calendar.getInstance();
            java.util.Date now = calendar.getTime();
            java.sql.Timestamp currentTimestamp = new java.sql.Timestamp(now.getTime());
            message = "bot says: "+message;
            Msg actualMsg = new Msg(currentTimestamp,message,"bot");
            messages.add(actualMsg);
            conversation.put(friendName,messages);
        }
    } catch (SmackException.NotConnectedException e) {
        e.printStackTrace();
    }

    System.out.println("You said "+"'"+message+"'"+" to "+myXMPPConnection.getRoster().getEntry(chat.getParticipant()).getName());

}

PacketListener myPacketListener = new PacketListener() {
    @Override
    public void processPacket(Packet p) {
        if (p instanceof Message) {
            Message msg = (Message) p;
        }
    }


};

public void displayMyFriends()
{
    Roster roster = myXMPPConnection.getRoster();
    Collection entries = roster.getEntries();
    System.out.println("You currently have: "+entries.size()+" friends available to chat.");

    int counter = 0;
    Iterator i = entries.iterator();

    while(i.hasNext())
    {
        RosterEntry r = (RosterEntry) i.next();
        Presence.Type entryPresence;
        entryPresence = roster.getPresence(r.getUser()).getType();
        System.out.println((counter+1)+" . "+r.getName() +" is "+entryPresence);
        //System.out.println("id:..."+r.getUser());
        myFriends.add(r.getUser());
        counter++;
    }
}

public void disconnectMe()
{
    try {
        System.out.println("Disconnection in progress...");
        myXMPPConnection.disconnect();
        System.out.println("You have been successfully disconnected.");
    } catch (SmackException.NotConnectedException e) {
        e.printStackTrace();
    }
}


@Override
public void processMessage(Chat chat, Message message)
{
    if((message.getType() == Message.Type.chat) && (message.getBody()!= null)) {


        System.out.println(myXMPPConnection.getRoster().getEntry(chat.getParticipant()).getName() + " says: " + message.getBody());

        String myMsg = myXMPPConnection.getRoster().getEntry(chat.getParticipant()).getName() + " says: " + message.getBody();

        Calendar calendar = Calendar.getInstance();
        java.util.Date now = calendar.getTime();
        java.sql.Timestamp currentTimestamp = new java.sql.Timestamp(now.getTime());

        Msg actualMsg = new Msg(currentTimestamp,myMsg,"customer");

        conversation.get(myXMPPConnection.getRoster().getEntry(chat.getParticipant()).getName()).
                add(actualMsg);

    }

}

public void receiveMessage(){

    myXMPPConnection.addPacketListener(myPacketListener, null);
}

public void retrieveUnservicedMessagesForSpecificPerson(String clientName)
{
    ArrayList<Msg> myMessages = conversation.get(clientName);
    Calendar calendar = Calendar.getInstance();
    java.util.Date now = calendar.getTime();
    java.sql.Timestamp currentTimestamp = new java.sql.Timestamp(now.getTime());

    System.out.println("Unserviced messages from: "+ clientName);
    if(!myMessages.isEmpty())
    {

        int counter = myMessages.size()-1;
        System.out.println("Size of array list: "+counter);
        boolean found = false;
        java.sql.Timestamp lastBotTimestamp = null;


        while (counter != 0 && found == false){

            if(myMessages.get(counter).getOwner()=="bot")
            {
                lastBotTimestamp = myMessages.get(counter).getTimestamp();
                found = true;
            }
            else
            {
                counter = counter-1;
            }

        }

        for(Msg msg:myMessages)
        {
            if(msg.getTimestamp().before(currentTimestamp) &&
                    msg.getTimestamp().after(lastBotTimestamp)){

                    System.out.println("---------------------------");
                    System.out.println("-"+msg.getActualMessage());
                    System.out.println("-"+msg.getTimestamp());
                    System.out.println("---------------------------");
            }

        }
    }
}


public void returnConversation(String name) {

    System.out.println("Name of participant entered: "+ name);
    System.out.println("Conversation history is: ");
    ArrayList<Msg> m = conversation.get(name);

    for(Msg msg:m){

        System.out.println(msg.getActualMessage());
        System.out.println("on: "+msg.getTimestamp());

    }

}

public void returnAllUnservicedMessagesHistory()
{

    for(String name: conversation.keySet())
    {
        System.out.println("History of unserviced messages for: "+ name);
        retrieveUnservicedMessagesForSpecificPerson(name);
    }

}


public void getOfflineMessagesCount(){

    try {
        System.out.println("Number of offline messages: "+ offlineMessages.getMessageCount());
    } catch (XMPPException e) {
        e.printStackTrace();
    }

}

}

我的主类实现:

公共(public)类 MainGoogleChatApp {

public static void main(String[] args)
{

    //Step 1: need to make a chat request with your username and password.

    Scanner input  = new Scanner(System.in);

    System.out.println("Please enter your username to start: ");
    String myUsername = input.next();

    System.out.println("Please enter your password to continue: ");
    String myPassword = input.next();

    ChatRequest myChatRequest = new ChatRequest();

    myChatRequest.setUsername(myUsername);
    myChatRequest.setPassword(myPassword);

    //Step 2: Need to initiate a connection to talk.google.com

    StartChatImpl convo = new StartChatImpl();

    try {
        convo.engageChat(myChatRequest);
    } catch (XMPPException e) {
        e.printStackTrace();
    }

    BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    String myMessage;

    System.out.println("Friend list.");

    convo.displayMyFriends();



    convo.receiveMessage();

    try {
        while(true)
        {
            System.out.println("Input Which friend you want to chat with '0 to sign out' : ");
            int num = input.nextInt() -1;
            if (num == -1){
                break;
            }
            String chatWith = StartChatImpl.myFriends.get(num);

            System.out.print("Type your message: ");

            myMessage=br.readLine();


            try {
                convo.send(myMessage,chatWith);



            } catch (XMPPException e) {
                e.printStackTrace();
            }
            convo.displayMyFriends();

        }
    } catch (IOException e) {
        e.printStackTrace();
    }

    System.out.println("Enter participant name to get specific chat...");
    String yourName = null;
    try {
        yourName = br.readLine();
    } catch (IOException e) {
        e.printStackTrace();
    }
    System.out.println("/./././././././././././././..//.");
    if(yourName!=null){
        System.out.println("Your name is not null...ok");
        convo.returnConversation(yourName);
    }

    System.out.println("Enter another participant's name to get specific chat...");
    String yourName1 = null;
    try {
        yourName1 = br.readLine();
    } catch (IOException e) {
        e.printStackTrace();
    }
    System.out.println("/./././././././././././././..//.");
    if(yourName1!=null){
        System.out.println("Your name is not null...ok");
        convo.returnConversation(yourName1);
    }

    System.out.println("Select a client name for whom you want to view unserviced messages: ");
    String yourClientName = null;
    try {
        yourClientName = br.readLine();
    } catch (IOException e) {
        e.printStackTrace();
    }
    if(yourClientName!=null){
        System.out.println("...........................................");
        convo.retrieveUnservicedMessagesForSpecificPerson(yourClientName);
    }

    System.out.println("...........................................");

    convo.returnAllUnservicedMessagesHistory();



    System.out.println("You have chosen to disconnect yourself from talk.google.com");
    convo.disconnectMe();
    System.exit(0);
}

}

尝试检索离线消息 header :

公共(public)类 TestOfflineService {

XMPPConnection xmppConnection = null;
//OfflineMessageManager offlineMessageManager = null;

public void makeConnection()
{
    ConnectionConfiguration config = new ConnectionConfiguration("talk.google.com", 5222, "gmail.com");
    //config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
    config.setSendPresence(true);
    xmppConnection = new XMPPTCPConnection(config);


    try{

        System.out.println("Connecting to talk.google.com");
        xmppConnection.connect();

        System.out.println("Logging you in...");
        xmppConnection.login("*******.*@***.com", "*****");

        System.out.println("You have been successfully connected.");

    } catch (SmackException e) {
        e.printStackTrace();
    } catch (IOException e) {
        e.printStackTrace();
    } catch (XMPPException e) {
        e.printStackTrace();
    }

}

public void makeMeUnavailable()
{
    try {
        xmppConnection.sendPacket(new Presence(Presence.Type.unavailable));
    } catch (SmackException.NotConnectedException e) {
        e.printStackTrace();
    }
}

public void getOfflineMessages()
{
    OfflineMessageManager offlineMessageManager1 = new OfflineMessageManager(xmppConnection);
    try {
        Iterator<OfflineMessageHeader> headers = offlineMessageManager1.getHeaders();

        if(headers.hasNext())
        {
            System.out.println("Messages found");
        }
    } catch (XMPPException e) {
        e.printStackTrace();
    }

}

public static void main(String[] args)
{
    TestOfflineService test = new TestOfflineService();
    test.makeConnection();
    test.makeMeUnavailable();
    System.out.println("Enter messages");
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("Getting offline messages.....");
    test.getOfflineMessages();

}

}

Answer 1

OfflineMessageManager 尝试使用 XEP-0013检索离线消息。该 XEP 不是由 GTalk 实现的。另请注意，一旦启动环聊就意味着您将永远不会再收到离线消息，因为环聊实例永远不会离线。

GTalk 也没有用于检索聊天历史记录的 XMPP API，例如 XEP-0136或XEP-0313 .