подклассы абстрактного объекта класса равны нулю при использовании автопроводки - PullRequest
Новая
       23

подклассы абстрактного объекта класса равны нулю при использовании автопроводки

0 голосов
/ 29 апреля 2019

У меня есть эти классы. когда я отлаживаю, я вижу, что пружина создает сервисный объект в конструкторе и вызывает конструкторы в обоих классах, но когда я хочу использовать поля, они равны нулю. В чем проблема?! (type1Processor, type2Processor и type3Processor равны нулю) 

import com.vali.ReactiveSocketServer.service.ReceivedDataService;
import org.springframework.stereotype.Component;

public abstract class Processor {

public ReceivedDataService receivedDataService;

public Processor(ReceivedDataService receivedDataService) {
    this.receivedDataService = receivedDataService;
}

public abstract void readStream(String stream);
}

и это его подкласс 

import com.vali.ReactiveSocketServer.model.ReceivedData;
import com.vali.ReactiveSocketServer.service.ReceivedDataService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class Type1Processor extends Processor {


@Autowired
public Type1Processor(ReceivedDataService receivedDataService) {
    super(receivedDataService);
}

@Override
public void readStream(String stream) {
    System.out.println("readStream "+ getClass().getSimpleName() + "-" + stream);
    receivedDataService.add(new ReceivedData(stream.getBytes()));
}
}

и это его использование: 

import com.vali.ReactiveSocketServer.processor.Processor;
import com.vali.ReactiveSocketServer.processor.Type1Processor;
import com.vali.ReactiveSocketServer.processor.Type2Processor;
import com.vali.ReactiveSocketServer.processor.Type3Processor;
import com.vali.ReactiveSocketServer.receivers.AppServer;
import com.vali.ReactiveSocketServer.socket.ClientHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.util.HashMap;
import java.util.Map;

@SpringBootApplication
public class ReactiveSocketServerApplication {

private AppServer appServer;

@Autowired
Type1Processor type1Processor;

@Autowired
Type2Processor type2Processor;

@Autowired
Type3Processor type3Processor;

public static void main(String[] args) {
    SpringApplication.run(ReactiveSocketServerApplication.class, args);

    ReactiveSocketServerApplication reactiveSocketServerApplication = new ReactiveSocketServerApplication();
    reactiveSocketServerApplication.Start();
}


public void Start(){

    appServer = AppServer.getInstance();

    Map<Integer, Processor> processorMap = new HashMap<>();

    processorMap.put(7001, type1Processor);
    processorMap.put(7002, type2Processor);
    processorMap.put(7003, type3Processor);

    appServer.initialize(processorMap);

    new ClientHandler(7001, 1000);
    new ClientHandler(7002, 5000);
}
}

Ответы [ 2 ]

3 голосов
/ 29 апреля 2019

Вы сами создаете ReactiveSocketServerApplication.

Таким образом, Spring не может внедрить аннотированные бобы @Autowired, потому что экземпляр был создан вне его жизненного цикла.

Удалите это полностью: 

ReactiveSocketServerApplication reactiveSocketServerApplication = new ReactiveSocketServerApplication();
reactiveSocketServerApplication.Start();

И комментируйте свой Start() с помощью @PostConstruct: 

@PostConstruct
public void Start() { ... }
0 голосов
/ 29 апреля 2019

Вы пропускаете @Component в абстрактном классе ReceivedDataService.

Это означает, что при создании подклассов используется: 

@Autowired
public Type1Processor(ReceivedDataService receivedDataService) {
   super(receivedDataService);
}

Невозможно внедрить ReceivedDataService и получить значение по умолчанию (null)

...