Передать String в AsyncTask, получить callback

@zoleg · Регистрация: 10.01.2012

Author24 — интернет-сервис помощи студентам

Не могу сообразить как одновременно и передать в AsyncTask запрос и возвратить ответ в UI.

Вот код как есть - нужно возвращать закоментированные callback.*

Пробую возвратить // callback.onRecievedMessage(msg); Но пока безуспешно.

Java

public abstract class jabberdSenderAcyncTasker extends AsyncTask<Void, Void, String> {
    public eJabberdSenderInteface callback;
    private String oucoming_Message;
    private Throwable t;
 
    String JABBERSERVER = TetGlobalData.JBS;
    int JABBERPORT = TetGlobalData.JPORT;
    String JABBERDUSER = TetGlobalData.JBU;
    AbstractXMPPConnection jConnection;
    boolean result = true;
    boolean notReply = false;
    private String pseudo_tag="jabberdSenderAcyncTasker";
 
    public jabberdSenderAcyncTasker(String outcoming_mesage) {
 
        super();
 
        oucoming_Message = outcoming_mesage;
    }
protected jabberdSenderAcyncTasker(eJabberdSenderInteface callback) {
    this.callback = (eJabberdSenderInteface) callback;
}
 
 
    @Override
    protected void onPreExecute() {
        super.onPreExecute();
 
    }
 
    protected abstract boolean doAction() throws Exception; // Do redefinition method
 
