Форум программистов, компьютерный форум CyberForum.ru

Программирование Android

Войти
Регистрация
Восстановить пароль
 
zoleg
14 / 14 / 1
Регистрация: 10.01.2012
Сообщений: 138
#1

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

06.03.2016, 13:12. Просмотров 201. Ответов 5
Метки нет (Все метки)

Не могу сообразить как одновременно и передать в 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) {
 
    }
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
06.03.2016, 13:12     Передать String в AsyncTask, получить callback
Посмотрите здесь:

Android AsyncTask<String, String, String> объясните пожалуйста
Android Как получить данные из Runnable процесса вызываемого из CallBack функции
Android AsyncTask
Android Как получить значение String из UI потока в потоке AsyncTask?
Получить первую букву из слова (переменная String) Android
Android AsyncTask и get()
AsyncTask Android
Передать String-путь в EditText AlertDialog'a ? Android
AsyncTask Android
Как получить ресурс из String с путем ресурса? Android
Android Получить данные в string

Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Mikalai
256 / 232 / 93
Регистрация: 11.01.2015
Сообщений: 651
06.03.2016, 16:22     Передать String в AsyncTask, получить callback #2
zoleg, AsyncTask - пример
zoleg
14 / 14 / 1
Регистрация: 10.01.2012
Сообщений: 138
06.03.2016, 18:08  [ТС]     Передать String в AsyncTask, получить callback #3
Цитата Сообщение от 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
256 / 232 / 93
Регистрация: 11.01.2015
Сообщений: 651
06.03.2016, 18:30     Передать String в AsyncTask, получить callback #4
Цитата Сообщение от zoleg Посмотреть сообщение
Упрощаю задачу
Спасибо! ))

А зачем тут вообще AsyncTask? почему просто не сделать второй поток, а ответ прислать через EventBus?
zoleg
14 / 14 / 1
Регистрация: 10.01.2012
Сообщений: 138
06.03.2016, 18:48  [ТС]     Передать String в AsyncTask, получить callback #5
Цитата Сообщение от Mikalai Посмотреть сообщение
почему просто не сделать второй поток, а ответ прислать через EventBus?
Вот от него то и хочу избавится. С ним работает но есть некая неприятность. Липкий Ивент принять не могу (приемник не заточен для него), а простой не доходит до адресата если АсинхТаск успевает к этому времени завершится.
В общем , доходит, но не всегда Липкий вообще не канает именно для этого приемника. Приходится перешаманивать. А так все легко получилось , но не все же в жизни Масленица, должны быть и неприятности.
zoleg
14 / 14 / 1
Регистрация: 10.01.2012
Сообщений: 138
07.03.2016, 23:36  [ТС]     Передать String в AsyncTask, получить callback #6
Все оказалось очень просто

Убираем переопределение
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();
Yandex
Объявления
07.03.2016, 23:36     Передать String в AsyncTask, получить callback
Ответ Создать тему
Опции темы

Текущее время: 06:32. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru