Вы искали git - Страница 5 из 12

RabbitMQ: отложенные сообщения

12.05.2022 Павел Грибов PHP

Задача: организовать доставку сообщения «слушателю» спустя какое-то время, а не сразу

Решение: одним из способов реализации является использование модуля rabbitmq-delayed-message-exchange.

Установка для Ubuntu:

Скачать подходящую версию модуля для версии вашего RabbitMQ в формате *.ez
Положить его в папку (в моём случае) /usr/lib/rabbitmq/lib/rabbitmq_server-3.8.9/plugins
Включить плагин

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

1	rabbitmq-plugins enable rabbitmq_delayed_message_exchange

Использование:

Пример постановки в очередь:



define('WUO_ROOT', dirname(__FILE__));

require_once WUO_ROOT.'/../vendor/autoload.php';
// загружаем классы
spl_autoload_register(function ($class_name) {
    require_once WUO_ROOT.'/../class/'.$class_name.'.php';
});

//Необходимые классы
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Wire\AMQPTable;

//Создаем соединение
$connection = new AMQPStreamConnection('22.357.184.20', 5672, 'цсцаучсцу', 'сысыуксыук');

//Берем канал и декларируем в нем новую очередь, первый аргумент - название
$channel = $connection->channel();

// Очередь
$channel->queue_declare('wss_messages', false, true, false, false);

// Отправляю 5 сообщений
for ($i=0;$i<6;$i++){
    $msg = new AMQPMessage("Hello All №".$i, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);		
    $msg->set('application_headers', new AMQPTable(['x-delay' => 5000]));
    $channel->basic_publish($msg, 'main');
};
echo "Messages sended\n";
$channel->close();
$connection->close();

define('WUO_ROOT', dirname(__FILE__));

require_once WUO_ROOT.'/../vendor/autoload.php';

// загружаем классы

spl_autoload_register(function ($class_name) {

require_once WUO_ROOT.'/../class/'.$class_name.'.php';

});

//Необходимые классы

use PhpAmqpLib\Connection\AMQPStreamConnection;

use PhpAmqpLib\Message\AMQPMessage;

use PhpAmqpLib\Wire\AMQPTable;

//Создаем соединение

$connection = new AMQPStreamConnection('22.357.184.20', 5672, 'цсцаучсцу', 'сысыуксыук');

//Берем канал и декларируем в нем новую очередь, первый аргумент - название

$channel = $connection->channel();

// Очередь

$channel->queue_declare('wss_messages', false, true, false, false);

// Отправляю 5 сообщений

for ($i=0;$i<6;$i++){

$msg = new AMQPMessage("Hello All №".$i, ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

$msg->set('application_headers', new AMQPTable(['x-delay' => 5000]));

$channel->basic_publish($msg, 'main');

};

echo "Messages sended\n";

$channel->close();

$connection->close();

Пример слушателя:



define('WUO_ROOT', dirname(__FILE__));
require_once WUO_ROOT.'/../vendor/autoload.php';
// загружаем классы
spl_autoload_register(function ($class_name) {
    require_once WUO_ROOT.'/../class/'.$class_name.'.php';
});

//Необходимые классы
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Wire\AMQPTable;

//Создаем соединение
$connection = new AMQPStreamConnection('22.53.14.120', 5672, 'уцмцу', 'мцукмцукм');
$channel = $connection->channel();

$channel->queue_declare('wss_messages', false, true, false, false);

$callback = function ($msg) {
        echo $msg->body;
        echo PHP_EOL;
};
$channel->basic_qos(null, 1, null);
$channel->basic_consume('wss_messages', '', false, true, false, false, $callback);

while (count($channel->callbacks)) {
        $channel->wait();
}
$channel->close();
$connection->close();

define('WUO_ROOT', dirname(__FILE__));

require_once WUO_ROOT.'/../vendor/autoload.php';

// загружаем классы

spl_autoload_register(function ($class_name) {

require_once WUO_ROOT.'/../class/'.$class_name.'.php';

});

//Необходимые классы

use PhpAmqpLib\Connection\AMQPStreamConnection;

use PhpAmqpLib\Message\AMQPMessage;

use PhpAmqpLib\Wire\AMQPTable;

//Создаем соединение

$connection = new AMQPStreamConnection('22.53.14.120', 5672, 'уцмцу', 'мцукмцукм');

$channel = $connection->channel();

$channel->queue_declare('wss_messages', false, true, false, false);

$callback = function ($msg) {

echo $msg->body;

echo PHP_EOL;

};

$channel->basic_qos(null, 1, null);

$channel->basic_consume('wss_messages', '', false, true, false, false, $callback);

while (count($channel->callbacks)) {

$channel->wait();

}

$channel->close();

$connection->close();

Оставить комментарий rabbitmq, задержка, очередь

HelpDesk-z: класс для взаимодействия по API

11.03.2022 Павел Грибов PHP

Документация: https://docs.helpdeskz.com/en/latest/

С моими правками: https://github.com/donpadlo/helpdeskz-dev

В принципе эта ХелпДеск система уже умеет работать с API, осталось дело за малым — обернуть это всё в удобный класс для работы:

» Читать далее

Оставить комментарий

Особенности установки helpdesk-z

09.03.2022 Павел Грибов PHP, WEB

К сожалению в руководстве по установке, процесс описан очень коротенько, и очень часто установка сводится к выводу сообщения:

Whoops! We seem to have hit a snag. Please try again later…

Чтобы улучшить информативность фреймворка, что же ему таки не хватает, можно временно добавить в index.php строчку:

define('ENVIRONMENT', 'testing');

1	define('ENVIRONMENT', 'testing');

Но! В этом случае после успешного прохождения всех шагов инсталляции, фремворк будет пытаться проходить тесты и писать результаты в SQLite3, что нам не нужно. Потому не забудьте эту строчку удалить.

Для локализации, достаточно скачать необходимый язык из https://github.com/helpdesk-z/translations, и в настройках поменять локаль на нужную

Оставить комментарий helpdesk-z

Ошибка определения текущих координат пользователя

28.05.2021 Павел Грибов Android

С выходом новых версий Android (начиная с 11), почему то сломалось определение текущих координат пользователя в webview. Пока сделал следующий костыль:

 function fetchLocation() {
        if (navigator.geolocation) {
            navigator.geolocation.getCurrentPosition(onGeoSuccess, onGeoError)
        } else {            
            console.log("- без передачи геолокации ((")            
        }
     }
    function onGeoSuccess(event){
        latitude=event.coords.latitude;
        longitude=event.coords.longitude;
        accuracy=event.coords.accuracy; //точность
        console.log("- можно снимать координаты в браузере способ №2")
        geosupport=true;
    }
    function onGeoError(event){
            console.log("- без передачи геолокации ((")
    }
    
        console.log("--способ 1");
        navigator.geolocation.getCurrentPosition(
        function(location) {
            latitude=location.coords.latitude;
            longitude=location.coords.longitude;
            accuracy=location.coords.accuracy; //точность
            console.log("- можно снимать координаты в браузере способ №1")
          },
            function(error){
                console.log("-пробую способ 2");
                fetchLocation();
           },{enableHighAccuracy: true,timeout: 2000,
                             maximumAge: 60000}
      );

function fetchLocation() {

if (navigator.geolocation) {

navigator.geolocation.getCurrentPosition(onGeoSuccess, onGeoError)

} else {

console.log("- без передачи геолокации ((")

}

function onGeoSuccess(event){

latitude=event.coords.latitude;

longitude=event.coords.longitude;

accuracy=event.coords.accuracy; //точность

console.log("- можно снимать координаты в браузере способ №2")

geosupport=true;

}

function onGeoError(event){

console.log("- без передачи геолокации ((")

}

console.log("--способ 1");

navigator.geolocation.getCurrentPosition(

function(location) {

latitude=location.coords.latitude;

longitude=location.coords.longitude;

accuracy=location.coords.accuracy; //точность

console.log("- можно снимать координаты в браузере способ №1")

function(error){

console.log("-пробую способ 2");

fetchLocation();

},{enableHighAccuracy: true,timeout: 2000,

maximumAge: 60000}

);

Оставить комментарий android, webview, геолокация

RGB лента + Raspberry Pi

08.03.2021 Павел Грибов Из жизни

На днях собрал себе очередную игрушку на raspberry pi для загородного дома. А именно по датчику движения в коридоре будет включаться RGB лента, цель которой дать освещение достаточное для «дойти до выключателя». Не, я конечно натыкал и «проходных» выключателей аж 3 штуки, но всё равно иной раз приходиться идти до них, нащупывать их в темноте, попутно спотыкаясь о валяющуюся на полу пилу, циркуляру и электрокосу 😉 Пока правда собрал «на коленке», для проверки работы ленты. Получилось примерно так:

https://www.youtube.com/watch?v=qSEB7YS0lw8

Лента самая китайская на контроллере WS2812b, 5V , 60 диодов на метр, 5 метров (1300р). Блок питания S-100W-5 (1000р).

Схема подключения:

Результат выложил на Гитхаб: https://github.com/donpadlo/rgb_led_effect

Оставить комментарий led, raspberry pi, rgb, WS2812b, эффекты

« 1 … 3 4 5 6 7 … 12 »

Пн	Вт	Ср	Чт	Пт	Сб	Вс
				1	2	3
4	5	6	7	8	9	10
11	12	13	14	15	16	17
18	19	20	21	22	23	24
25	26	27	28	29	30