    @Override
    protected String doInBackground(Void... params) {
        Log.i(pseudo_tag,""+pseudo_tag+" RUN doInBackground");
        XMPPTCPConnectionConfiguration.Builder config = XMPPTCPConnectionConfiguration.builder();
        config.setUsernameAndPassword(TetGlobalData.JBU + "@" + TetGlobalData.JBS, TetGlobalData.JBP);
        config.setServiceName(TetGlobalData.JBS);
        config.setHost(TetGlobalData.JBS);
        config.setPort(TetGlobalData.JPORT);
        config.setDebuggerEnabled(true);
        config.setSecurityMode(ConnectionConfiguration.SecurityMode.ifpossible);
        config.setSendPresence(true);
        config.setCompressionEnabled(false);
        // config.setReconnectionAllowed(true);
        // config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
        //config.setRosterLoadedAtLogin(true);
        // config.setSocketFactory(ManagerFactory.getDefault());
        //
        // config.setSASLAuthenticationEnabled(false);
        //config.setSocketFactory(new DummySSLSocketFactory());
        //config.setSecurityMode(ConnectionConfiguration.SecurityMode.ifpossible);
        config.build();
        ///////////////////////////////////////////////////////////////////////////////////////////////////
        SASLMechanism mechanism = new SASLDigestMD5Mechanism();
        SASLAuthentication.registerSASLMechanism(mechanism);
        SASLAuthentication.blacklistSASLMechanism("SCRAM-SHA-1");
        SASLAuthentication.blacklistSASLMechanism("DIGEST-MD5");
        SASLAuthentication.unBlacklistSASLMechanism("PLAN");
//////////////////////////////////////////////////////////////////////////////////////////////////
        // accept all certificate - just for testing
        try {
            TLSUtils.acceptAllCertificates(config);
        } catch (NoSuchAlgorithmException e) {
        } catch (KeyManagementException e) {
        }
//////////////////////////////////////////////////////////////////////////////////////////////////
// verify all hostname - just for testing
        config.setHostnameVerifier(new HostnameVerifier() {
            public boolean verify(String hostname, SSLSession session) {
                return true;
            }
        });
//////////////////////////////////////////////////////////////////////////////////////////////////
 /*       try {
            SSLContext sc = SSLContext.getInstance("TLS");
            config.setCustomSSLContext(sc);
        } catch (NoSuchAlgorithmException e) {
            throw new IllegalStateException(e);
        }
*/
        XMPPTCPConnection.setUseStreamManagementDefault(true);
        jConnection = new XMPPTCPConnection(config.build());
        jConnection.setPacketReplyTimeout(10000);
        try {
            System.out.println("connecting");
            jConnection.connect();
            System.out.println("connected");
            jConnection.login();
            System.out.println("logged in");
       //     callback.onLogin(true);
        } catch (XMPPException e) {
            e.printStackTrace();
        } catch (SmackException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        Log.e(pseudo_tag, "###  jConnection.getStreamId() = " +jConnection.getStreamId()+"");
        if (jConnection.isAuthenticated()) {
            Roster roster = Roster.getInstanceFor(jConnection);
 
            if (!roster.isLoaded()) {
                try {
                    roster.reloadAndWait();
                } catch (SmackException.NotLoggedInException e) {
                    e.printStackTrace();
                } catch (SmackException.NotConnectedException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
 
            Collection<RosterEntry> entries = roster.getEntries();
 
            for (RosterEntry entry : entries)
                System.out.println("Here: " + entry);
            /// Normal connect
            ChatManager chatmanager = ChatManager.getInstanceFor(jConnection);
            ///Create chat
            Chat newChat = chatmanager.createChat(TetGlobalData.JBC + "@" + TetGlobalData.JBS, new ChatMessageListener() {
 
                @Override
                public void processMessage(Chat chat, Message message) {
                    try {
                        chat.sendMessage(message);
                        String from = message.getFrom();
                        String body = message.getBody();
                        String msg = String.format("%1$s", body);
                        Log.d(pseudo_tag, "!!!!!!!!!!!!!!!!! DEBUG  StringTokenizer msg =" + msg + " !!!");
                        StringTokenizer st = new StringTokenizer(msg, TetGlobalData.TOKEN_SEPARATOR);
                        String token = st.nextToken();
                        if (token.equals(TetGlobalData.RESPONCE)) {
                            String tokenres = st.nextToken();
                            if (!tokenres.equals(TetGlobalData.DS_SETUP_OK)) {
                                TetGlobalData.notReply = true;
                                Log.d(pseudo_tag, "++++!!!!!!!!!!!!!!!!! DEBUG  StringTokenizer OK OK OK OK !!!!!!!!++++");
                                EventBus.getDefault().post(new EventJabIncomMessage(msg), "INCOMING_MESSAGE");
                               // callback.onRecievedMessage(msg);
                                jConnection.disconnect();
                            } else {
                                TetGlobalData.notReply = true;
                                result = false;
                                jConnection.disconnect();
                            }
 
                        } else {
                            jConnection.disconnect();
                        }
 
                    } catch (SmackException.NotConnectedException e) {
                        Log.d(TetGlobalData.TAG_TET_A_TET, e.toString());
                    }
                }
            });
 
            Log.i(pseudo_tag, "" + pseudo_tag + " SENDING message ="+oucoming_Message+"! ");
            try {
 
                newChat.sendMessage(oucoming_Message);
            } catch (SmackException.NotConnectedException e) {
                e.printStackTrace();
            }
 
        }
        return "";
    }
 
    @Override
    protected void onPostExecute(String v) {
        EventBus.getDefault().unregister(this);
        super.onPostExecute(v);
        EventBus.getDefault().unregister(this);
     // callback.onPostExecute(true);
    }
 
 
 
}

Интерфейс такой

Java

public interface eJabberdSenderInteface {
    void onRecievedMessage(String msg);
 
    void onLogin(boolean aTrue);
 
    void onPostExecute(boolean b);
}

Дергаю так

Java

public class toServerSenderAcyncTasker implements eJabberdSenderInteface {
 
 
    private final String pseudo_tag;
 
    public toServerSenderAcyncTasker(String REQUEST) {
 
        String action = getClass().getCanonicalName();
        int pos = action.lastIndexOf('.') + 1;
        String onlyClass = action.substring(pos);
        pseudo_tag = onlyClass;
 
        if (TetGlobalData.JBS.equals("172.14.2.101")) {
            //TetTempoDate.jabberd_OUT_COMMING_MESSAGE = REQUEST;
            new jabberdSenderAcyncTaskerLocal(REQUEST) {
                @Override
                protected boolean doAction() throws Exception {
                    Thread.currentThread().wait(1000);
                    return false;
                }
            }.execute();
        } else {
            new jabberdSenderAcyncTasker(REQUEST) {
                @Override
                protected boolean doAction() throws Exception {
                    Thread.currentThread().wait(1000);
                    return false;
                }
            }.execute();
        }
    }
 
    @Override
    public void onRecievedMessage(String msg) {
     Log.e(pseudo_tag, "onRecievedMessage = " + msg + "");
    }
 
    @Override
    public void onLogin(boolean aTrue) {
 
    }
 
    @Override
    public void onPostExecute(boolean b) {
 
    }
}

@Mikalai · 06.03.2016, 16:22

zoleg, AsyncTask - пример

@zoleg · 06.03.2016, 18:08 **[ТС]**

Сообщение от Mikalai

zoleg, AsyncTask - пример

Это же совсем другое.
И даже есть внешние, глобальные отличия.
1. Все упаковано в тело кода Activity.
2. Пример не включает применение интерфейса
4. Не используется передача между классами
3. Пример дает читку стрим

В общем, ничем не помогла ссылка.

Добавлено через 17 минут
Упрощаю задачу
Выкладываю урезанный вариант

Java

public abstract class jabberdSenderAcyncTasker extends AsyncTask<Void, Void, String> {
 
    public eJabberdSenderInteface callback;
    private String oucoming_Message;
    private Throwable t;
 
   public jabberdSenderAcyncTasker(String outcoming_mesage) {
 
        super();
 
        oucoming_Message = outcoming_mesage;
    }
 
protected jabberdSenderAcyncTasker(eJabberdSenderInteface callback) {
    this.callback = (eJabberdSenderInteface) callback;
 
protected abstract boolean doAction() throws Exception; // Do redefinition method
 
 @Override
    protected String doInBackground(Void... params) {
 
                callback.onRecievedMessage("bla-bla-bla");
             }
 
      }
 
}

Как получить callback в вызывающем классе toServerSenderAcyncTasker. Отсылка месаг идет без проблем. Проблема получить колбэк.

@Mikalai · 06.03.2016, 18:30

Сообщение от zoleg

Упрощаю задачу

Спасибо! ))

А зачем тут вообще AsyncTask? почему просто не сделать второй поток, а ответ прислать через EventBus?

@zoleg · 06.03.2016, 18:48 **[ТС]**

Сообщение от Mikalai

почему просто не сделать второй поток, а ответ прислать через EventBus?

Вот от него то и хочу избавится. С ним работает но есть некая неприятность. Липкий Ивент принять не могу (приемник не заточен для него), а простой не доходит до адресата если АсинхТаск успевает к этому времени завершится.
В общем , доходит, но не всегда

Липкий вообще не канает именно для этого приемника. Приходится перешаманивать. А так все легко получилось

, но не все же в жизни Масленица, должны быть и неприятности.

@zoleg · 07.03.2016, 23:36 **[ТС]**

Все оказалось очень просто

Убираем переопределение

Java

