Как объявить скоп сервиса так, чтобы при вызове в RabbitListener сервис был заново инициализирован?

Question

grv1 @grv1

Как объявить скоп сервиса так, чтобы при вызове в RabbitListener сервис был заново инициализирован?

До внедрения очереди у сервиса стояла аннотация @Scope(value = WebApplicationContext.SCOPE_REQUEST, proxyMode = ScopedProxyMode.TARGET_CLASS) и при каждом http запросе сервис имел новый скоп. Необходимо тоже самое, но для каждого сообщения в очереди.

Вопрос задан более трёх лет назад
150 просмотров

Комментировать

Подписаться 1 Простой Комментировать

Пригласить эксперта

Ответы на вопрос 2

11 комментариев

grv1 @grv1 Автор вопроса

Ерлан Ибраев, a можно пример)

Написано более трёх лет назад
Ерлан Ибраев @mad_nazgul
Какой пример?
Создать Bean без состояния?!
public class TestStateless { public int sum(int a, int b) { return a + b; } }

Вот самый простой пример. :-)
Главное, чтобы состояние Bean'а не менялось при вызове методов.
Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Ерлан Ибраев, а что делать, если прочитать вопрос и увидеть, что нужен statefull :-)

Написано более трёх лет назад
Ерлан Ибраев @mad_nazgul

grv1, Судя по условию ТС statefull тут не нужен, если нужна инициализация на каждое сообщение в очереди :-)

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Ерлан Ибраев, тролим...
По делу бы писал.

Написано более трёх лет назад
Ерлан Ибраев @mad_nazgul

grv1, Нет, пишу по делу.
ТС судя по тому, что он просит нужно создавать новый Bean каждое сообщение. То ему не нужно, чтобы Bean хранил состояние. Т.е. Stateless Bean.
Это не значит, что помимо сообщения туда не могут передаваться параметры.
Это значит, если в него поступают одинаковые данные, то результат будет один и тот же.
Соответственно Scope тут не при чем.

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Ерлан Ибраев, Нужно чтобы состояние бина между его @Autowire сохранялось, но в пределах сообщения(@RabbitListener) при новом сообщении в бин должен быть чистым.

Написано более трёх лет назад
Ерлан Ибраев @mad_nazgul

grv1, Нету состояния "между" Autowire.
Если же нужно сохранять состояние между сообщениями.
Грубо говоря нужно помнить последнее сообщение.
Так выделите для этого отдельный Bean, в котором он будет храниться.
А обработку сообщения сделайте stateless.

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Ерлан Ибраев, что значит
Нету состояния "между" Autowire.
все бины имеют скоп и настройку инстанса. И вы видимо плохо прочитали мое предыдущее сообщение. мне как раз нужно чтобы бин "жил" в пределах сообщения, а не между)

Написано более трёх лет назад
Ерлан Ибраев @mad_nazgul

grv1, Я про что и говорю.
У вас должен быть stateless бин который обрабатывает сообщения.
Во время обработки сообщения вы можете хранить какое то состояние.
Но желательно не выносить его (состояние) в методы, а передавать через параметры функций. Как вариант.

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Ерлан Ибраев, Это обход проблемы. Есть прям решение использовать ThreadLocal в @RabbitListener, за пример взять Spring SecurityContext

Написано более трёх лет назад

5 комментариев

grv1 @grv1 Автор вопроса

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

Написано более трёх лет назад
Евгений @zolt85

grv1, для лучшего взаимопонимания необходимо определится с терминами. Что для Вас есть инициализация сервиса внутри сообщения? Что такое сообщение? Считаю, если Вы покажете код, о котором мы с Вами разговариваем, будет проще что-то конструктивно обсуждать.

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Евгений,
инициализация сервиса внутри сообщения?
это @Autowired сервиса
Что такое сообщение?
то что выполняется внутри @RabbitListener

Написано более трёх лет назад
Евгений @zolt85

grv1, я правильно понимаю, что у Вас несколько @Autowire одного и того же сервиса внутри одного @RabbitListener ?

Написано более трёх лет назад
grv1 @grv1 Автор вопроса

Евгений, да

Написано более трёх лет назад

Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации

Похожие вопросы

Android

+3 ещё

Средний
Как получить разрешение для автостарта (чтобы при старте оно загружалось) для приложения под Андройд (Android)?
- 1 подписчик
- вчера
- 59 просмотров
0

ответов
Java

Простой
Как сделать глобальный чат Chatty?
- 1 подписчик
- 20 апр.
- 69 просмотров
0

ответов
Java

+2 ещё

Простой
Selenide + Spring Boot. Как объявить страницу через метод open(), если класс страницы является bean?
- 1 подписчик
- 19 апр.
- 41 просмотр
0

ответов
Java

+1 ещё

Простой
Почему не видит WebSecurityConfigurerAdapter при попытке импортировать его в класс SecurityConfig?
- 1 подписчик
- 19 апр.
- 59 просмотров
1

ответ
Java

Простой
Почему происходит два пустых вывода при чтении с клавиатуры?
- 1 подписчик
- 19 апр.
- 48 просмотров
1

ответ
Java

+3 ещё

Средний
Пытаюсь подключиться к postgresql 16 через docker-compose, использую spring-boot 3.2.4, что не так?
- 1 подписчик
- 17 апр.
- 197 просмотров
3

ответа
Java

+1 ещё

Простой
Как правильно внедрять зависимости в классы, зависящие от не-бинов?
- 1 подписчик
- 16 апр.
- 71 просмотр
1

ответ
Python

+1 ещё

Простой
Возможно ли соединить работающий java код и так же работающий скрипт python?
- 1 подписчик
- 15 апр.
- 226 просмотров
3

ответа
Java

+2 ещё

Простой
Как заставить Tomcat работать c utf-8 и кириллицей?
- 1 подписчик
- 14 апр.
- 65 просмотров
0

ответов
Java

+2 ещё

Простой
Как правильно вывести подблок с данными на странице?
- 1 подписчик
- 14 апр.
- 30 просмотров
1

ответ
Показать ещё Загружается…

Lead Java

Bell Integrator • Ульяновск

До 400 000 ₽

Lead Java

Bell Integrator • Хабаровск

До 400 000 ₽

Java-разработчик

ДАЛЕЕ

от 200 000 ₽

Создание и публикация короткого (reels) UGC-видео на YouTube-канале

25 апр. 2024, в 01:46

500 руб./за проект

Настроить перехват https-трафика для android-приложения

25 апр. 2024, в 01:02

10000 руб./за проект

Программа (скрипт) для автоматизации торговли Solana

25 апр. 2024, в 00:45

100 руб./в час

Answer 1 · 2018-01-22 12:56:22

Ерлан Ибраев @mad_nazgul

Э-э-э... может сервис сделать stateless, а не statefull?!

Ответ написан более трёх лет назад

11 комментариев

Answer 2 · 2018-01-22 13:17:11

Для того, чтоб спринговый бин инициализировался каждый раз, когда он будет запрошен, его нужно отметить аннотацией
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
Тут есть некоторые нюансы, а именно, если Вы будете инжектить такой бин в другой бин, который является синглтоном (по-умолчанию), то заинжектится такой бин только один раз, соответственно по-факту это будет синглтон.
А если Вы будете просить такой бин в коде у ApplicationContext, то да, всегда будете получать новый инстанс бина.

Как объявить скоп сервиса так, чтобы при вызове в RabbitListener сервис был заново инициализирован?

Войдите, чтобы написать ответ

Минуточку внимания

Войдите на сайт