Здравствуйте,

есть задача: 
1. принять сообщение
2. передать сообщение модулю по префиксу команды (к примеру команда monitor::update, где monitor - имя модуля, в котором находится обработчик, update - команда)
3. в заданном модуле произвести обработку, и асинхронно вернуть результат, в некоторую очередь в первом модуле

пояснение к задаче:
1) за прием и маршрутизацию команд отвечает модуль router
2) тестовый модуль, в котором будет обработчик назовем monitor
3) при загрузке модуль monitor регистрирует функцию обработчик в модуле router. Добавляет в список префиксов префикс 'monitor' - связка префикс-обработчик
4) очередь результатов, находится в модуле router и должна быть доступна всем прочим модулям

вопрос по 4 пункту: используется динамическое связывание, модули подключаются во время исполнения программы, как сделать объект общим? Если я описываю, объект как extern при связывании линкер пишет undefined symbol, если я не указываю extern создается локальная копия

обоснованная критика архитектуры приветствуется

Модуль router оформляется как librouter.so файл (с описанием объекта без каких либо префиксов в нем самом и с extern в соответствующем *.h файле) Главная программа линкуется с librouter.so, с ним же ликуются при компиляции все остальные загружаемые модули (они должны быть собраны в виде *.so файлов).
Тогда при загрузке этих *.so (через dlopen) они подхватят librouter.so, который к тому времени уже будет загружен в основной программе



Это сообщение отредактировал(а) xvr - 9.11.2014, 13:39

Описан dbus

А почему нельзя воспользоваться СТАНДАРТНЫМ механизмом очередей сообщений в Linux?
- man 2 msgget
- man 3 mq_open

Это база. Можно воспользоваться d-Bus, если хочется поковыряться...

Просто, дело в том, что реализуя механизм очередей сообщений самостоятельно, Вы неизбежно столкнётесь с проблемой блокировок и анализом полноты буферов. Это не очень простые задачи.

наверно можно, но это будет менее эффективно, все-таки msgget это механизм IPC. А так же, после, все-равно придется выполнять копирование в тот самый объект (хеш-таблица), так как с ним ведется работа

dbus - тоже IPC



это предусмотрено в самой хеш-таблице, там коллизии разрешаются списками, а списки лочатся. Это и сейчас работает, я просто уперся в архитектуру (модуль стал слишком жирным), мне нужно произвести эти изменения, чтобы двигаться дальше

Добавлено @ 15:51


спасибо за ответ.
но мне очень не хочется линковаться с еще одной либой, дело в том, что модули выгружаемые, и совсем не факт, что во всех конфигурациях это понадобится - в некоторых случаях она будет висеть мертвым грузом

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



Это сообщение отредактировал(а) fish9370 - 10.11.2014, 15:59

Описан любой message oriented middleware. То есть вообще любой, от zeromq до CORBA/WebSphere.

И совершэнно необязательно брать сразу самый дебильно сделанный.

Может, именно это я и предлагал. А что бы на этапе сборки линкер не ругался, ему этот router.so надо подать в линковку (при сборке модулей/динамических библиотек).

А почему самый дебильный? Я просто его использовал в связке с Qt, не скажу, что получал удовольствие, скорее наоборот, но оно работало. Потом пытался найти какую-то межхостовую его замену и наткнулся на ZeroC Ice. По описанию понравилось, даже написал тестовый примерчик Python vs C++. К несчастью времени попользовать его в боевых условиях не хватило. Приведённые Вами

лучше или каждый хорош по своему?

я попробую поиграться в разделе описания, раньше у меня таких проблем не было

мне нужно было выговориться, слишком я долго носил это в себе

<quote>&gt;Если я описываю, объект как extern при связывании линкер пишет undefined symbol,</quote>

1) Ни в коем случае, никогда, never,  nie, nunca, jamais -- не делай глобальных объектов. И синглтонов тожэ не делай. Когда тебе будет можно -- ты ужэ прекрасно поймёшь, о чём я, и что я имел в виду, а пока не понял -- просто не делай.

2) Типичный -- вызываешь какую-нибудь функцыю init(), или connect("address") которая возвращает ссылку на нужный тебе объект. У объекта, если он действительно объект C++ -- хорошым тоном будет сделать какой-нибудь абстрактный предок, с несколькими чисто виртуальным функцыями. А если не C++, с простой C -- то, соответственно, можно сделать непрозрачную структуру, которая просто передаётся внутрь  функцый библиотеки-мессенджэра.

Разумеется. А в чём дело? Вы ведь писали:



Асинхронными могут быть только процессы (потоки/нитки). Иначе вся эта затея теряет смысл. Если изначально предполагалась многопоточность, т о почему же не использовать стандартные средства синхронизации?!

Добавлено через 10 минут и 43 секунды

Для того, что бы ответить на этот вопрос, необходимо:

• Строчка исходного файла, в котором объект объявляется глобальным
• Строчка исходного файла (другого) в котором он используется
• Строчки из make-файла, в которых компиллируются и линкуются эти два объектных (so) файла.

Не знаю, как-то куда в нём ни ткнёшь -- в publish/subscribe, в marshalling (с системой типов из VBA, зато с обязательным юникодом), в релизацыю сервера, в его конфиг, в реальную поддержку tcp/ip -- всё как-то очень половинчато сделано. При  этом да, жыть можно -- да что там, я и на VBA писал, тожэ вполне себе язык программирования.



У каждого свои плюсы. У того жэ 0mq -- вообще не маршаллинга, всё относительно с очередями (впрочем, в dbus с очередями примерно такжэ) -- зато скорость высокая. У полувзрослых брокеров (rabbitMQ, например) -- много приятностей, вообще, на мой взгляд, из распространённого и подо все языки, rabbitMQ -- самый вменяемый вариант. Плюсов и возможностей совсем взрослых (webSphere той жэ) я пока не ощутил, но вполне допускаю, что отказоустойивость и интэроперабельность с джавой у них более на высоте.

я не буду это комментировать, просто выражу свое несогласие




1) не С++ 2) непрозрачную структуру - это как? 3) может пора уже что-то с русским языком сделать? сколько Вас читаю, ничего у Вас не меняется






разумеется потоков несколько, но разница, между передачей данных через IPC и напрямую существенна. Нужно ли это объяснять?











компилится с ключами -fPIC и -shared

линукуется динамически

Это сообщение отредактировал(а) fish9370 - 10.11.2014, 21:33

Это структура, поля которой не опубликованы для кода, который её использует. То есть как в stdio (stdin/stdout) или много где ещё. Доступ внутрь имеет только библиотека, которая обеспечивает интэрфейс к ней.

Да, передаётся обычно через указатель. 

как это должно помочь в моем вопросе?