Spring Cloud Stream неясно

@AlexZZZ79 · Регистрация: 02.09.2014

Студворк — интернет-сервис помощи студентам

Добрый день.
Есть учебный проект.У нас есть множество датчиков ,которые являются output их нужно завязать на сервер-контроллер,который связан с БД и с клиентами.Я вижу по примерам в сети что есть понятие Sink и Output ,которые с собой связываются.Но как мне множество источников завязать на одно приложение?

@LeX · 22.09.2017, 21:04

делаешь реализацию коровых интерфейсов из spring cloud stream и спринг все подхватит и будет вызывать уже твои листенеры

@AlexZZZ79 · 23.09.2017, 15:50 **[ТС]**

Можно пример.Допустим у меня есть приложение ,которое я запустил в SpringBoot и через @Autowired гружу поля где инициализирую Listener ,который читает из KAFKA(topic,partition)?Тогда output как с KAFKA связать...Просто куча примеров с Output->Sink.

@LeX · 23.09.2017, 17:43

В офф доке было, с телефона не найду сейчас

@AlexZZZ79 · 26.09.2017, 19:22 **[ТС]**

А как запустить несколько sink?Я один запустил,а второй не запускается.Поменял порт BOOTSERVICE и все равно не запускается.Один работает.А второй нет...такой же по настройкам только порт другой.

@LeX · 27.09.2017, 08:58

давай код и настройки, тут нет кашпировских

@AlexZZZ79 · 27.09.2017, 17:15 **[ТС]**

Вот источник.Их должно быть запущено на одной машине(localhost) более 1.Я запускаю один,а по второму идет ошибка.
Второй запускаю с файлом конфигурации application.properties.
Работаю я с KAFKA+SpringBoot

Java
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
31
32
33
34
35
36
@SpringBootApplication
@EnableBinding(Source.class)
public class EdmpSampleStreamApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(EdmpSampleStreamApplication.class, args);
    }
 
    @Bean
    @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "10000", maxMessagesPerPoll = "1"))
    public MessageSource<TimeInfo> timerMessageSource() {
        return () -> MessageBuilder.withPayload(new TimeInfo(new Date().getTime()+"","Label")).build();
    }
 
    public static class TimeInfo{
 
        private String time;
        private String label;
 
        public TimeInfo(String time, String label) {
            super();
            this.time = time;
            this.label = label;
        }
 
        public String getTime() {
            return time;
        }
 
        public String getLabel() {
            return label;
        }
 
    }
 
}

Добавлено через 17 минут
Что вообще нужно.
Есть много source c сигналом realtime true,false,которые отправляют сигнал в опр.topic и partition и есть sink,который должен принимать(подписан) сигнал от множества output.Каждому sink соотв.своя группа output.

Добавлено через 6 часов 41 минуту
Все задача решена.
Нужно было просто SpringBoot указать другой порт.
server.port=****
Спасибо за участие в теме!

Новые блоги и статьи Все статьи Все блоги /
Загрузка PNG-файла с альфа-каналом с помощью библиотеки SDL3_image на Android 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .	влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .
Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .	Использование SDL3-callbacks вместо функции main() на Android, Desktop и WebAssembly 8Observer8 24.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .	моя боль iceja 24.01.2026 Выложила интерполяцию кубическими сплайнами www. iceja. net REST сервисы временно не работают, только через Web. Написала за 56 рабочих часов этот сайт с нуля. При помощи perplexity. ai PRO , при. . .	Модель сукцессии микоризы anaschu 24.01.2026 Решили писать научную статью с неким РОманом

@AlexZZZ79 2 / 2 / 0 Регистрация: 02.09.2014 Сообщений: 81

	Spring Cloud Stream неясно 22.09.2017, 12:27. Показов 941. Ответов 6 Метки нет (Все метки) Добрый день. Есть учебный проект.У нас есть множество датчиков ,которые являются output их нужно завязать на сервер-контроллер,который связан с БД и с клиентами.Я вижу по примерам в сети что есть понятие Sink и Output ,которые с собой связываются.Но как мне множество источников завязать на одно приложение? 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	22.09.2017, 21:04
	делаешь реализацию коровых интерфейсов из spring cloud stream и спринг все подхватит и будет вызывать уже твои листенеры 0

@AlexZZZ79 2 / 2 / 0 Регистрация: 02.09.2014 Сообщений: 81
	23.09.2017, 15:50 [ТС]
	Можно пример.Допустим у меня есть приложение ,которое я запустил в SpringBoot и через @Autowired гружу поля где инициализирую Listener ,который читает из KAFKA(topic,partition)?Тогда output как с KAFKA связать...Просто куча примеров с Output->Sink. 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	23.09.2017, 17:43
	В офф доке было, с телефона не найду сейчас 0

@AlexZZZ79 2 / 2 / 0 Регистрация: 02.09.2014 Сообщений: 81
	26.09.2017, 19:22 [ТС]
	А как запустить несколько sink?Я один запустил,а второй не запускается.Поменял порт BOOTSERVICE и все равно не запускается.Один работает.А второй нет...такой же по настройкам только порт другой. 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	27.09.2017, 08:58
	давай код и настройки, тут нет кашпировских 0