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

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

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

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

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

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

Java
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
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
1
2
3
4
5
6
7
public interface eJabberdSenderInteface {
    void onRecievedMessage(String msg);
 
    void onLogin(boolean aTrue);
 
    void onPostExecute(boolean b);
}

Дергаю так

Java
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
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
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
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
1
2
3
4
5
6
  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
1
2
3
4
5
6
7
new jabberdSenderAcyncTaskerLocal(this,REQUEST) {
                @Override
                protected boolean doAction() throws Exception {
                    Thread.currentThread().wait(1000);
                    return false;
                }
            }.execute();

Новые блоги и статьи Все статьи Все блоги /
Подключение Box2D v3 к SDL3 для Android: физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL3_image 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .
Влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .	Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .

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