Вопросы по теме 'eventmachine'
Отправка хэша с помощью eventmachine
Я хочу отправить хэш, заполненный данными, от клиента EventMachine на сервер. Проблема в том, что серверный метод receive_date просто печатает строку.
Сервер:
def receive_data(data)
send_data("Ready")
puts data[:total]
end...
482 просмотров
schedule
05.03.2022
Один вопрос с EventMachine
require 'eventmachine'
module EchoServer
def post_init
puts "-- someone connected to the echo server!"
end
def receive_data data
send_data ">>>you sent: #{data}"
close_connection if data =~ /quit/i
end...
331 просмотров
schedule
24.05.2023
AJAX и Rails: два стека или один?
Большая часть веб-приложения представляет собой довольно стандартный CRUD. Мне нужно, чтобы некоторые данные передавались клиентам в режиме реального времени по мере их создания. Стоит ли запускать отдельный, более легкий стек (например, Sinatra или...
126 просмотров
schedule
24.01.2024
Почему EventMachine намного медленнее, чем Node?
По крайней мере, в моем конкретном случае. Не пытаюсь делать здесь общие заявления.
У меня есть поисковый робот, который я написал на Node.js. Вместо этого я хотел бы использовать Ruby, поэтому я переписал его в EventMachine. Поскольку оригинал...
1728 просмотров
schedule
30.05.2023
Проблема Async Rails 3.1 с активами
У меня проблема с активами в асинхронном приложении rails 3.1, мне удалось создать минимальный пример, показывающий мою проблему, но это мне мало помогло.
Приложение очень простое, что я сделал: - создал новое приложение с 3.1 (не rc) - добавил...
635 просмотров
schedule
10.05.2022
Ruby EventMachine – как вернуть значения из EM::Deferrable в основной цикл EM?
Я играю с EventMachine уже несколько дней, у которого ИМХО крутая кривая обучения ;-) Я пытаюсь вернуть хэш, вызывая HttpHeaderCrawler.query(), который мне нужен в обратном вызове. Но в этом случае я получаю не хэш {'http_status' => xxx,...
2379 просмотров
schedule
14.07.2022
Потоковая передача HTTP с помощью Thin & EventMachine
Я играю с EM, чтобы добиться потоковой передачи и параллелизма. У меня возникла проблема с потоковой передачей... Я запускаю следующее стоечное приложение https://gist.github.com/1394840 используя
$ rackup -s thin -p 3000 async_app.ru
Во...
689 просмотров
schedule
19.06.2022
Потоковое приложение Sinatra + em::periodic таймер при запуске
Мне нужно создать потоковое веб-приложение с Sinatra, я пытаюсь использовать один «источник» потоковой передачи, когда у меня открыто несколько подключений, как лучше всего это сделать?
Я не могу проверить до нескольких дней, но моя основная идея...
1253 просмотров
schedule
19.02.2023
Шаблон запрос-ответ не работает с em-zeromq
Я пытаюсь реализовать шаблон запрос-ответ с помощью драгоценного камня em-zeromq, но я не могу заставить сокет ответа отправить сообщение обратно в сокет запроса в его обработчике. Я написал очень простой код, чтобы проверить это:
em_req.rb...
548 просмотров
schedule
04.11.2022
Использование Eventmachine для записи в базу данных, а затем использование Rails для ее чтения и отображения
Я написал сценарий сервера Eventmachine, который будет получать данные о местоположении от удаленного GPS-трекера. Теперь я хотел бы спросить следующее: 1) Как записать данные о местоположении в базу данных MySQL, скажем, по имени Position, используя...
364 просмотров
schedule
27.07.2023
Ruby Eventmachine и HTTP-запросы через прокси
Я кодирую высокомасштабируемый веб-комбайн, работающий поверх Eventmachine. Все работает отлично и быстро. Недавно я пытаюсь запускать запросы через кучу прокси-серверов, которые также отлично работают, например:
EventMachine.run do...
326 просмотров
schedule
31.08.2022
Как получить доступ к веб-сокетам машины событий через Thin/nginx?
У меня есть приложение websocket для обработки событий (использующее гем em-websocket ), и оно работает нормально. Проблема в том, что мне нужно развернуть его, используя порт 80 через nginx (не могу скомпилировать его с прокси-модулем tcp). Можно...
1061 просмотров
schedule
07.10.2022
Тестирование EventMachine с огурцом
Я пытаюсь написать функцию огурца и тесты rspec для своего приложения для доступа к потоковому API твиттера с помощью твиттер-потока. У меня есть следующий код:
Then /^I should see the latest (\d+) tweets from my timeline$/ do |num|
timeline =...
313 просмотров
schedule
10.03.2022
Приложение Rails и Goliath API и совместное использование базы данных/моделей
Я пытаюсь создать асинхронный API с платформой Goliath. Сервис должен писать в mysql, добавлять сообщения в RabbitMQ и получать ответы обратно. Также должно быть отдельное приложение администратора, созданное с помощью Rails. У меня есть несколько...
1362 просмотров
schedule
04.10.2022
EventMachine и зацикливание
Вот мой код:
EventMachine.run {
conn = EM::Protocols::HttpClient2.connect request.host, 80
req = conn.get(request.query)
req.callback { |response|
p(response.status)
p(response.headers)
p(response.content)
}
}...
2121 просмотров
schedule
17.03.2023
Как мне справиться с этим вариантом использования с помощью EventMachine?
У меня есть приложение, которое реагирует на сообщения, отправленные клиентами. Одно сообщение — reload_credentials , которое приложение получает каждый раз, когда регистрируется новый клиент. Затем это сообщение подключается к базе данных...
481 просмотров
schedule
13.08.2022
Использование таблицы с помощью EventMachine
У меня есть модель Resend в моем проекте Ruby, она содержит столбцы контента и статуса.
Каков наилучший/быстрый способ использовать все записи со статусом 0 с помощью EventMachine?
Я хочу создать простого работника, который пытается найти...
72 просмотров
schedule
17.09.2022
как реализовать бесконечный цикл в eventmachine
Мне нужен бесконечный цикл поверх eventmachine, который постоянно читает очередь redis. ниже мой код. рекурсия - правильный способ сделать это? Я пробовал loop do цикл, но не смог заставить его работать таким образом.
require 'em-hiredis'...
508 просмотров
schedule
23.02.2022
Цепочка отложенных обратных вызовов EventMachine
У меня есть некоторые Deferrables, и мне нужно что-то сделать в обратном вызове, когда все они будут завершены.
defers[0].callback do
defers[1].callback do
defers[2].callback do
yield if block_given?
end
end...
608 просмотров
schedule
17.07.2023
Надежная синхронизация с периодическими таймерами EventMachine
Моя цель — иметь систему, которая транслирует рекламу каждые 10 минут в 37 500 городов. Выполнение запросов к БД, расчетов и AMQP IO для всех городов занимает около 5 минут.
Код примерно структурирован так:
EventMachine.add_periodic_timer(10...
1440 просмотров
schedule
04.12.2022
