Простой мессенджер на tkinter,socket и threading
В этой статье я бы хотел показать как написать простое приложение мессенджер менее чем в 150 строк.
Серверная часть
Начнём с сервера(наше приложение будет состоять из скриптов сервера и клиента), через который можно получать входящие запросы от клиентов, желающих общаться. Традиционно указываем путь до интерпретатора и импортируем необходимые модули. Конкретно socket и threading. Первый отвечает непосредственно за “общение” процесссов между собой, второй за многопоточность. О этих модулях подробно можно почитать например здесь — socket , threading.
Использование фреймворков, таких как Twisted и SocketServer, было возможным, но мне показалось это излишним для такого простого программного обеспечения, как наше.
Давайте обозначим константы, отвечающие например за адрес порта и размер буфера.
Теперь мы разбиваем нашу задачу на прием новых соединений, рассылку сообщений и обработку определенных клиентов. Давайте начнем с принятия соединений:
Это просто цикл, который всегда ждет входящих соединений и, как только он его получает, регистрирует соединение (печатает некоторые сведения о соединении) и отправляет подключенному клиенту приветствие. Затем он сохраняет адрес клиента и позже запускает поток обработки для этого клиента. Конечно, мы еще не определили для этого целевую функцию handle_client (), но вот как мы это сделаем:
Естественно, после того, как мы отправим новому клиенту приветственное сообщение, он ответит именем, которое он хочет использовать для дальнейшего общения. В функции handle_client () первая задача, которую мы делаем, — мы сохраняем это имя, а затем отправляем клиенту еще одно сообщение о дальнейших инструкциях. После этого идет основной цикл: здесь мы получаем дополнительные сообщения от клиента и, если сообщение не содержит инструкций для выхода, мы просто передаем сообщение другим подключенным клиентам (мы определим метод широковещания через минуту ). Если мы сталкиваемся с сообщением с инструкциями выхода (то есть клиент отправляет ), мы возвращаем то же самое сообщение клиенту, а затем мы закрываем сокет подключения для него. Затем мы делаем очистку, удаляя запись для клиента, и, наконец, сообщаем другим связанным людям, что этот конкретный человек покинул чат.
Теперь пропишем функцию broadcast ():
Эта функция просто отправляет сообщение всем подключенным клиентам и при необходимости добавляет дополнительный префикс. Мы передаем префикс для broadcast () в нашей функции handle_client () и делаем это так, чтобы люди могли точно знать, кто является отправителем конкретного сообщения. Это были все необходимые функции для нашего сервера. Наконец, мы добавили код для запуска нашего сервера и прослушивания входящих соединений:
Мы присоединяемся к ACCEPT_THREAD, чтобы основной скрипт ожидал его завершения и не переходил на следующую строку, которая закрывает сервер. Это завершает наш серверный скрипт.
В итоге получаем вот такой код для серверной части:
Клиентская часть###
Теперь приступим к наиболее интересной части нашего приложения — к клиенту. В качестве gui будем использовать tkinter, т.к в нём довольно легко построить несложное приложение. Традиционно импортируем модуль tkinter, а также модули использовавшиеся ранее при написании серверной части программы.
Теперь мы напишем функции для обработки отправки и получения сообщений. Начнем с получения:
Почему мы снова используем бесконечный цикл? Потому что мы будем получать сообщения совершенно независимо от того, как и когда мы отправляем сообщения. Мы не хотим, чтобы это было приложение для чата с функциональностью уровня рации. Мы хотим приложение в котором можно отправлять или получать сообщения одновременно; мы хотим получать сообщения, когда сами того пожелаем, и отправлять их, когда захотим.
Функциональность внутри цикла довольно проста; recv () является блокирующей частью. Он останавливает выполнение до тех пор, пока не получит сообщение, а когда это произойдет, мы продвигаемся вперед и добавляем сообщение в msglist. Затем мы определяем msg_list, который является функцией Tkinter для отображения списка сообщений на экране. Далее мы определим функцию send ():
my_msg — это поле ввода в графическом интерфейсе, и поэтому мы извлекаем сообщение для отправки с помощью msg = my_msg.get (). После этого мы очищаем поле ввода и затем отправляем сообщение на сервер, который, как мы видели ранее, передает это сообщение всем клиентам (если это не сообщение о выходе). Если это сообщение о выходе, мы закрываем сокет, а затем приложение с графическим интерфейсом (через top.close ())
Мы определяем еще одну функцию, которая будет вызываться, когда мы решим закрыть окно с GUI. Это своего рода функция очистки до закрытия, которая закрывает соединение с сокетом до закрытия графического интерфейса:
Это устанавливает в поле ввода значение , а затем вызывает send (). Начнем с определения виджета верхнего уровня и установки его заголовка, как и в любой другой программе на tkinter:
Затем создаём фрейм со списком сообщений, поле для ввода сообщений и скроллбар для перемещения по истории переписки
“Упаковываем” наши элементы и размечаем их расположение в окне:
После этого мы создаем поле ввода для пользователя, чтобы ввести свое сообщение, и привязать его к строковой переменной, определенной выше. Мы также привязываем его к функции send (), чтобы всякий раз, когда пользователь нажимает return, сообщение отправлялось на сервер.
Далее мы создаем кнопку отправки, если пользователь желает отправить свои сообщения, нажав на нее. Опять же, мы связываем нажатие этой кнопки с функцией send ().
И да, мы также упаковываем все то, что создали только сейчас. Кроме того, не забудьте использовать функцию очистки on_closing (), которая должна вызываться, когда пользователь хочет закрыть окно GUI:
И вот мы подходим к завершению. Мы еще не написали код для подключения к серверу. Для этого мы должны запросить у пользователя адрес сервера. Я сделал это, просто используя input (), чтобы пользователь встретился с подсказкой командной строки, запрашивающей адрес хоста перед запуском окна с графическим интерфейсом. В будущем можно добавить виджет для этой цели. А пока вот так:
Как только мы получаем адрес и создаем сокет для подключения к нему, мы запускаем поток для получения сообщений, а затем основной цикл для нашего приложения с графическим интерфейсом:
Вот и всё! Теперь наш скрипт клиентской части выглядит вот так:
Да, наше приложение не может тягаться с такими гигантами как: telegram, viber, клиентами xmpp/jabber; однако нам удалось создать простой чат, который каждый может развить в что-то своё: сделать уклон в безопасность(например шифруя передаваемые пакеты) или в хороший ux/ui. Получилась своего рода база для чего-то большего и это круто. Спасибо за прочтение, буду рад любым замечаниям и пожеланиям. Традиционно исходный код программы доступен в моём репозитории на github.
How to build Messenger chatbot in Python, Flask and Heroku?
I will show you how to build your own bot and deploy it on Messenger platform in several simply steps using Python, Flask and Heroku.
Setup Facebook Developer Account
Before you start coding have to create a Facebook developer account, Facebook App & Facebook page, and set it all up.
When yours’ new Facebook Page and App are ready you have to connect them together. To do this, open the App page, use the Set up button under the Messenger box in Dashboard tab. Add your newly created Page and allow App to manage and access conversation in Messenger. After that Edit Page Subscriptipon check messages, messaging_postback and messagingn_referrals. Then generate, copy and save secret token which will be necessary later and use button Add to Submission next to pages_messaging — that’s will be enough for now. Let’s move on. We’ll be back here when our Flask application starts working.
Coding time ��������
I assume that you know what Flask is and you already have at least basic experience with Python. If not I’ll refer you to the Python and Flask documentation. Best will be use Python 3.7 or newer version. If you still use Python 2.x you have to migrate as soon as possible.
Ok, start with creating an HTTP server:
And add your Webhook endpoint — this is the core of your Messenger bot. By using Webhook you will receive, process, and send messages.
Now you can run your Flask app locally and public URLs using ngrok which
will allow to test the solution until deploy them on Heroku.
Build better voice apps. Get more articles & interviews from voice technology experts at voicetechpodcast.com
To authorize Webhook back to your Facebook Developer App Dashboard. Add Callback URL in Webhook part and provide Verify Token (the same which you set in Flask app).
Voila ���� your connection between server and Messenger is ready. Now we can take care of messaging ✉️. As there is in documentation…
Messages are sent by submitting a POST request to the Send API with your page access token appended to the URL query string:
https://graph.facebook.com/ v5.0 /me/messages?access_token=<PAGE_ACCESS_TOKEN>
… so add POST support and start receiving messages from users ��.
Now if you send a message to your chatbot in console you can see how the POST request looks like:
This is a Python dict with several keys like sender id, recipient_id or message[‘text’] that stores the message from the user. If you can know how to catch messages will be good to answer them, right?
Look at the documentation and everything will be clear ��
Sending Text
To send a basic text message, submit a POST request to the Send API, with message.text set in the request body:
curl -X POST -H "Content-Type: application/json" -d ' <
"recipient": <
"id":"<PSID>"
>,
"message": <
"text":"hello, world!"
>
>' "https://graph.facebook.com/ v5.0 /me/messages?access_token=<PAGE_ACCESS_TOKEN>"
Of course you can arrange different conditions and answers depending on what the user has written to us (if — else). You can arrange various scenario, query the API of external suppliers and return desired information depending on what you or your business need. I highly recommend you to read the documentation prepared by Facebook. They’ve provided many types of response you can use to do it. It doesn’t have to be plain text. Persistent Menu, Buttons, Quick Replies these are just some of them, and all of them significantly improve the user experience.
Deploying Flask App to Heroku
At first of course you have to create account on Heroku if you don’t have yet. Create new project on it, install on your computer Heroku CLI & Git CLI (we use git to upload our code).
Open console inside your project create Procfile with code bellow:
The web command tells Heroku to start a web server for app using gunicorn. If your app file name is named app.py, you have to set the app name to be app as well.
If you did it, in the next step in console run…
… your apps should working on Heroku now. Last thing which you have to do it’e edit Callback URL onto Facebook Developer account. Have fun! ��
Пишем свой мессенджер P2P
На фоне обсуждения будущего интернет мессенджеров и прочтения статьи «Почему ваш любимый мессенджер должен умереть», решил поделиться своим опытом создания P2P приложения для общения независимо от сторонних серверов. Точнее — это просто заготовка, передающая одно сообщение от клиента серверу, дальнейшее расширение функционала зависит только от Вашей фантазии.
В этой публикации мы напишем 3 простых приложения для связи P2P из любой точки Земного шара — клиент, сервер и сигнальный сервер.
Нам понадобится:
— один сервер с белым статическим IP адресом;
— 2 компьютера за NAT с типом соединения Full Cone NAT (либо 1 компьютер с 2-мя виртуальными машинами);
— STUN-сервер.
Full Cone NAT — это такой тип преобразования сетевых адресов, при котором существует однозначная трансляция между парами «внутренний адрес: внутренний порт» и «публичный адрес: публичный порт».
Вот, что мы можем прочесть о STUN-сервере на Wiki:
При решении задачи использовались следующие питоновские модули: socket, twisted, stun, sqlite3, os, sys.
Для обмена данными, как между Сервером и Клиентом, так и между Сервером, Клиентом и Сигнальным Сервером — используется UDP протокол.
В общих чертах механизм функционирования выглядит так:
Сервер <-> STUN сервер
Клиент <-> STUN сервер
Сервер <-> Сигнальный Сервер
Клиент <-> Сигнальный Сервер
1. Клиент, находясь за NAT с типом соединения Full Cone NAT, отправляет сообщение на STUN сервер, получает ответ в виде своего внешнего IP и открытого PORT;
2. Сервер, находясь за NAT с типом соединения Full Cone NAT, отправляет сообщение на STUN сервер, получает ответ в виде своего внешнего IP и открытого PORT;
При этом, Клиенту и Серверу известен внешний (белый) IP и PORT Сигнального Сервера;
3. Сервер отправляет на Сигнальный Сервер данные о своих внешних IP и PORT, Сигнальный Сервер их сохраняет;
4. Клиент отправляет на Сигнальный Сервер данные о своих внешних IP и PORT и id_destination искомого Сервера, для которого ожидает его внешний IP, PORT.
Сигнальный Сервер их сохраняет, осуществляет поиск по базе, используя id_destination и, в ответ, отдает найденную информацию в виде строки: ‘id_host, name_host, ip_host, port_host’;
5. Клиент принимает найденную информацию, разбивает по разделителю и, используя (ip_host, port_host), отправляет сообщение Серверу.
Приложения написаны на Python версии 2.7, протестированы под Debian 7.7.
Создадим файл server.py с содержимым:
Заполним соответствующие поля разделов: «Внешний IP и PORT СИГНАЛЬНОГО СЕРВЕРА» и «IP и PORT этого КЛИЕНТА».
Создадим файл client.py с содержимым:
Заполним соответствующие поля разделов: «Внешний IP и PORT СИГНАЛЬНОГО СЕРВЕРА» и «IP и PORT этого КЛИЕНТА».
Name already in use
If nothing happens, download GitHub Desktop and try again.
Launching GitHub Desktop
If nothing happens, download GitHub Desktop and try again.
Launching Xcode
If nothing happens, download Xcode and try again.
Launching Visual Studio Code
Your codespace will open once ready.
There was a problem preparing your codespace, please try again.
Latest commit
Git stats
Files
Failed to load latest commit information.
README.md
Что такое Messenger?
Messenger — бесплатный мессенджер с открытым исходным кодом для обмена мгновенными сообщениями
Messenger написан на языке програмирования Python
Работают ли определённые версии Python:
- 3.10 — Все основные тесты происходят на этой версии
- 3.9 — Версия поддерживается Messenger и тестируется в Github
- 3.8 — Версия поддерживается Messenger и тестируется в Github
- 3.7 — Версия не поддерживается, но пока что есть возможность запустить Messenger на ней
- 3.6 — Версия не поддерживается, но пока что есть возможность запустить Messenger на ней
- 2.7 — Версия не поддерживается
Остальные версии не тестировались
Скачивание из терминала
Если у вас установлен git , то выполните команду: git clone https://github.com/werryxgames/Messenger.git
В таком случае Messenger скачается в текущую директорию
Скачивание из Github
Также вы можете скачать Messenger при помощи интерфейса Github
Нажмите на кнопку Code , а затем на Download ZIP
Необходимо распаковать скачанный архив в нужную директорию
Теперь вы можете удалить скачанный архив
Теперь вы можете создать ярлыки со следующими командами на рабочий стол:
Рекомендуется обновлять версию только из релизов
Прочитайте, написано ли в релизе про изменение формата хранения данных. Если да, то необходимо будет удалить все данные, затем проделайте шаги, как в Скачивание репозитория
Если написано, что формат хранения данных не изменён, или ничего не написано, проделайте шаги, как в Скачивание из Github, но распакуйте только файлы server.py и main.py
Messenger состоит из двух частей: сервера и клиента
Сервер хранит все данные и обрабатывает запросы от клиентов
Клиент показывает информацию от сервера в графическом виде
Чтобы запустить сервер, напишите
Вы должны увидеть надпись Сервер запущен , иначе создайте проблему на вкладке Issues
Перед надписью Сервер запущен может появиться дополнительная информация ( True , False (несколько раз) и список с сообщениями). Это значит, что база данных сброшена до первоначального состояния. После этого рекомендуется выключить сервер и сделать то, что написано в Отключение сброса базы данных
Отключение сброса базы данных
Чтобы отключить сброс базы данных, необходимо зайти в файл server.py (пролистать в конец) и убрать все строки между этими (оставьте сами строки, удалите все строки, на месте которых «. «):
Вам понадобиться включить сервер
Чтобы зайти в Messenger в первый раз, надо создать аккаунт. Для этого введите логин и пароль в соответствующие поля. Если всё правильно, то вы должны увидеть, как появится основной интерфейс Messenger`а
Если интерфейс не появился, посмотрите в консоли, там должно была появиться ошибка на подобии следующей:
Чтобы отправить сообщения, выберите получателя в списке слева, напишите текст сообщения справа внизу и нажмите ‘Enter’, или кнопку ‘Отправить’
Внизу вашего сообщения написан его статус
- Отправлено — Сообщение отправлено, но ещё не получено сервером
- Доставлено — Сообщение доставлено на сервер, но ещё не получено получателем
- Получено — Сообщение получено получателем, но он ещё не ответил
- Прочитано — Сообщение получено получателем, который написал что-то после вашего сообщения
Код проверяется при помощи flake8 и pytest (тесты в папке tests):