Слияние кода завершено, страница обновится автоматически
На основе протокола MQTT реализована система мгновенного обмена сообщениями (IM) с использованием коммуникационного компонента Netty.
Реализовано на основе Netty и MQTT, поддерживает управление соединением и пересылает бизнес-логику в ocean-logic через Motan RPC.
Обрабатывает конкретную бизнес-логику IM, временно использует MongoDB.
Базовая модель.
Java SDK, демонстрационная версия.
Способ запуска: 1. Запустите com.dempe.logic.server.LogicServer (зависит от MongoDB, обратите внимание на изменение конфигурации application-mongo.xml). 2. Запустите com.dempe.chat.ChatServer. 3. Запустите com.dempe.ocean.sdk.example.ChatSdkDemo.
После запуска вы увидите следующие сообщения в журнале:
[INFO]2016-09-09 11:50:34,370, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:50:44,182, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:50:54,183, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:51:04,184, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:51:14,184, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:51:24,182, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:51:34,186, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
[INFO]2016-09-09 11:51:44,185, [MessageThread]ChatSdkDemo.java:31, onFriendMsg topci:f|222,payload:[104, 101, 108, 108, 111]
Проект находится в стадии разработки, логика ещё не реализована и проект пока недоступен для использования.
1. Выделить connector, который будет только поддерживать соединение и пересылать сообщения, чтобы сделать его более лёгким.
2. Переработать ocean-logic, разделить конкретные реализации и предоставить механизм для расширения функциональности.
3. Решить проблемы с MQTT при реализации IM.
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )