ملزومات بهاری: نحوه استفاده از حاشیه نویسی bean برای خدمات سفارشی

package org.spring.mastery.config;

import org.spring.mastery.service.SmtpNotificationService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class NotificationConfig {

    @Bean
    public SmtpNotificationService smtpNotificationService() {
        return new SmtpNotificationService("smtp.example.com", 587, "username", "password");
    }
}

package org.spring.mastery.service;

public class SmtpNotificationService {

    public SmtpNotificationService(String host, int port, String username, String password) {
        //add fake behavior
        System.out.println(STR."Connecting to SMTP server at \{host}:\{port}");
        System.out.println(STR."Authenticating with username: \{username}");
        System.out.println("Sending a test email to verify connection...");
        System.out.println("Email sent successfully. Connection verified.");
    }

    public void sendEmail(String mail, String subject, String message) {
        System.out.println(STR."Sending email to \{mail}...");
        System.out.println(STR."Email subject: \{subject}");
        System.out.println(STR."Email message: \{message}");
        System.out.println("Email sent successfully.");

    }
}

package com.example.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class NotificationService {

    private final SmtpNotificationService smtpNotificationService;

    @Autowired
    public NotificationService(SmtpNotificationService smtpNotificationService) {
        this.smtpNotificationService = smtpNotificationService;
    }

    public void sendNotification(String message) {
        smtpNotificationService.sendEmail("recipient@example.com", "Subject", message);
    }
}

2025-04-11T10:04:25.296-03:00  INFO 11240 --- [           main] j.LocalContainerEntityManagerFactoryBean : Initialized JPA EntityManagerFactory for persistence unit 'default'
Connecting to SMTP server at smtp.example.com:587
Authenticating with username: username
Sending a test email to verify connection...
Email sent successfully. Connection verified.

    org.springframework.kafka
    spring-kafka
    3.3.4

# Kafka Configuration
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer

package org.spring.mastery.service;

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class KafkaService {

    private final KafkaTemplate<String, String> kafkaTemplate;

    public KafkaService(KafkaTemplate<String, String> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

package org.spring.mastery.config;

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.support.serializer.JsonSerializer;

import java.util.HashMap;
import java.util.Map;

@Configuration
public class KafkaConfig {

    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
        return new DefaultKafkaProducerFactory<>(configProps);
    }

    @Bean
    public KafkaTemplate<String, String> kafkaTemplate() {
        System.out.println("Create custom kafka bean");
        return new KafkaTemplate<>(producerFactory());
    }
}

2025-04-11T11:06:23.541-03:00  INFO 22032 --- [           main] j.LocalContainerEntityManagerFactoryBean : Initialized JPA EntityManagerFactory for persistence unit 'default'
Create custom kafka bean