Вопросы с тегами [message]

1

голосов
1

ответ
3.6k

Просмотры

msgrcv: Invalid ошибки Аргумент

Я получаю сообщение об ошибке, которое говорит: msgrcv: недопустимый аргумент, что может быть причиной этой ошибки? Вот мой код Bassically Я передаю сообщение от родителя к ребенку, то я хочу, чтобы передать сообщение от ребенка к родителю, и даже если я использую в основном один и тот же код для обоих, она не работает второй получить. структура тзд {длинный ИНТ метатип; / * Тип сообщения * / символ МТЕКСТ [1024]; / * Текст сообщения * /} сбщ; INT Len, msgflg = 0, msqid * пинта; pid_t ПИД-регулятора; size_t msgsz = 40; долго INT msgtyp; msqid = msgget (IPC_PRIVATE, S_IRWXU); символ * charpid [250]; msg.mtype = 1; если (msqid <0) {PError ( "msgget"); выход (1); } Переключатель (PID = вилка ()) // вилки дочерний процесс {Случай 0: процесс // Ребенок // получить сообщение от родителя, если (msgrcv (msqid, & тзд, SizeOf msg.mtext, 1, IPC_NOWAIT)> = 0) {Е ( "Обслуживание для клиента PID #% S", msg.mtext); asprintf (& charpid [0], "% Л.Д. \ п", PID); strncpy (msg.mtext, charpid [0], 1024); если (msgsnd (msqid, & тзд, STRLEN (msg.mtext), msgflg)
Matt_Bro
1

голосов
0

ответ
279

Просмотры

Как получить множественное сообщение RabbitMQ обратного вызова?

Я использую RabbitMQ в рамках симфоней публиковать и использовать данные очереди. Я успешно передать данные в очередь, но при чтении данных я с вопросом. одно сообщение я могу легко, но проблема чтения с множественным сообщением с обратным вызовом. У меня есть создать дизайн для потребления очереди с использованием некоторых услуг. QueueService.php класс QueueService {защищенный $ логгер; общественная функция addInQueue ($ класс $ данных, $ событие, $ IsEnabled) {$ publishData = $ this-> getPublishData ($ класс $ данных, $ событие, $ IsEnabled); $ This-> queue-> опубликовать ($ publishData); } Общественная функция fetchInQueue () {$ this-> logger-> информация ( 'fetchInQueue >>>>>>>>'); $ Рез = $ this-> queue-> потреблять (); $ This-> logger-> информация ( 'получила сообщение >>>>>>>>' print_r ($ Рез, истинный).); }} AMQPHelper.php класс AMQPHelper {защищенный $ conConfig; защищенный $ queueConfig; защищенный $ регистратора; частный $ ответ; общественная функция __construct ($ conConfig, $ queueConfig) {$ this-> conConfig = $ conConfig; $ This-> queueConfig = $ queueConfig; $ LoggerHelper = новый LoggerHelper (); $ This-> Регистратор = $ loggerHelper-> Init ( 'AMQP-помощник'); } Общественная функция потребления () {$ соединение = новый AMQPConnection ($ this-> conConfig [ 'хозяин'], $ this-> conConfig [ 'порт'], $ this-> conConfig [ 'имя пользователя'], $ this-> conConfig [ 'пароль'], $ this-> conConfig [ 'ВХост']); $ Канал = $ connection-> канал (); $ Channel-> exchange_declare ($ this-> queueConfig [ 'обмен'], 'прямой', ложь, истина, ложь); $ Channel-> queue_declare ($ this-> queueConfig [ 'обмен'], ложь, истина, ложь, ложь); $ Channel-> queue_bind ($ этом-> queueConfig [ 'обмен'], $ этом-> queueConfig [ 'обмен'], $ этом-> queueConfig [ 'маршрутизации']); // Потребляйте $ channel-> basic_qos (нуль, 1, NULL); $ Channel-> basic_consume ($ этом-> queueConfig [ 'обмен'], $ этом-> queueConfig [ 'маршрутизации'], ложь, ложь, ложь, ложь, массив ($ это, 'getQueueMsg')); в то время как (количество ($ CHANNEL-> обратные вызовы)) {$ this-> logger-> информация (»messages'.print_r ($ this-> ответ, 1)); $ This-> logger-> информация (» Ожидание входящих сообщений); $ Channel-> ждать (); } $ Connection-> Close (); $ Channel-> близко (); вернуть $ this-> ответ; } Общественная функция getQueueMsg (AMQPMessage $ тзд) {$ this-> logger-> информация ( 'Тело сообщения', print_r ($ тзд, 1)); $ Данных = json_decode ($ msg-> тело, правда); $ This-> ответ = $ данных; } У меня написать консольную команду использовать QueueService function.I хочет, чтобы все возвращаемые данные очереди в консоли команды, потому что после получения всех данных очереди я хочу, чтобы повторно запустить некоторые консольные команды, основанные на данных. ConsumeFailureCommand.php класс ConsumeFailureCommand расширяет BaseCommand {защищенная функция конфигурирования () {$ это -> SetName ( 'потребляют безотказную') -> setDescription ( 'сообщение с уведомлением потребителя от RabbitMQ') -> addOption ( ' ждать», нулевой InputOption :: VALUE_REQUIRED 'Ждите следующее сообщение', 1); } Защищенная функция выполнения (InputInterface $ ввода, OutputInterface $ выход) {$ queueMng = $ this-> getContainer () -> получить ( 'service_queue_management.queue_service'); $ Этом-> setInput ($ вход); $ This-> setOutput ($ выход); $ Данные = $ queueMng-> fetchInQueue (); $ Этом-> Логинфо (print_r ($ данные, 1)); }}, Так как очередь будет возвращать все данные службы. Она возвращает одно сообщение каждый раз, но я хочу многомерном массив всех данных. getContainer () -> Get ( 'service_queue_management.queue_service'); $ Этом-> setInput ($ вход); $ This-> setOutput ($ выход); $ Данные = $ queueMng-> fetchInQueue (); $ Этом-> Логинфо (print_r ($ данные, 1)); }}, Так как очередь будет возвращать все данные службы. Она возвращает одно сообщение каждый раз, но я хочу многомерном массив всех данных. getContainer () -> Get ( 'service_queue_management.queue_service'); $ Этом-> setInput ($ вход); $ This-> setOutput ($ выход); $ Данные = $ queueMng-> fetchInQueue (); $ Этом-> Логинфо (print_r ($ данные, 1)); }}, Так как очередь будет возвращать все данные службы. Она возвращает одно сообщение каждый раз, но я хочу многомерном массив всех данных.
truesource
1

голосов
1

ответ
29

Просмотры

Существует ли система очереди сообщений, которая поддерживает темы 10k?

У нас есть проблемы, как это: У нас есть работа последовательно идет из очереди. Эти рабочие места имеют различные типы и различные типы заданий обрабатываются с разной скоростью. Мы обрабатываем эти рабочие места одновременно, поэтому мы не требуем рабочих мест, обрабатываемых в порядке, так что строго нам не нужны очереди FIFO. На самом деле, блокируя один тип заданий из-за медлительности другого вида работ не допускается. Если мы сможем создать тему для каждого типа заданий, то проблема решена. Но проблема в том, что у нас так много видов работ, потенциально 10k из них. В настоящее время мы готовимся построить систему «очередь» для этой проблемы, возможно, на верхней части базы данных. Но использование БД в качестве очереди рассматривается как анти-паттерна с помощью большого количества людей. Есть ли система очередей сообщений, которые могут обрабатывать 10k тему (или подразделы)? Одним из требований является то, что на стороне потребителя нужно менять темы он выписывает последовательно. Так что, если требуется много Спасибо за ваши советы.
ntysdd
1

голосов
0

ответ
99

Просмотры

chrome extension - Pass message among background, content script, and popup

Мой код содержание сценария включает в себя: chrome.runtime.onMessage.addListener ((сообщение, отправитель, SendResponse) => {console.log (сообщение); console.log (отправитель);}); chrome.runtime.onConnect.addListener ((порт) => {если (port.name === 'стучать') {console.log (порт); port.onMessage.addListener ((MSG) => {console.log ( MSG);});}}); вар порт = chrome.runtime.connect ({имя: 'стучать'}); В то время как в фоновом режиме chrome.runtime.onConnect.addListener ((порт) => {если (port.name === 'стучать') {console.log (порт); port.onMessage.addListener (функция (МСГ) {консоль. журнал (MSG);});}}); вар порт = chrome.runtime.connect ({имя: 'стучать'}); И всплывающее окно вар порт = chrome.runtime.connect ({имя: 'стучать'}); port.postMessage ({сообщение: {Успех: истинно}}); Фон окружающей среды принимает и регистрирует сообщение успешно, в то время как ни один из скрипта содержимого не журналы запуска. Я смущен этим. Как я могу отправить сообщение через порт (создание долгоживущих соединения) из фона, всплывающее окно к содержимому среды сценариев и наоборот?
necroface
1

голосов
0

ответ
242

Просмотры

Нет Сообщение об ошибке при подаче запроса на пост

Я пытаюсь опубликовать данные в базу данных с помощью запроса на запись. Я также использую данные из входного в предыдущей странице. Т.е. посещение Профиля пользователя и добавляет данные в форму Данные форм размещена на контроллер, а затем создать вид возвращается с входными данными Формы в создании зрения предварительно заполняются предыдущими данными (от контроллера), пользователь должен иметь возможность отправить форму, но это не проливает ошибок сообщения Я заметил, что URL будет / предварительно заказывать противоположность / Бронирование / создать (это связанно с страницей профиля передачи данных в контроллер и вывод. есть идеи? профиль функцию предварительно заказывать общественный контроллер () {$ дата = Input :: получить ( 'запрос', '01 / 01/2010 '); $ гостей = вход :: получить (' гости, '2'); $ ресторан = Input :: получить (» restaurantID», '2'); $ RestaurantName = Input :: получить ( 'restaurantName', '2'); $ Время = Input :: получить ( 'timeFrom', '2'); вернуться вид ( 'userbookings.create') -> с ( 'дата', $ дата) -> с ( 'гости', $ гостей) -> с ( 'ресторан', $ ресторан) -> с ( 'restaurantName', $ restaurantName) -> с ( 'время', $ времени); } Опубликовать код формы {!! Форма :: разомкнут (массив ( 'маршрут' => 'user.bookings.store', 'метод' => 'POST')) !!} @include ( 'userbookings.form') {!! Форма :: близко () !!} Создать форму (например, поле ввода) Party Size: Метод Хранить в контроллер публичной функции магазина (Request $ запрос) {запрос () -> Validate ([ 'дата' => 'требуется', 'timeFrom' => 'требуется', 'TimeTo' => 'требуется', «partySize '=> 'требуется', 'статус'=> 'требуется', 'комментарии'=> 'требуется']); Бронирование :: создать ($ request-> все ()); вернуться редирект () -> маршрут ( 'user.bookings.index') -> с ( 'успех', 'созданный бронирование успешно'); } Миграция Код: Схема :: Create ( '' бронирований, функция (Blueprint $ таблица) {$ table-> приращения ( 'идентификатор'); $ table-> целое число ( 'user_id') -> без знака (); $ стол-> иностранный ( 'user_id') -> ссылки ( 'ID') -> по ( 'пользователей'); ** $ table-> строка ( 'дата'); ** ** $ table-> строка ( 'timeFrom'); ** $ table-> строка ( 'TimeTo'); ** $ table-> строка ( 'partySize'); ** $ table-> строка ( 'статус'); $ Стол-> текст ( 'комментарии'); ** $ стол-> текст ( 'BusinessID'); ** $ table-> метки времени (); }); ** $ стол-> текст ( 'BusinessID'); ** $ table-> метки времени (); }); ** $ стол-> текст ( 'BusinessID'); ** $ table-> метки времени (); });
CarlM
1