  public jabberdSenderAcyncTasker(String outcoming_mesage) {
 
        super();
 
        oucoming_Message = outcoming_mesage;
    }

А в это

Java

1	protected jabberdSenderAcyncTasker(eJabberdSenderInteface callback)

Добавляем стринг
[JAVA]

Java

1	protected jabberdSenderAcyncTasker(eJabberdSenderInteface callback, String request)

Естественно мы его теперь передаем при вызове с добавочкой "this"

Java

new jabberdSenderAcyncTaskerLocal(this,REQUEST) {
                @Override
                protected boolean doAction() throws Exception {
                    Thread.currentThread().wait(1000);
                    return false;
                }
            }.execute();

@Mikalai 266 / 242 / 96 Регистрация: 11.01.2015 Сообщений: 673
	06.03.2016, 16:22	2
	zoleg, AsyncTask - пример 0

@Mikalai 266 / 242 / 96 Регистрация: 11.01.2015 Сообщений: 673
	06.03.2016, 18:30	4
	Сообщение от zoleg Упрощаю задачу Спасибо! )) А зачем тут вообще AsyncTask? почему просто не сделать второй поток, а ответ прислать через EventBus? 0

@zoleg 69 / 62 / 13 Регистрация: 10.01.2012 Сообщений: 508
	06.03.2016, 18:48 [ТС]	5
	Сообщение от Mikalai почему просто не сделать второй поток, а ответ прислать через EventBus? Вот от него то и хочу избавится. С ним работает но есть некая неприятность. Липкий Ивент принять не могу (приемник не заточен для него), а простой не доходит до адресата если АсинхТаск успевает к этому времени завершится. В общем , доходит, но не всегда Липкий вообще не канает именно для этого приемника. Приходится перешаманивать. А так все легко получилось , но не все же в жизни Масленица, должны быть и неприятности. 0

	07.03.2016, 23:36