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

Question

[grv1]

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

Answer 1

[Ерлан Ибраев]

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

Comments

[grv1]

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

[Ерлан Ибраев]

Какой пример?
Создать Bean без состояния?!

public class TestStateless {
  public int sum(int a, int b) {
    return a + b;
  }
}

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

[grv1]

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

[Ерлан Ибраев]

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

[grv1]

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

[Ерлан Ибраев]

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

[grv1]

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

[Ерлан Ибраев]

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

[grv1]

Ерлан Ибраев, что значит

Нету состояния "между" Autowire.

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

[Ерлан Ибраев]

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

[grv1]

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

Answer 2

[Евгений]

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

Comments

[grv1]

Вы не внимательно читаете.

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

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

[Евгений]

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

[grv1]

Евгений,

инициализация сервиса внутри сообщения?

это @Autowired сервиса

Что такое сообщение?

то что выполняется внутри @RabbitListener

[Евгений]

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

[grv1]

Евгений, да