голосов
0

ответ
141

Просмотры

Viber: как удалить сообщение с API

Как я могу удалить сообщение, отправленное с моим ботом к пользователю? Если сообщение содержит кнопки это будет влиять на них? Есть ли они исчезают? Каков наилучший способ удаления кнопки?
Eugene Lisitsky
1

голосов
1

ответ
108

Просмотры

Почему msgsnd () и msgrcv () не может работать хорошо?

Msgsnd () и msgrcv () находятся в одной и той же функции, она работает хорошо, как и в первом примере. main.c #include #include #include INT основных (INT ARGC, символ * ARGV []) {pid_t ПИД1; pid_t ПИД2; pid_t PID3; pid_t pid4; если ((ПИД1 = вилка ()) <0) {Е ( "вилка ошибка \ п"); } Еще если (ПИД1 == 0) {Е ( «Я в первый процесс \ п»); INT NodeId = 1; // cmc_init (NodeId); test2 (NodeId); возвращать 0; } Если ((PID2 = вилка ()) <0) {Е ( "вилка ошибка \ п"); } Еще если (ПИД2 == 0) {Е ( «Я нахожусь в процессе второго \ п»); INT NodeId = 2; // cmc_init (NodeId); test2 (NodeId); возвращать 0; } Если ((PID3 = вилка ()) <0) {Е ( "PID3 вилка ошибки \ п"); } Еще если (PID3 == 0) {Е ( "Я в третий процесс \ п"); INT NodeId = 3; // cmc_init (NodeId); test2 (NodeId); возвращать 0; } Если ((pid4 = вилка ()) <0) {Е ( "pid4 вилка ошибки \ п"); } Еще если (pid4 == 0) {Е ( "Я в четвертый процесс \ п"); INT NodeId = 4; // cmc_init (NodeId); // test2 (NodeId); возвращать 0; } Если (waitpid (-1, NULL, 0) <0) {Е ( "wait1 ошибка \ п"); } Сна (3); возвращать 0; } Comproc.c ЬурейеЙ структура Msg_context {INT NodeId; } Msg_context; недействительными test2 (интермедиат NodeId) {Int I = 1; для (я = 1; я } Если ((pid4 = вилка ()) <0) {Е ( "pid4 вилка ошибки \ п"); } Еще если (pid4 == 0) {Е ( "Я в четвертый процесс \ п"); INT NodeId = 4; // cmc_init (NodeId); // test2 (NodeId); возвращать 0; } Если (waitpid (-1, NULL, 0) <0) {Е ( "wait1 ошибка \ п"); } Сна (3); возвращать 0; } Comproc.c ЬурейеЙ структура Msg_context {INT NodeId; } Msg_context; недействительными test2 (интермедиат NodeId) {Int I = 1; для (я = 1; я } Если ((pid4 = вилка ()) <0) {Е ( "pid4 вилка ошибки \ п"); } Еще если (pid4 == 0) {Е ( "Я в четвертый процесс \ п"); INT NodeId = 4; // cmc_init (NodeId); // test2 (NodeId); возвращать 0; } Если (waitpid (-1, NULL, 0) <0) {Е ( "wait1 ошибка \ п"); } Сна (3); возвращать 0; } Comproc.c ЬурейеЙ структура Msg_context {INT NodeId; } Msg_context; недействительными test2 (интермедиат NodeId) {Int I = 1; для (я = 1; я
mHuster
1

голосов
1

ответ
38

Просмотры

Настройка планировщика или службы таймера в Либерти

Мы мигрируем наш код от WAS 8 до Liberty.In WAS 8 мы имеем конфигурацию, чтобы поместить обновленные политики в очередь сообщений между 3 до 8 с интервалом в 1 час. Мы пытались имитировать ту же конфигурацию, в Liberty. Может кто-нибудь, пожалуйста, помогите нам о том, как настроить этот
Venkatesh
1

голосов
1

ответ
173

Просмотры

Как назначить идентификатор MessageListenerContainer без использования @JmsListener

Я использую интеграции пружинных в моем приложении и используя @ServiceActivator, а затем @JmsListener. Мне нужно присвоить идентификатор MessageListenerContainer, так что я могу программно запускать и останавливать контейнер. Может кто-то помочь мне понять, как настроить идентификатор для messageListenerContainer.
1

голосов
1

ответ
150

Просмотры

Переместить отпечатанные уведомления выше заголовка страницы в WooCommerce отдельных страниц продукта

Я использую WooCommerce и мне нужно, чтобы переместить сообщения WooCommerce (самое главное все сообщения, которые отображаются на одной странице), чтобы ВЫШЕ заголовок страницы (моя тема использует название продукта в качестве заголовка страницы). Я знаю, что могу удалить одно сообщение с помощью add_filter ( «wc_add_to_cart_message», «remove_add_to_cart_message»); Функция remove_add_to_cart_message () {возвращение; } Но мне это нужно для всех сообщений монопродуктовых-страниц, и мне нужно, чтобы они были readded снова над заголовком страницы.
Lotus
1

голосов
0

ответ
24

Просмотры

Чтобы изменить «название» в модальном диалоге

У меня есть создать очень просто скрипт: вар HTML = HtmlService.createHtmlOutput; ( «шрифт желтый / Backround черный!») . SpreadsheetApp.getUi () ShowModalDialog (HTML, 'Мой Заголовок'); модифицировать «пользовательский интерфейс» это не проблема - но как я могу изменить «название»? например, я буду писать название «Мой Заголовок», как: «Мой Заголовок» (Word заголовок жирным шрифтом).
J. Doe
1

голосов
0

ответ
22

Просмотры

Щебетать подсчета длины сообщения

Это из щебета документа: https://developer.twitter.com/en/docs/basics/counting-characters.html «Twitter подсчитывает длину чирикать, используя версию Нормализации Form C (NFC) текста ... Twitter также подсчитывает количество кодовых в тексте, а не UTF-8 байт «. Он работает для западных языков. Но когда я применяю FormC нормализации к следующему, например: (я опубликовал пример на корейском языке, но StackOverflow считает это спам и не позволяет мне отправить его) я получаю значение 160. На веб-клиенте в Twitter, это Максимально доступное сообщение - добавление даже одного символа переходит предел. Применяя FormD к вышесказанному получаешь значение более 300. Так как предел Twitter либо 140 или 280, я действительно не понимаю, как счетчик гольца того сообщения определяется на Twitter. Так что - как в мире, я могу понять, что фактическая длина сообщения для незападных языков твит? Код для нормализации, в C #: частный статический Int GetCodepointLength (строка InP) {вар информация = новый StringInfo (inp.Normalize (NormalizationForm.FormC)); вернуться info.LengthInTextElements; }
MikeMedved
1

голосов
0

ответ
36

Просмотры

Как повысить скорость подключения к ActiveMQ HTTP транспорта

У меня есть брокера Apache ActiveMQ с HTTP transportConnector. Я пытаюсь подключить потребитель Java к нему. После того, как около 260 потребителей времени, чтобы установить соединение линейно возрастает. Процессор и память остается на низком уровне, так что я не понимаю, что происходит не так. ActiveMQ брокер версии 5.11.1 Java клиенты используют org.apache.activemq: ActiveMQ-клиента: 5.15.4 Транспорт настраивается следующим образом:
Kristof Neirynck
1

голосов
0

ответ
14

Просмотры

Как отображать пользовательское сообщение от models.py в Джанго

Мне нужно, чтобы отобразить пользовательское сообщение от models.py файла для администратора settings.How написать сообщение в моделях
Sujitha
1

голосов
0

ответ
86

Просмотры

React-Native Flash-Message with Mobx and React-navigation

I'm trying to use react-native-flash-message to provide little toasts in my app, and I am supposed to add the flash message to my root view. I cannot figure out where that is in my app. I used examples to get up and running with mobx/react-navigation/react-native, and so my app.js actually just exports an index.js that looks like this: import React from 'react'; import { createRootNavigator } from './router'; import { isSignedIn } from './auth'; import { Font, SplashScreen } from 'expo'; import { library } from '@fortawesome/fontawesome-svg-core'; import { faCheckSquare, faCoffee, faHome } from '@fortawesome/free-solid-svg-icons'; import { configure } from 'mobx'; import { Provider } from 'mobx-react'; import _ from 'lodash'; import { RootStore } from './stores/RootStore'; import { getDecoratedStores } from './stores/util/store-decorator'; import { AsyncStorage } from 'react-native'; import FlashMessage from "react-native-flash-message"; configure({ enforceActions: 'observed' }); const rootStore = new RootStore(); const stores = getDecoratedStores(rootStore); //Library of Icons library.add(faCheckSquare, faCoffee, faHome); export default class App extends React.Component< {}, { checkedSignIn: boolean; signedIn: boolean; loaded: boolean } > { constructor(props: any) { super(props); this.state = { signedIn: false, checkedSignIn: false, loaded: false, }; } componentWillMount() { this._loadFontsAsync(); } _loadFontsAsync = async () => { await Font.loadAsync({ robotoBold: require('../app/uiComponents/fonts/Roboto-Bold.ttf') }); await Font.loadAsync({ robotoRegular: require('../app/uiComponents/fonts/Roboto-Regular.ttf'), }); this.setState({ loaded: true }); }; componentDidMount() { isSignedIn() .then(res => { SplashScreen.hide(); this.setState({ signedIn: res as boolean, checkedSignIn: true }); }) .catch(err => {console.log(err); alert('Error')}); } render() { const { checkedSignIn, signedIn } = this.state; // If we haven't checked AsyncStorage yet, don't render anything (better ways to do this) if (!checkedSignIn) { return null; } AsyncStorage.getItem('auth-demo-key').then((data) => console.log("Async Storage: " + data)); const Layout = createRootNavigator(signedIn); return ( ); } } Can anyone help me figure out how to add my flash message in this return statement? I tried wrapping the provider in a view, but that failed and crashed my app, same with adding it within the provider (a view), also tried just adding flash message here in the provider, but that failed, too. Can anyone help?
shawleigh17
1

голосов
1

ответ
92

Просмотры

Как получить длину ROS MSG в Python?

У меня есть проблема, которую необходимо подсчитать длину каждого ROS тему сообща. Я изменил rostopic (/opt/ros/smart-ros/lib/python2.7/dist-packages/rostopic / __ init__.py): Класс CallbackEcho (объект) - нет> Защита обратного вызов (сам, данные, callback_args, CURRENT_TIME = None ): Print ( «длина сообщения =», sys.getsizeof (данные) длина) #statics тзд Но когда сообщение содержит вектор или структуры список, длина неверна. Пожалуйста, помогите решить эту проблему? Благодарю.
wei hu
1

голосов
3

ответ
3.9k

Просмотры

CDO.Message - to many connections

Я пишу приложение бюллетень с помощью CDO.Message. Но получить обратно ошибки, что мы должны много соединений. Кажется, у них есть ограничение на 10 одновременных подключений. Итак, есть ли способ, чтобы отправить несколько сообщений на одно соединение, или отсоединять быстрее? Существует CDO / конфигурация / параметр smtpconnectiontimeout, но я думаю, что это больше о том, как долго отправитель будет пытаться. (Если мы посылаем, муравей это не удается, то получится снова через несколько минут, вероятно, означает, что соединение отключено). (Мы используем CDO отчасти потому, что мы вытягивать тело HTML сообщение с веб-сервера) Edit: Public Sub ipSendMail (ByVal toEmail As String, ByVal fromEmail As String, при условии ByVal As String, ByVal URL As String) Dim IMSG As Object Set IMSG = CreateObject ( "CDO.Message") iMsg.From = fromEmail iMsg.To = toEmail IMSG.
Olav
1

голосов
2

ответ
344

Просмотры

архив SMS решения

Кто-нибудь знает, есть ли SMS решение архив там? Идея заключается в том, чтобы архивировать смс сообщение с телефона в центре города.
Herman
1

голосов
1

ответ
1.1k

Просмотры

Система I (ISeries, AS / 400) сообщения Опция очередей

Я пытаюсь найти варианты MQ о ISeries кроме WebSphere MQ. Кто-нибудь есть опыт работы с этим? Является ли это возможным? Могу ли я запустить чистый Java MQ сервер, как OpenMQ?
Matt Davis
1

голосов
4

ответ
2.7k

Просмотры

Smart quotes in a MimeMessage not showing up correctly in Outlook

Наше приложение берет текст с веб-форму и отправляет его по электронной почте соответствующему пользователю. Тем не менее, когда кто-то копировать / пасты в печально известных «умных кавычках» или других специальных символах из Слова, вещи получить волосатые. Типы пользователей в он сказал «привет» мне-разве это хорошо? Но когда в Outlook 2003 появляется сообщение, оно выходит так: он поздоровался с meisnt, что приятно? Код для этого был: сессия Session = Session.getInstance (реквизит, новый MailAuthenticator ()); сообщ Message = новый MimeMessage (сессия); // удалены настройки в / из адресов для упрощения msg.setSubject (при условии); msg.setText (текст); msg.setHeader ( "X-Mailer", MailSender.class.getName ()); msg.setSentDate (новая дата ()); Transport.send (MSG); После небольшого исследования, я понял, что это, вероятно, проблема кодировки символов и попытался переместить вещи UTF-8. Так, Я обновил код таким образом: сессии Session = Session.getInstance (реквизит, новый MailAuthenticator ()); MimeMessage MSG = новый MimeMessage (сессия); // удаляют, установив в / из адресов для упрощения msg.setHeader ( "X-Mailer", MailSender.class.getName ()); msg.addHeader ( "Content-Type", "текст / обычный"); msg.addHeader ( "кодировка", "UTF-8"); msg.setSentDate (новая дата ()); Transport.send (MSG); Это заставило меня ближе, но не сигара: он не сказал «hello» для MEA-isnÂ't, что хорошо? Я не могу себе представить, что это необычная проблема - то, что я пропустил?
abeger
1

голосов
3

ответ
3k

Просмотры

PostThreadMessage и PeekMessage проблема в Delphi 2006

Я создал multichilded приложения. Окна приложения (W [N]: TMyWindows) все же и у всех есть экземпляр класса частного объекта, связанный с ними (E: TMyObject). Дочерние окна генерируют через эти объекты некоторые сообщений. Я создал в главном приложении два потока, которые обрабатывают эти сообщения, в зависимости от содержания сообщения. Например, позволяет иметь следующие асинхронные вызовы: W [1] .E.Service (thread1service) Вт [2] .E.Service (thread2service) TMyObject.Service (ServiceType) является случай ServiceType из thread1service: PostThreadMessage (thread1id, .. .); thread2service: PostThreadMessage (thread2id, ...); конец; Теперь, в Execute Method каждого потока у меня есть что-то вроде этого: в то время как не прекращаются ли начать ... если PeekMessage (МСГ, 0, thread1message_1, thread1message_n, PM_REMOVE), то сообщение процесса делать другие вещи; конец Все идет хорошо, что кроме мазута второй поток не получает никаких сообщений. Есть ли у вас какие-либо идеи, почему?
zoomz
1

голосов
1

ответ
707

Просмотры

Создание очереди сообщений доставки в PHP

Я строю систему, которая будет посылать стихи Писания подписчикам по электронной почте. Абоненты смогут: Определить, какой объем Писания они хотят получить стихи из Определить суточную частоту сообщений и сколько стихов будут включены в каждое сообщение Определите, в какое время они хотят получать сообщения Следите за их прогрессом (так что они могут читать книги в течение определенного периода времени) я действительно трудное время оборачивать вокруг моей головы модели данных для этой задачи. В частности, я борюсь с тем, как я буду идти о создании и отправке сообщений им. До сих пор я придумал подписную таблицу, которая будет описывать предпочтения пользователя для содержания, частоты и количества содержания поставленного за сообщение, но я не» знаю точно, как модель хранения раз они хотят это содержимое. Я думаю, хроны будет работать каждый час, который будет генерировать сообщения, которые должны быть отправлены и поместить их в таблице message_queue. Другой хрон будет работать и записывать через таблицу message_queue и отправлять сообщения, когда придет время. Любые идеи о том, как я могу более эффективно моделировать и строить эту систему? Вот моя текущая модель данных: Модель данных http://www.kirkouimet.com/files/images/sendmescripture.gif
Kirk Ouimet
1

голосов
1

ответ
486

Просмотры

Что лучший способ массового обслуживания чувствительных ко времени сообщений с PHP / MySQL?

Я построение SMS-вызов и реагирование в новом приложении, которое получает сообщение через шлюз агрегатора, проверяет его функциональные ключевые слова (запускать, останавливать, спрашивать и т.д.), а затем обрабатывает их соответствующим образом (сохранить в базу данных, возвращать ответ, или выполнить задачу на основе авторизации пользователей). Это отлично работает на данный момент, поскольку есть только несколько пользователей, но я полагаю, его будет иметь больше проблем, как масштабировать его. Мы в настоящее время работает его на одной машине (DV Mediatemple база DV). Мой вопрос заключается в следующем: он делает больше смысла, чтобы установить что-то вроде Memcached для запуска очереди, или простую базы данных с демоном управлением для обработки каждого сообщения по одному? У меня нет большого опыта работы ни с одним, так что любой совет будет полезным. Поскольку обмен сообщения несколько раз чувствительны к регистру, что будет самый быстрый и самый надежный способ справиться с этим? Кроме того, поскольку мы посылаем ответ, я, вероятно, нужно настроить и очереди исходящих сообщений, а также. Имеет ли смысл использовать ту же концепцию для обоих?
Andy T
1

голосов
2

ответ
225

Просмотры

Как построить очередь терабайт?

Как создать / дизайн / программа терабайт или очередь петабайт в памяти? (Представьте себе твиттер, как сервис с огромным количеством пользователей.)
user319280
1

голосов
1

ответ
764

Просмотры

MSMQ - Message Queue Abstraction and Pattern

Позвольте мне определить проблему первого и почему была выбрана MessageQueue. У меня есть datalayer, который будет транзакционной и КРАЙНЕ вставки тяжелы и, а не пытаться справиться с этими проблемами, когда они происходят, я надеюсь реализовать мое приложение с нуля, с учетом этого. Я решил решить эту проблему с помощью Message Queue Microsoft и выполнять вставки, как время позволяет асинхронно. Однако я быстро столкнулся с проблемой. Некоторые вставки, которые я выполняю, возможно, придется напомнить (т.е. извлечены) немедленно (представьте это для системы POS и что произойдет, если вам нужно вспомнить последнюю сделку - тот, который до сих пор не установлена). Так я решил решить эту проблему является абстрагирование MessageQueue и комбинируя его в моем слое доступа к данным, тем самым создавая иллюзию единого набора данных, возвращаемых пользователю в datalayer (я рассмотрел другие вопросы, которые возникают в таких сценарий (т.е. по существу грязного чтения и такое), и пришли к выводу, для моих целей я могу контролировать эти вопросы). Однако это, где все становится немного противно ... Я работал, как получить сообщения обратно и такой (тривиальная достаточно проблемы), но где я застрял есть; как я создаю общий (или, по крайней мере, несколько общих) способа запросов моей очереди сообщений? Один, где я могу свести к минимуму дублирования между запросами SQL и MessageQueue запросами. Я рассматривал возможность использования LINQ (но имею очень ограниченное понимание технологии) и также предпринял попытку реализации предикатов, которая до сих пор является довольно вонючей. Существуют ли какие-либо шаблоны для такой проблемы, что я могу использовать? Собираюсь ли я об этом не так? Есть ли у кого-либо из своих собственных представлений о том, как я могу решить эту проблему? Кто-нибудь даже понять, что я имею в виду? :-) Любые и все входные будут высоко оценены и серьезно рассматривать ... Еще раз спасибо. Для тех, кто заинтересован. Я решил в конце концов просто кэшировать сделку в другом месте и использовать MSMQ по назначению и описано ниже. Существуют ли какие-либо шаблоны для такой проблемы, что я могу использовать? Собираюсь ли я об этом не так? Есть ли у кого-либо из своих собственных представлений о том, как я могу решить эту проблему? Кто-нибудь даже понять, что я имею в виду? :-) Любые и все входные будут высоко оценены и серьезно рассматривать ... Еще раз спасибо. Для тех, кто заинтересован. Я решил в конце концов просто кэшировать сделку в другом месте и использовать MSMQ по назначению и описано ниже. Существуют ли какие-либо шаблоны для такой проблемы, что я могу использовать? Собираюсь ли я об этом не так? Есть ли у кого-либо из своих собственных представлений о том, как я могу решить эту проблему? Кто-нибудь даже понять, что я имею в виду? :-) Любые и все входные будут высоко оценены и серьезно рассматривать ... Еще раз спасибо. Для тех, кто заинтересован. Я решил в конце концов просто кэшировать сделку в другом месте и использовать MSMQ по назначению и описано ниже.
1

голосов
1

ответ
1.9k

Просмотры

уведомляющие приложения на дб INSERT

Рассмотрим приложение с двумя компонентами, возможно, работает на разных машинах: Производитель - Вставляет записи в базу данных, но мало делает, чтобы не читать из базы данных. Несколько экземпляров могут быть запущены одновременно. Потребитель - должен быть уведомлен, когда запись вставляется в базу данных экземпляра компонента А. Может также иметь несколько экземпляров. Что является лучшим способом для выполнения уведомления, если предположить, что производители будут вставлять 10-100 записи в базу данных в секунду в часы пик? Технология баз данных в настоящее время MySQL, но это не обязательно высечено в камне. Я могу видеть несколько различных способов: использовать что-то вроде очереди сообщений MySQL на «PUSH» уведомлений INSERT для абонентов (потребителей). Производители не имели бы никакого знания, что это происходило. Наличие производители взаимодействуют с промежуточным слоем, который выполняет вставки и толкает уведомления в очередь сообщений, что потребители подписаны. У потребителей опрашивать базу данных часто проверять наличие новых дополнений (кажется плохой идеей) и т.д. Что касается сочетания касается: Это хорошая идея, чтобы иметь два относительно отдельных компонентов приложения выполняют прямые запросы на общей базе данных, или должен один компонент «собственные» базы данных в то время как другой компонент косвенно взаимодействует с БД через вызовы к компоненту имущего?
Josh Johnson
1

голосов
1

ответ
2.8k

Просмотры

Oracle Forms - Отображение блоки сообщений Остальная часть коды или сообщений не отображается

