发送 ArrayList<Object>通过插座.爪哇 [英] Sending ArrayList&lt;Object&gt; through socket. Java

问题描述

我想要做的是通过套接字从 Android 客户端向 Java 服务器发送和 ArrayList.这是发送 ArrayList 的客户端代码:

What i'm trying to do is to send and ArrayList through a socket from Android client to Java server. Here is the code of client which sends the ArrayList :

private void sendContacts(){
            AppHelper helperClass = new AppHelper(getApplicationContext());
            final ArrayList<Person> list = helperClass.getContacts();
            System.out.println("Lenght of an contacts array : " +list.size());
//          for (Person person : list) {
//              System.out.println("Name "+person.getName()+"\nNumber "+ person.getNr());
//          } 
            handler.post(new Runnable() {

                @Override
                public void run() {
                    // TODO Auto-generated method stub
                    try {
//**151 line**              os.writeObject(list); 
                    os.flush();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    Log.e(TAG, "Sending Contact list has failed");
                    e.printStackTrace();
                }
            }
            });
}

public ArrayList<Person> getContacts() {
        ArrayList<Person> alContacts = null;
        ContentResolver cr = mContext.getContentResolver(); //Activity/Application android.content.Context
        Cursor cursor = cr.query(ContactsContract.Contacts.CONTENT_URI, null, null, null, null);
        if(cursor.moveToFirst())
        {
             alContacts = new ArrayList<Person>();
            do
            {
                String id = cursor.getString(cursor.getColumnIndex(ContactsContract.Contacts._ID));

                if(Integer.parseInt(cursor.getString(cursor.getColumnIndex(ContactsContract.Contacts.HAS_PHONE_NUMBER))) > 0)
                {
                    Cursor pCur = cr.query(ContactsContract.CommonDataKinds.Phone.CONTENT_URI,null,ContactsContract.CommonDataKinds.Phone.CONTACT_ID +" = ?",new String[]{ id }, null);
                    while (pCur.moveToNext()) 
                    {
                        String contactNumber = pCur.getString(pCur.getColumnIndex(ContactsContract.CommonDataKinds.Phone.NUMBER));
                        String contactName = pCur.getString(pCur.getColumnIndex(ContactsContract.CommonDataKinds.Phone.DISPLAY_NAME));
                        Person temp = new Person(contactName, contactNumber);

                        alContacts.add(temp);
                        break;
                    }
                    pCur.close();
                }

            } while (cursor.moveToNext()) ;
        }
        return alContacts;
    }

这是服务器代码:

private void whileChatting() throws IOException {
        ableToType(true);
        String message = "You are now connected ";
        sendMessage(message);
        do {// have conversation
            try {
                message = (String) input.readObject();
                // message = (String) input.readLine();
                showMessage("\n" + message);
            } catch (ClassNotFoundException e) {
                showMessage("It is not a String\n");

                // TODO: handle exception
            }
            try{
                ArrayList<Person> list =(ArrayList<Person>) input.readObject();
                showMessage("GOT A LIST OF PERSON WITH SIZE :" + list.size());
            }catch(ClassNotFoundException e){
                showMessage("It is not a List of Person\n");
            }
        } while (!message.equals("client - end"));
    }

错误代码:

Caused by: java.io.NotSerializableException: com.lauris.client.Person
    at java.io.ObjectOutputStream.writeNewObject(ObjectOutputStream.java:1344)
    at java.io.ObjectOutputStream.writeObjectInternal(ObjectOutputStream.java:1651)
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:1497)
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:1461)
    at java.util.ArrayList.writeObject(ArrayList.java:648)
    at java.lang.reflect.Method.invoke(Native Method)
    at java.lang.reflect.Method.invoke(Method.java:372)
    at java.io.ObjectOutputStream.writeHierarchy(ObjectOutputStream.java:1033)
    at java.io.ObjectOutputStream.writeNewObject(ObjectOutputStream.java:1384)
    at java.io.ObjectOutputStream.writeObjectInternal(ObjectOutputStream.java:1651)
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:1497)
    at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:1461)
    **at com.lauris.client.MainActivity$ClientThread$4.run(MainActivity.java:151)**
    at android.os.Handler.handleCallback(Handler.java:739)
    at android.os.Handler.dispatchMessage(Handler.java:95)
    at android.os.Looper.loop(Looper.java:135)
    at android.app.ActivityThread.main(ActivityThread.java:5221)
    at java.lang.reflect.Method.invoke(Native Method)
    at java.lang.reflect.Method.invoke(Method.java:372)
    at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:899)
    at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:694)

我想我的问题是序列化?我真的不明白这是什么意思?有人可以解释一下它是什么，为什么我需要它?我该如何修复我的代码?

I guess my problem is serialization ? I don't really understand the meaning of this ? Can somebody explain me what it is, why i need it? And how may i fix my code?

补充问题.您可以在我的代码中看到我正在尝试侦听不同的 InputStreams.我想我做错了.有人可以更高级的解释我如何正确地做吗?

Additional question. You can see in my code im trying to listen for different InputStreams. I think i,m doing it wrong. Could somebody more advanced explain me how to do it correct ?

感谢您的帮助，我真的很困惑.

Appreciate your help, i'm really stuck on this.

推荐答案

Person 类必须实现 Serializable:

import java.io.Serializable;

public class Person implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

}

这篇关于发送 ArrayList<Object>通过插座.爪哇的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！