So integrieren Sie Activemq in Springboot
May 21, 2023 pm 01:13 PM
1 Importieren Sie die für die Integration erforderlichen Abh?ngigkeiten:
<dependency> ??????<groupid>org.springframework.boot</groupid> ??????<artifactid>spring-boot-starter-activemq</artifactid> ????</dependency>
2 Erstellen Sie die application.properties-Datei
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8080 queue=myqueue
3 Passen Sie den Warteschlangennamen der Konfigurationsdatei an und erstellen Sie eine Warteschlange basierend auf dem Warteschlangennamen
package?com.example.demo;
import?javax.jms.Queue;
import?org.apache.activemq.ActiveMQConnectionFactory;
import?org.apache.activemq.command.ActiveMQQueue;
import?org.springframework.beans.factory.annotation.Value;
import?org.springframework.context.annotation.Bean;
import?org.springframework.context.annotation.Configuration;
import?org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import?org.springframework.jms.core.JmsTemplate;
@Configuration
public?class?QueueConfig?{
??@Value("${queue}")
??private?String?queue;
??@Bean
??public?Queue?logQueue()?{
????return?new?ActiveMQQueue(queue);
??}}
4. Erstellen Sie einen Produzenten. Sie k?nnen die bereitgestellte Vorlage JmsMessagingTemplate direkt zum Senden von Nachrichten verwenden:
package?com.example.demo.producter;
import?javax.jms.Queue;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.jms.core.JmsMessagingTemplate;
import?org.springframework.stereotype.Component;
import?com.example.demo.SpringbootActivemqApplication;
@Component
public?class?Producter?{
??@Autowired
??private?JmsMessagingTemplate?jmsMessagingTemplate;
??@Autowired
??private?Queue?queue;
??private?static?Logger?logger?=?LoggerFactory.getLogger(
Producter?
.class);?public?void?send()?{?String?str?=?"生產(chǎn)者生產(chǎn)數(shù)據(jù)："?+?System.currentTimeMillis();?jmsMessagingTemplate.convertAndSend(queue,?str);?logger.info("生產(chǎn)者數(shù)據(jù):{}",?str);?}?}
6. Starten Sie das Projekt, Konsolenausgabeinhalt:
7 Verbraucher, Verbraucher erstellen Es ist einfacher, h?ren Sie sich einfach die Warteschlange an:
package?com.example.demo;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;
import?org.springframework.context.ApplicationListener;
import?org.springframework.context.event.ContextRefreshedEvent;
import?org.springframework.scheduling.annotation.EnableScheduling;
import?com.example.demo.producter.Producter;
import?com.example.demo.producter.consumer.Consumer;
@SpringBootApplication
@EnableScheduling
public?class?SpringbootActivemqApplication?implements?ApplicationListener<contextrefreshedevent>?{
??@Autowired
??public?Producter?producter;
??@Autowired
??public?Consumer?consumer;
??public?static?void?main(String[]?args)?{
????SpringApplication.run(SpringbootActivemqApplication.class,?args);
????//onApplicationEvent方法?在啟動(dòng)springboot的時(shí)候?會(huì)運(yùn)行該方法,可根據(jù)項(xiàng)目實(shí)際情況?選擇合適調(diào)用消息發(fā)送方法
??}
??@Override
??public?void?onApplicationEvent(ContextRefreshedEvent?event)?{
????producter.send();
??}
}</contextrefreshedevent>
8. Endergebnis:
Das obige ist der detaillierte Inhalt vonSo integrieren Sie Activemq in Springboot. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Hei?e KI -Werkzeuge
Undress AI Tool
Ausziehbilder kostenlos
Undresser.AI Undress
KI-gestützte App zum Erstellen realistischer Aktfotos
AI Clothes Remover
Online-KI-Tool zum Entfernen von Kleidung aus Fotos.
Clothoff.io
KI-Kleiderentferner
Video Face Swap
Tauschen Sie Gesichter in jedem Video mühelos mit unserem v?llig kostenlosen KI-Gesichtstausch-Tool aus!
Hei?er Artikel
Hei?e Werkzeuge
Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor
SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen
Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung
Dreamweaver CS6
Visuelle Webentwicklungstools
SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)
Wie Springboot Jasypt integriert, um die Verschlüsselung von Konfigurationsdateien zu implementieren
Jun 01, 2023 am 08:55 AM
Einführung in Jasypt Jasypt ist eine Java-Bibliothek, die es einem Entwickler erm?glicht, seinem Projekt mit minimalem Aufwand grundlegende Verschlüsselungsfunktionen hinzuzufügen und kein tiefes Verst?ndnis der Funktionsweise der Verschlüsselung erfordert. standardbasierte Verschlüsselungstechnologie. Passw?rter, Text, Zahlen, Bin?rdateien verschlüsseln ... Geeignet für die Integration in Spring-basierte Anwendungen, offene API, zur Verwendung mit jedem JCE-Anbieter ... Fügen Sie die folgende Abh?ngigkeit hinzu: com.github.ulisesbocchiojasypt-spring-boot-starter2 Die Vorteile von Jasypt schützen unsere Systemsicherheit. Selbst wenn der Code durchgesickert ist, kann die Datenquelle garantiert werden.
So implementieren Sie verteilte Sperren mit Redis in SpringBoot
Jun 03, 2023 am 08:16 AM
1. Redis implementiert das Prinzip der verteilten Sperren und warum verteilte Sperren erforderlich sind. Bevor über verteilte Sperren gesprochen wird, muss erl?utert werden, warum verteilte Sperren erforderlich sind. Das Gegenteil von verteilten Sperren sind eigenst?ndige Sperren. Wenn wir Multithread-Programme schreiben, vermeiden wir Datenprobleme, die durch den gleichzeitigen Betrieb einer gemeinsam genutzten Variablen verursacht werden. Normalerweise verwenden wir eine Sperre, um die Richtigkeit der gemeinsam genutzten Variablen sicherzustellen Die gemeinsam genutzten Variablen liegen im gleichen Prozess. Wenn es mehrere Prozesse gibt, die gleichzeitig eine gemeinsam genutzte Ressource betreiben müssen, wie k?nnen sie sich dann gegenseitig ausschlie?en? Heutige Gesch?ftsanwendungen sind in der Regel Microservice-Architekturen, was auch bedeutet, dass eine Anwendung mehrere Prozesse bereitstellen muss. Wenn mehrere Prozesse dieselbe Datensatzzeile in MySQL ?ndern müssen, ist eine Verteilung erforderlich, um fehlerhafte Daten zu vermeiden wird zu diesem Zeitpunkt eingeführt. Der Stil ist gesperrt. Punkte erreichen wollen
Wie SpringBoot Redis anpasst, um die Cache-Serialisierung zu implementieren
Jun 03, 2023 am 11:32 AM
1. Passen Sie den RedisTemplate1.1-Standard-Serialisierungsmechanismus an. Die API-basierte Redis-Cache-Implementierung verwendet die RedisTemplate-Vorlage für Daten-Caching-Vorg?nge. ?ffnen Sie hier die RedisTemplate-Klasse und zeigen Sie die Quellcodeinformationen der Klasse publicclassRedisTemplateextendsRedisAccessorimplementsRedisOperations an. Schlüssel deklarieren, verschiedene Serialisierungsmethoden des Werts, der Anfangswert ist leer @NullableprivateRedisSe
So l?sen Sie das Problem, dass Springboot nach dem Einlesen in ein JAR-Paket nicht auf die Datei zugreifen kann
Jun 03, 2023 pm 04:38 PM
Springboot liest die Datei, kann aber nach dem Packen in ein JAR-Paket nicht auf die neueste Entwicklung zugreifen. Es gibt eine Situation, in der Springboot die Datei nach dem Packen in ein JAR-Paket nicht lesen kann ist ungültig und kann nur über den Stream gelesen werden. Die Datei befindet sich unter resources publicvoidtest(){Listnames=newArrayList();InputStreamReaderread=null;try{ClassPathResourceresource=newClassPathResource("name.txt");Input
Wie SpringBoot Redisson integriert, um eine Verz?gerungswarteschlange zu implementieren
May 30, 2023 pm 02:40 PM
Nutzungsszenario 1. Die Bestellung wurde erfolgreich aufgegeben, die Zahlung erfolgte jedoch nicht innerhalb von 30 Minuten. Die Zahlung ist abgelaufen und die Bestellung wurde automatisch storniert. 2. Die Bestellung wurde unterzeichnet und es wurde 7 Tage lang keine Bewertung durchgeführt. Wenn die Bestellung abl?uft und nicht ausgewertet wird, wird die Bestellung standardm??ig positiv bewertet. Wenn der H?ndler die Bestellung innerhalb von 5 Minuten nicht erh?lt, wird die Bestellung abgebrochen Es wird eine SMS-Erinnerung gesendet ... Für Szenarien mit langen Verz?gerungen und geringer Echtzeitleistung k?nnen wir die Aufgabenplanung verwenden, um eine regelm??ige Abfrageverarbeitung durchzuführen. Zum Beispiel: xxl-job Heute werden wir ausw?hlen
So implementieren Sie Springboot+Mybatis-plus, ohne SQL-Anweisungen zum Hinzufügen mehrerer Tabellen zu verwenden
Jun 02, 2023 am 11:07 AM
Wenn Springboot + Mybatis-plus keine SQL-Anweisungen zum Hinzufügen mehrerer Tabellen verwendet, werden die Probleme, auf die ich gesto?en bin, durch die Simulation des Denkens in der Testumgebung zerlegt: Erstellen Sie ein BrandDTO-Objekt mit Parametern, um die übergabe von Parametern an den Hintergrund zu simulieren dass es ?u?erst schwierig ist, Multi-Table-Operationen in Mybatis-plus durchzuführen. Wenn Sie keine Tools wie Mybatis-plus-join verwenden, k?nnen Sie nur die entsprechende Mapper.xml-Datei konfigurieren und die stinkende und lange ResultMap konfigurieren Schreiben Sie die entsprechende SQL-Anweisung. Obwohl diese Methode umst?ndlich erscheint, ist sie ?u?erst flexibel und erm?glicht es uns
Vergleich und Differenzanalyse zwischen SpringBoot und SpringMVC
Dec 29, 2023 am 11:02 AM
SpringBoot und SpringMVC sind beide h?ufig verwendete Frameworks in der Java-Entwicklung, es gibt jedoch einige offensichtliche Unterschiede zwischen ihnen. In diesem Artikel werden die Funktionen und Verwendungsm?glichkeiten dieser beiden Frameworks untersucht und ihre Unterschiede verglichen. Lassen Sie uns zun?chst etwas über SpringBoot lernen. SpringBoot wurde vom Pivotal-Team entwickelt, um die Erstellung und Bereitstellung von Anwendungen auf Basis des Spring-Frameworks zu vereinfachen. Es bietet eine schnelle und einfache M?glichkeit, eigenst?ndige, ausführbare Dateien zu erstellen
So verwenden Sie die @Import-Annotation in SpringBoot
May 31, 2023 pm 06:25 PM
1. @Import führt gew?hnliche Klassen ein @Import führt gew?hnliche Klassen ein, um uns dabei zu helfen, gew?hnliche Klassen als Beans zu definieren. @Import kann zu den Klassen hinzugefügt werden, die @SpringBootApplication (Startklasse), @Configuration (Konfigurationsklasse) und @Component (Komponentenklasse) entsprechen. Hinweis: @RestController, @Service und @Repository geh?ren alle über die Annotation @Import zu @Component@SpringBootApplication@Import(ImportBean.class)//ImportBean
