Чтение/запись текста в Telegram канал из Android приложения

При написании программы приложения для Android в среде программирования Android Studio мною было потрачено значительное количество времени на разработку подпрограмм обмена текстовыми данными приложения с определенным Telegram каналом. Возможно это связано с моим небольшим опытом программирования на java или плохим освещением данного момента в интернете. Короче, для возможного сокращения временных затрат новичкам на разработку программ подключения приложения Android к Telegram предлагается данный туториал.

В основу предлагаемой программы положен один из способов обмена информацией в запросах Bot API: строка запроса URL. Для запросов используются HTTP методы GET и POST. Прием/передача текстовых данных производится в фоновом режиме посредством класса AsyncTask, задаваемого как внутренний класс основного класса приложения.

Передача данных производится посредством класса: SendMessageTelegram.

Прием данных производится посредством класса: GetMessageTelegram.

В основной программе (например MainActivity) до вызова объектов на основе данных классов необходимо определить переменные:

private String outMesRemember = "";//последнее запомненное передаваемое сообщение

public static String token = "bot_token";

public static String id = "chat_id";

private String updateTelegram = "";//новое сообщение в канале

Значения bot_token и chat_id прописываются из созданного вами канала Telegram. Как создать канал описано во многих источниках. Инициация процедуры Чтения/Записи текста в канал производится по вызову:

//посылка сообщения в telegram

new SendMessageTelegram().execute();

//получение нового сообщения из telegram-канала

new GetMessageTelegram().execute();

