Основанный на Netty фреймворк для реализации MVC-паттерна разработки

└── framework
    ├── codec Кодирование и декодирование
    ├── core Обработка сообщений и маршрутизация
    └── session Управление соединением и отправка сообщений

@Endpoint
public class JT808Endpoint {

    @Autowired
    private LocationService locationService;

    @Autowired
    private DeviceService deviceService;
}
``````markdown
    // Асинхронная обработка пакетных сообщений, размер очереди 20000, максимальное количество сообщений для обработки за один раз 200, максимальное время ожидания 5 секунд
    @AsyncBatch(capacity = 20000, maxElements = 200, maxWait = 5000)
    @Mapping(types = "Сообщение о местоположении", desc = "Сообщение о местоположении")
    public void сообщение_о_местоположении(List<T0200> list) {
        locationService.batchInsert(list);
    }

    @Async
    @Mapping(types = "Регистрация терминала", desc = "Регистрация терминала")
    public T8100 register(T0100 message, Session session) {
        Header header = message.getHeader();

        T8100 result = new T8100(session.nextSerialNo(), header.getMobileNo());
        result.setSerialNo(header.getSerialNo());

        String token = deviceService.register(message);
        if (token != null) {
            session.register(header);

            result.setResultCode(T8100.Success);
            result.setToken(token);
        } else {

            result.setResultCode(T8100.NotFoundTerminal);
        }
        return result;
    }
}

Для более подробных примеров обратитесь к директории Test. Проекты, использующие этот компонент: [https://gitee.com/yezhihao/jt808-server/tree/master](https://gitee.com/yezhihao/jt808-server/tree/master).

Проект периодически обновляется, рекомендую звездить и следить за ним, ваша поддержка — моя самая большая мотивация.

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

Группа для технического общения в QQ: [906230542]