Я пытаюсь показать сообщение на форме без успеха. То, что я делаю это: Когда новая линия щелкнул, я использую КОГДА-NEW-RECORD-INSTANCE сделать некоторые проверки и некоторые включения / выключения по форме и появляется сообщение. Проблема в том, иногда это делает включение / отключение, но не сообщение, то я нажимаю другую линию, и она показывает предыдущее сообщение, но не делает включение / отключение ... Я уже пробовал некоторые вещи, как: сообщение (» сообщение'); п: = Show_alert ( 'сообщение'); с и без Синхронизировать; Я не думаю, что это сам код блокировки сообщений ... или я что-то отсутствует ... Кто-нибудь когда-нибудь была такая проблема? Может кто-нибудь сказать мне различные варианты для отображения сообщений и их различия? Благодарю.
user295744
1

голосов
1

ответ
578

Просмотры

Получив сообщение из очереди сообщений POSIX

Я должен написать приложение C в Unix, например, что N дети процессы будут раздвоенный от родительского процесса, и я буду отправлять сообщения этим детям и детям, как предполагается отправлять сообщения друг другу. Однако проблема, мне нужно, чтобы отправлять сообщения определенного процесса целевого ребенка. т.е. родитель будет отправить ребенок 1 ребенок 1 пошлет к ребенку 2, ... и ребенку п будет отправить 1 (циркулярно). Проблема заключается в том, если я создаю только одну очереди сообщений, любой из русских детей могут из очереди сообщений (поскольку любые из них может работать после родительского процесса из ядра планировщика), поэтому сообщение будет удалены из очереди в неправильном процессе! В моем приложении, будет макс. 1 сообщение в очереди в то время. Единственное решение приходит в мой ум, чтобы создать п различных очередей сообщений и передавать сообщения в соответствующую очередь с тем, что конкретный целевой процесс может получить его. Но я думаю, что должен мне более законное решение. Есть идеи? Контрсилы: Трубы между процессами не допускаются, я знаю, что MQ неэффективна здесь. Я также осуществлять их, как требуется. PS Это своего рода домашнее задание (блин я являюсь создателем http://canyoudomyhomework.com), однако это не просто домашнее задание, сложный вопрос, ИМХО.)
AhmetB - Google
1

голосов
1

ответ
809

Просмотры

Выбор очереди сообщений?

Мы используем SysV Message Queue для нашей распределенной системы обработки данных в течение более 15 лет. По какой-то причине, мы хотим заменить его новой механизм очереди сообщений. Есть ли какие-нибудь предложения? Требования: Быстрая реакция, сводя к минимуму системы очередей сообщений накладных расходам множественного языка клиента библиотекой поддержки, в основном, с, с # и Java Можно сделать некоторые конфигурации HA для предотвращения SPOF Have регистрации возможности проверить, кто отправляет сообщение и кто получает сообщение, я нашел Apache ActiveMQ и RabbitMQ , но мне кажется, RabbitMQ не хватает стабильной поддержки клиентской библиотеки C?
dhchen
1

голосов
3

ответ
249

Просмотры

ответно проверки две очереди без привязки CPU

У меня есть система пула потоков, который использует передачу сообщений для организации мероприятий, и я также использую Windows API, который также делает немного передачи сообщений. Таким образом, по существу, мне нужно использовать функции, которые проверяют на наличие сообщений без блокировки. Если заблокировать (если я использую GetMessage Я думаю, что он будет блокировать) во время проверки либо очереди, я могу пропустить входящие сообщения на другой очереди. Первое решение, которое я знаю, это спать пару милисекунд где-то во время моей петли выглядывала на оба очередях. Другой способ, которым я могу думать о том, чтобы иметь дополнительный поток, так что теперь у меня есть для каждого цикла я слушать. Я делаю это не несет ответственность за то, ничего, кроме запуска цикла окна сообщений, а затем использовать его для обработки и пересылки событий в мою собственную очередь сообщений для событий, которые будут обрабатываться. Но это выиграл» т работать, если Windows, в частности, отправляет сообщения, я заинтересован в к оригинальной теме. Есть ли другие хорошие решения?
Steven Lu
1

голосов
1

ответ
226

Просмотры

Какие MDB прослушивает очередь

Как я могу сказать, какой MDB прослушивает определенную очередь, имя очереди по? Спасибо.
Sergiu
1

голосов
1

ответ
524

Просмотры

Сообщения Джанго которые будут отображаться только при следующем запросе

У меня есть приложение Django, и я использую сообщения для того, чтобы показать некоторые ограничения, которые проходят пользователь. Моя проблема заключается в том, что все мои сообщения отображаются после второго запроса. Я имею в виду, после добавления сообщения и собирается на страницу, где должно быть демонстрировался сообщение, я не вижу, но я начинаю видеть его после обновления. Что я делаю неправильно?
alexarsh
1

голосов
1

ответ
740

Просмотры

Порядок NServicebus и Message Handler

Я сожалею, что было неясно. На самом деле нет никаких зависимостей между обработчиками, некоторые из них просто обрабатывать один и тот же тип сообщения. Например, в нашей системе мы обработки счетов-фактур, очень упрощено это происходит, когда счет-фактура поступает в систему: сообщение «InvoiceArrived» отправляется на nservicebus и должны произойти две вещи, информация о счете-фактуре должны быть направлены на внешнюю систему и электронная почта должна быть отправлена ​​к лицу, который должен обрабатывать счета-фактуры (другого человека, в зависимости от информации о счете-фактуре). Эти две вещи не имеет зависимость от друг друга, но экспорт внешней системы очень важно, в то время как электронная почта не так важно. Что случилось, что обработчик отправки электронной почты был запущен первый и crached (из-за плохой конфигурации), он был повторен пять раз, но каждый раз, когда crached и ни электронная почта, ни экспорт внешней системы имела место. Крепление конфигурации было легко, но он показал нам изъян в нашем проекте. Я reallize теперь, что мы должны пересмотреть конструкцию, потому что определяя порядок, в котором обработчики запуска ничего не будет решать, как и обратная ситуация также не желательно, чтобы он запускает обработчик ехпортируя первым, а затем craches в обработчике отправки по электронной почте, в результате чего пять повторы и пять успешных экспорта (но не успешной электронной почты). Я думаю, мы должны послать один тип сообщения для каждого обработчика ... Исходное сообщение: Мы используем NServiceBus создать обработчик для целого ряда событий, каждый посылающим уникальный типа сообщений на шину (в настоящее время 6, но их число растет ). Некоторые из этих событий (2 в данный момент) имеют более чем один обработчик, и мы хотим, чтобы они были выполнены в определенном порядке для каждого из типов сообщений. У нас есть собственный хозяин, и я знаю, что вы можете указать порядок, как: (.. First.Then () AndThen () AndThen () // и т.д.) NServiceBus.Configure.With () ... .UnicastBus () .LoadMessageHandlers Lets что у нас есть обработчики сообщений H1_1, H1_2 (обе обработки сообщений типа 1, H1_1 будет выполняться до H1_2) соответственно H2_1, H2_2 (обработки сообщений типа 2) и Н3 - Н6 (только те, для обработки сообщений типа 3 - 6 ) конечно, мы можем управлять, указав все обработчики .LoadMessageHandlers (First.Then (). Тогда () // и т.д.), но это означает, что каждый раз, когда мы добавляем новый обработчик, мы должны добавить к этой конфигурации, можно ли написать .LoadMessageHandlers (Первый. Тогда ()) // и все остальные обработчики запускаются там после? Это было бы, конечно, лучше, но все равно, H1_1 и H2_1 не имеет никакого отношения друг с другом, чтобы сделать и не будет работать на том же сообщении каким-либо образом. Нет ли способ указать на тип сообщения, т.е. для 1-го типа First.Then () и 2-го типа First.Then () и для всех остальных типов нет спецификации не является необходимой, так как есть только один обработчик? Большое спасибо заранее - любая помощь будет принята с благодарностью! Тогда () и для всех остальных типов нет спецификации не является необходимой, так как есть только один обработчик? Большое спасибо заранее - любая помощь будет принята с благодарностью! Тогда () и для всех остальных типов нет спецификации не является необходимой, так как есть только один обработчик? Большое спасибо заранее - любая помощь будет принята с благодарностью!
Christian
1

голосов
1

ответ
232

Просмотры

@ Ресурс-аннотации в MessageDrivenBeans абстрактного родительского класса?

это нормально @MessageDriven (...) общественный класс EventMDB реализует MessageListener {@Resource частный контекст MessageDrivenContext; // OnMessage (Message) ... но он также работает, если я ставлю пометку ресурсов в абстрактном родительском классе? @MessageDriven (...) общественный класс EventMDB простираться ParentMDB {// OnEvent (событие) ... с открытым абстрактным классом ParentMDB реализует MessageListener {@Resource защищенного MessageDrivenContext контекст; // OnMessage (Message) возвращает объект из ObjectMessage и вызывает OnEvent (событие) // абстрактные аннулируются OnEvent (Event) ...
user600148
1

голосов
2

ответ
6.7k

Просмотры

S / MIME проверки с сертификатом x509

У меня есть некоторые проблемы с проверкой S / Mime подписали сообщение с сертификатом x509. Это мой код: общественный класс verifyMsg {частная статическая силы проверить (SMIMESignedParser s) бросает исключение {Security.addProvider (новый BouncyCastleProvider ()); System.out.println ( "wbilem"); CertStore CERTS = s.getCertificatesAndCRLs ( "Коллекция", "БК"); SignerInformationStore подписанты = s.getSignerInfos (); Коллекция с = signers.getSigners (); Итератор она = c.iterator (); в то время как (it.hasNext ()) {Файл F = новый файл ( "signature.crt"); FileInputStream Fis = новый FileInputStream (е); DataInputStream дис = новый DataInputStream (ФИС); байт [] keyBytes = новый байт [(целое) f.length ()]; dis.readFully (keyBytes); dis.close (); fis.close (); SignerInformation подписывающий = (SignerInformation) it.next (); Коллекция certCollection = certs.getCertificates (signer.getSID ()); Итератор certIt = certCollection.iterator (); FileInputStream пт = новый FileInputStream ( "signature.crt"); CertificateFactory ср = CertificateFactory.getInstance ( "Х509"); X509Certificate серт = (X509Certificate) cf.generateCertificate (FR); если (signer.verify (серто, "BC")) {// Проблемы есть ... System.out.println ( "подпись проверяется"); } Еще {System.out.println ( "подпись не удалось!"); }}} Государственной статической силы основных (String [] агдз) бросает исключение {Свойства реквизита = System.getProperties (); Сессия Session = Session.getDefaultInstance (реквизит, нуль); попробуйте {FileInputStream пт = новый FileInputStream ( "signature.crt"); CertificateFactory ср = CertificateFactory.getInstance ( "Х509"); X509Certificate с = (X509Certificate) cf.generateCertificate (FR); System.out.println ( «Читайте в следующем свидетельстве:»); System.out.println ( "\ tCertificate для:" + c.getSubjectDN ()); System.out.println ( "\ tCertificate выдан:" + c.getIssuerDN ()); System.out.println ( "сертификат \ Лобовое действует с" + c.getNotBefore () + "к" + c.getNotAfter ()); System.out.println ( "\ tCertificate SN #" + c.getSerialNumber ()); System.out.println ( "\ tGenerated с" + c.getSigAlgName ()); System.out.println (c.getPublicKey ()); } Задвижка (Исключение е) {e.printStackTrace (); } {Попробуйте MimeMessage тзд = новый MimeMessage (сеанс, новый SharedFileInputStream ( "G: \\ MIME.txt")); если (msg.isMimeType ( "многочастному / подпись")) {SMIMESignedParser S = новый SMIMESignedParser ((MimeMultipart) msg.getContent ()); System.out.println ( "Status:"); проверить (с); } Иначе, если (msg.isMimeType ( «приложение / PKCS7-мим»)) {// в этом случае содержание заворачивают в блоке подписи. // SMIMESignedParser S = новый SMIMESignedParser (MSG); System.out.println ( "STATUS1:"); проверить (с); } Еще {System.err.println ( "Не подписанное сообщение!"); }} Поймать (MessagingException е) {// TODO автоматической генерации улов блок e.printStackTrace (); } Поймать (IOException е) {// TODO автоматической генерации улов блок e.printStackTrace (); } Задвижка (CMSException е) {// TODO автоматической генерации улов блок e.printStackTrace (); }}} И у меня есть проблемы с этим исключением: CMSSignerDigestMismatchException: сообщение-дайджест значения атрибута не соответствует расчетной стоимости. Я не знаю, что я делаю неправильно. Я использую JDK 1.4.2. CMSSignerDigestMismatchException: сообщение-дайджест значение атрибута не соответствует расчетной стоимости. Я не знаю, что я делаю неправильно. Я использую JDK 1.4.2. CMSSignerDigestMismatchException: сообщение-дайджест значение атрибута не соответствует расчетной стоимости. Я не знаю, что я делаю неправильно. Я использую JDK 1.4.2.
s7474
1

голосов
1

ответ
1.3k

Просмотры

JMS and MessageDriven EJB Bean

У меня есть проблема с управляемым сообщениями EJB. У меня тоже приложений веб-служб и приложений EJB, который содержит MessageDrivenBean. Для того, чтобы отправить сообщение JMS Я использую ObjectMessage: Вот мой код: соединение Connection = connectionFactory.createConnection (); Сессия Сессия = connection.createSession (ложь, 1); MessageProducer messageProducer = session.createProducer (очереди); ObjectMessage outMessage = session.createObjectMessage (); outMessage.setObject (((Сериализуемый) операции)); LOGGER.debug ( "Отправка сообщения ..."); messageProducer.send (outMessage); LOGGER.debug ( "Отправка сообщения: сделано."); messageProducer.close (); session.close (); connection.close (); Когда я называю веб-службы Я зову этот метод хорошо. В arives сообщения в MDB и начинает процесс. Вот мой MDB код: @MessageDriven (mappedName = "JMS / cbsDestination", activationConfig = {@ActivationConfigProperty (ИмениСвойства = "acknowledgeMode", PropertyValue = "Auto подтверждени"), @ActivationConfigProperty (ИмениСвойства = "DestinationType", PropertyValue = " javax.jms.Queue ")}) общественного класса OperationsBackgroundService реализует MessageListener {// Некоторый код .... общественности недействительным OnMessage (сообщение Message) {LOGGER.debug (" Got сообщение: "+ message.toString ()); если (сообщение InstanceOf ObjectMessage) {ObjectMessage objectMessage = (ObjectMessage) сообщение; операция Операция = NULL; } Это все хорошо, я получаю сообщение, он начинает обрабатывать и заканчивается, как я ожидал. Но проблема: Когда я отправить первое сообщение MDB начинается процесс его (OK), а затем, когда первое сообщение обрабатывает я отправляю второе сообщение на мой MDB, и он начинает обрабатывает его, а также. Ass Я знаю, что JMS характеризуется тем, что, если я отправить одно сообщение и один обрабатывает другие сообщения ожидает, пока первый обрабатывается. Или я что-то пропустил? Пожалуйста помоги. Может быть, есть некоторые свойства, которые я забыл установить? Благодаря идентификатор заранее. Может быть, есть некоторые свойства, которые я забыл установить? Благодаря идентификатор заранее. Может быть, есть некоторые свойства, которые я забыл установить? Благодаря идентификатор заранее.
Paulius Matulionis
1

голосов
1

ответ
1.5k

Просмотры

Error when using Message class as return type in WCF service

Я имею службы WCF. Услуга настолько, что она возвращает результат в виде строки. При запуске приложения, я получаю сообщение об ошибке. Операция «GetTemplate» не может быть загружен, потому что он имеет параметр или тип возвращаемого типа System.ServiceModel.Channels.Message или такого типа, который имеет MessageContractAttribute и другие параметры различных типов. При использовании System.ServiceModel.Channels.Message или типов с MessageContractAttribute, метод не должен использовать любые другие типы параметров. Мой соответствующий код выглядит так: Интерфейс: - [OperationContract] [WebGet (ResponseFormat = WebMessageFormat.Json, Bodystyle = WebMessageBodyStyle.Wrapped, UriTemplate = "GetTemplate / templateid = {templateID}")] Message GetTemplate (строка templateID); Реализация: - общественное сообщение GetTemplate (строка templateID) {строка jsonText = TemplateManager.GetJSONTemplate (templateID); вернуть WebOperationContext.Current.CreateTextResponse (jsonText, "Применение / JSON; кодировка = UTF-8", Encoding.UTF8); } Когда я гугл т я должен знать, что мы не можем использовать любой сериализуемый объект в качестве параметра или типа возвращаемого значения при использовании Message. Я хочу, чтобы принять templateid в качестве параметра, чтобы получить соответствующий шаблон. Есть ли способ, чтобы принять параметр без иметь эту ошибку? Заранее спасибо. Vipin Менон } Когда я гугл т я должен знать, что мы не можем использовать любой сериализуемый объект в качестве параметра или типа возвращаемого значения при использовании Message. Я хочу, чтобы принять templateid в качестве параметра, чтобы получить соответствующий шаблон. Есть ли способ, чтобы принять параметр без иметь эту ошибку? Заранее спасибо. Vipin Менон } Когда я гугл т я должен знать, что мы не можем использовать любой сериализуемый объект в качестве параметра или типа возвращаемого значения при использовании Message. Я хочу, чтобы принять templateid в качестве параметра, чтобы получить соответствующий шаблон. Есть ли способ, чтобы принять параметр без иметь эту ошибку? Заранее спасибо. Vipin Менон
Vipin Menon T P
1

голосов
1

ответ
553

Просмотры

MySQL на уровне строк прочитать замок, чтобы заменить очереди сообщений

У меня есть MySQL таблица, в которой я храню рабочие места, подлежащую обработке. в основном текстовые поля сырых данных, которые будут принимать около минуты каждый обрабатывать. У меня есть 2 сервера тянущих данных из этой таблицы обработки она затем удаления. Для того, чтобы управлять распределением заданий между 2 серверами я в настоящее время с помощью амазонки SQS. Я храню все строки IDS, которые требуют обработки в SQS, серверы рабочих опрос SQS, чтобы получить новые строки для работы. В настоящее время система работает, но SQS добавляет уровень сложности и затраты, которые я чувствую, являются излишеством, чтобы добиться того, что я делаю. Я пытаюсь реализовать то же самое без SQS и было интересно, есть ли способ чтения заблокировать строку, так что если один работник работает на одной строке, ни один другой работник не может выбрать эту строку. Или есть ли лучший способ сделать это.
applechief
1

голосов
1

ответ
640

Просмотры

MD5sum is not calculated correctly

Я пытаюсь соответствовать md5sum загруженного файла с сервера. Обработка будет продолжена только в случае совпадения сумм. попробовать {MessageDigest дайджеста = MessageDigest.getInstance ( "MD5"); Файл F = новый файл (имя_файла); InputStream это = новый FileInputStream (е); байт [] буфера = новый байт [8192]; ИНТ чтения = 0; в то время как ((чтение = is.read (буфер))> 0) {digest.update (буфер, 0, чтение); } закрыто(); байт [] md5sum = digest.digest (); BigInteger BigInt = новый BigInteger (1, md5sum); Выход = bigInt.toString (16); System.out.println ( "MD5:" + выход); } Поймать (IOException е) {певд RuntimeException ( "Не удалось обработать файл MD5", е); } Задвижка (NoSuchAlgorithmException е) {e.printStackTrace (); } Приведенный выше код Безразлично» т обеспечить md5sum правильно для некоторых файлов каждый раз. Когда я иду в консоль и проверить md5sum md5sum такое же, как и в сервере. Но когда же вычисляется из кода он приносит другой результат. vimdiff загруженного файла не предоставляет каких-либо различий .. Файлы собственно после загрузки. Я не могу видеть проблему в коде выше. Я пытаюсь изменить размер буфера. Но не повезло, так я не буду гадать, что это не из-за размера буфера и т.д. байт [] буфера = новый байт [8192]; Привет Dheeraj Joshi Я пытаюсь изменить размер буфера. Но не повезло, так я не буду гадать, что это не из-за размера буфера и т.д. байт [] буфера = новый байт [8192]; Привет Dheeraj Joshi Я пытаюсь изменить размер буфера. Но не повезло, так я не буду гадать, что это не из-за размера буфера и т.д. байт [] буфера = новый байт [8192]; Привет Dheeraj Joshi
Dheeraj Joshi
1

голосов
1

ответ
1.2k

Просмотры

OCS SQL-запрос, чтобы получить мгновенные сообщения для конкретных пользователей

Я хочу, чтобы вывести все сообщения IM от OCS базы данных (LcsLogs), для самых различных пользователей. Я хочу, чтобы все сообщения, они отправляют или получают. У меня есть что-то вроде следующего в данный момент: SELECT * FROM dbo.Messages где Messages.FromId = '111' или Messages.ToId = '111' или Messages.FromId = '222' или Messages.ToId = '222' или сообщения .FromId = «333» или Messages.ToId = «333» Я также хочу, чтобы Absolutley, что я ищу все правильные таблицы и т.д., и быть новым для LcsLogs баз данных, я до сих пор не уверен, что если мой основной запрос comprehensiev достаточно , Я видел следующий запрос в Интернете: SELECT * FROM dbo.Messages, dbo.Users где dbo.Users.UserId = Messages.FromId Но я получил довольно много дублирования сообщений, используя этот запрос, и не был уверен, почему мы запрашивая " ПСЭ.
greatodensraven

Просмотр дополнительных вопросов