Далее приведены листинги программ с подробными комментариями выполняемых действий:

 //=====внутренний класс передачи сообщений в интернет на канал telegram=============         private  class SendMessageTelegram extends AsyncTask<Void, Void, Void> {         private String resultString = null; //метод для отображения индикатора выполнения в пользовательском интерфейсе            //не используется         @Override         protected void onPreExecute() {             super.onPreExecute();         }         // метод для выполнения задач в фоновом режиме         @Override         protected Void doInBackground(Void... voids) {             try {                 //адрес бота "телеграмм"                 String myURL =                         "https://api.telegram.org/bot" + token +"/sendMessage";                 String param = "chat_id=" + id + "&text=" + outMesRemember;                 byte[] data;                 try {//подключаемся к серверу                     URL url = new URL(myURL);                   HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();                     conn.setReadTimeout(5000);//тайм-аут чтения в мс                     conn.setConnectTimeout(10000);//тайм-аут соединения в мс                     conn.setRequestMethod("POST");                     conn.setDoOutput(true);                     conn.setDoInput(true);                     //задать общее свойство запроса:                     // - повторное использование соединений HTTP "Keep-Alive";                     // - тип формата отправки запроса по умолчанию (можно не указывать)           conn.setRequestProperty("Connection", "Keep-Alive");           conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");                     //определяем длину передаваемого сообщения                conn.setRequestProperty("Content-Length", "" + param.getBytes().length);                     OutputStream os = conn.getOutputStream();                     // конвертируем передаваемую строку в UTF-8                     data = param.getBytes(StandardCharsets.UTF_8);                     //передаем данные на сервер                     os.write(data);                     os.flush();                     os.close();                     conn.connect();   int responseCode = conn.getResponseCode();//Представляющие три цифры HTTP Status-Code                     resultString = Integer.toString(responseCode);                     conn.disconnect();//отключение соединения                 } catch (MalformedURLException e) {//неправильный адрес сайта                     resultString = "MalformedURLException:" + e.getMessage();                 } catch (IOException e) {//неудачная операция ввода/вывода                     resultString = "IOException:" + e.getMessage();                 } catch (Exception e) {//что-то пошло не так                     resultString = "Exception:" + e.getMessage();                 }             } catch (Exception e) {                 //e.printStackTrace();             }             return null;         }     // метод для обработки результата выполнения фоновых задач         @Override         protected void onPostExecute(Void result) {             super.onPostExecute(result);             // для отладки             if (resultString != null) {              //вывод результата на экран              Toast.makeText(MainActivity.this, resultString, Toast.LENGTH_LONG).show();             } else {              Toast.makeText(MainActivity.this, "no result", Toast.LENGTH_SHORT).show();             }          if (resultString.equals("200")) {//kod '200' - ok сообщение доставлено успешно       Toast.makeText(MainActivity.this, "СООБЩЕНИЕ:" +       outMesRemember  + "\r\n" + " ОТПРАВЛЕНО  B TELEGRAM", Toast.LENGTH_LONG).show();              } else {    Toast.makeText(MainActivity.this, "СООБЩЕНИЕ:" +    outMesRemember  + "\r\n" + " ОШИБКА отправки ИНТЕРНЕТ ", Toast.LENGTH_LONG).show();                                 }         }     }

  //=====внутренний класс приема новых сообщений через интернет с канала telegram=============         private class GetMessageTelegram extends AsyncTask<Void, Void, Void> {         private String resultString = null;         // метод для выполнения задач в фоновом режиме         @Override         protected Void doInBackground(Void... voids) {             try {                 //адресс бота "телеграмм"+получение последнего сообщения         String myURL = "https://api.telegram.org/bot" + token +"/getUpdates?offset=-1";                 byte[] data;                 try {//подключаемся к серверу          URL url = new URL(myURL);//создаем объект класса указателя ресурса в интернете          //создание объекта соединения  с удаленным объектом, на который ссылается URL.                //Приведение его к протоколу обмена HTTPs                   HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();                         //прописываем параметры соединения                     conn.setReadTimeout(5000);//тайм-аут чтения в мс                     conn.setConnectTimeout(10000);//тайм-аут соединения в мс                     conn.setRequestMethod("GET");                     conn.setDoOutput(true);                     conn.setDoInput(true);                     conn.connect();//подключаемся к ресурсу       InputStream is = conn.getInputStream();//открыть входной поток для чтения из URL             //BufferedReader - Читаем текст из потока ввода символов, буферизуя символы.                    //             //Можно указать размер буфера или использовать размер по умолчанию.             // Значение по умолчанию достаточно велико для большинства целей.                BufferedReader reader = new BufferedReader(new InputStreamReader(is));                StringBuilder buf = new StringBuilder();//спец.буфер для хранения строк                     String line;                     //Чтение строк текста пока не появится нулевая                     while ((line=reader.readLine()) != null) {               buf.append(line).append("\n");//в конце каждой строки доб. символ перевод строки                     }                    //полученное новое сообщение из телеграм-канала, ввиде JSONObject                    //со вложенными JSONObject внутри JSONArray (массива)                     String newMesTelegram = buf.toString();            //выделение текста из сообщения                     JSONObject jo = new JSONObject(newMesTelegram);                     JSONArray ja = jo.getJSONArray("result");//первое вложение                     String sj = ja.toString();                         //удаление признаков массива                     sj = sj.replace("[","");                     sj = sj.replace("]","");                  //если текст в сообщении присутствует, производим дальнейшую обработку                     if(!sj.equals("")) {                         JSONObject jon = new JSONObject(sj);                  JSONObject jonm = jon.getJSONObject("channel_post");//второе вложение                     //выделение текста из последнего JSONObject и преобразование его в                         //строку из UTF_8 кода                  updateTelegram = new String(jonm.getString("text").getBytes(), UTF_8);                     } else {                         updateTelegram = "";                     }                     is.close();      responseCode = conn.getResponseCode();//Представляющие три цифры HTTP Status-Code                     resultString = Integer.toString(responseCode);                     conn.disconnect();//отключение соединения                 } catch (MalformedURLException e) {//неправильный адрес сайта                     resultString = "MalformedURLException:" + e.getMessage();                 } catch (IOException e) {//неудачная операция ввода/вывода                     resultString = "IOException:" + e.getMessage();                 } catch (Exception e) {//что-то пошло не так                     resultString = "Exception:" + e.getMessage();                 }             } catch (Exception e) {                 //e.printStackTrace();             }             return null;         }         // метод для обработки результата выполнения фоновых задач         @Override         protected void onPostExecute(Void result) {             super.onPostExecute(result);             // для отладки             if (resultString != null) {                 //вывод результата на экран            Toast.makeText(MainActivity.this, resultString, Toast.LENGTH_LONG).show();             } else {            Toast.makeText(MainActivity.this, "no result", Toast.LENGTH_LONG).show();             }           if (resultString.equals("200")) {//kod '200' - ok сообщение получено успешно            Toast.makeText(MainActivity.this, "СООБЩЕНИЕ:" +            updateTelegram + "\r\n" + "ПОЛУЧЕНО ОТ TELEGRAM", Toast.LENGTH_LONG).show();                            }         }     }

Обмен данными представлен в виде двух отдельных классов, чтобы была возможность использования программы только для получение или передачи текста в канал.

Программа написана без использования дополнительных библиотек при декодировании получаемых сообщений из Telegram канала в виде JSON объекта и без использования веб‑перехватчиков (webhook). Но есть недостаток в представленном способе получения данных из канала — необходимость его периодически опрашивать.

При разработке программы за основу взяты примеры описанные в данных источниках:

Как в Android Studio передавать данные на сервер в интернете

Загрузка данных и класс HttpURLConnection