Fordi projektet har brug for, at nogle data bliver sendt og modtaget, da datamængden er relativt stor, omkring 3 millioner data om dagen
I starten brugte jeg http post til at indsende data, men fandt ud af, at det var for langsomt, og afsendelseshastigheden var meget mindre end modtagelseshastigheden.
Derfor, hvis du vil bruge en lang socket-forbindelse til at sende og modtage data, så skriv socket-serveren og klienten selv, er det spild af tid, men det kan være dårligt at gøre
Endelig bruges activemq til at sende og modtage data
For det første er producentkoden som følger:
Forbruger er der to modeller:
1: Almindeligt abonnement, ikke behov for vedvarende "abonnement", det vil sige, når du forbinder, kan du modtage beskeder, og du kan ikke modtage beskeder før forbindelse, ved brug af "CreateConsumer"
2: Vedvarende abonnement, efter forbindelse kan du modtage data, der ikke tidligere er blevet pushet, ved hjælp af "CreateDurableConsumer"
Links til introduktionen af CreateDurableConsumer:Hyperlink-login er synlig.
Opret et ikke-delt vedvarende abonnement på det angivne emne, hvis det ikke allerede eksisterer, og opret en forbruger på det vedvarende abonnement. Denne metode opretter et vedvarende abonnement uden at bruge en meddelelsesvælger, og noLocal-værdien er falsk.
Applikationen bruger et vedvarende abonnement, og applikationen skal modtage alle meddelelser, der er offentliggjort om emnet, inklusive meddelelser, der udgives uden aktive brugere tilknyttet den. JMS-udbyderen fører en registrering af dette vedvarende abonnement og sikrer, at alle beskeder fra den pågældende udgiver opbevares, indtil de leveres til forbrugeren og bekræftes af det vedvarende abonnement, indtil de er udløbet.
Vedvarende abonnementer fortsætter med at akkumulere beskeder, indtil de slettes ved hjælp af afmeldningsmetoden.
Denne metode kan kun bruges med ikke-delte persistente abonnementer. Eventuelle vedvarende abonnementer, der oprettes ved hjælp af denne metode, vil blive delt ikke. Det betyder, at kun én aktiv (dvs. ikke lukket) forbruger kan være på abonnementet ad gangen. Udtrykket "forbruger" her betegner objektet TopicSubscriber, MessageConsumer eller JMSConsumer i enhver klient.
Et ikke-delt persistent abonnement identificeres ved et klient-specificeret navn og en klientidentifikator, der skal sættes. Applikationer, der derefter ønsker at oprette forbrugere på et ikke-delt vedvarende abonnement, skal bruge samme klientidentifikator.
Hvis et ikke-delt persistent abonnement med samme navn og klientidentifikator allerede eksisterer, og samme emne, meddelelsesvælger og noLocal-værdi allerede er angivet, og ingen forbruger allerede er aktiv (dvs. ikke lukket) på det persistente abonnement, skaber denne metode et eksisterende varigt abonnement på MessageConsumer.
Hvis et ikke-delt persistent abonnement med samme navn og klientidentifikator allerede eksisterer, og der allerede er en forbruger på det persistente abonnement, som er aktiv (dvs. ikke lukket), vil en JMSException blive kastet.
Hvis der allerede findes et ikke-delt persistent abonnement med samme navn og klientidentifikator, men med et andet emne, en meddelelsesvælger eller noLocal-værdi er specificeret, og ingen forbruger allerede er aktiv (dvs. ikke lukket) på det persistente abonnement, svarer dette til at afabonnere (slette) det gamle og oprette et nyt.
Delte og ikke-delte vedvarende abonnementer har måske ikke samme navn og klientidentitet. Hvis et delt persistent abonnement med samme navn og klientidentifikator allerede eksisterer, kastes en JMSException.
Der er ingen grænse for vedvarende abonnementer og delte ikke-persistente abonnementer med samme navn og clientId. Et sådant abonnement vil være helt adskilt.
Denne metode er den samme som den tilsvarende createDurableSubscriber-metode, bortset fra at den returnerer en MessageConsumer i stedet for en TopicSubscriber for at repræsentere forbrugeren.
Parameter:
Temaer - Ikke-midlertidige emneabonnementer
navn - Navnet brugt til at identificere dette abonnement
Kast:
InvalidDestinationException - Hvis et ugyldigt emne er angivet.
IllegalStateException - Hvis gæsteidentifikatoren ikke er sat
JMSException -
Hvis sessionen fejler i at oprette et ikke-delt vedvarende abonnement, og MessageConsumer på grund af en intern fejl
Hvis et ikke-delt vedvarende abonnement med samme navn og klientidentifikator allerede eksisterer, og forbrugeren allerede er aktiv
Hvis der allerede findes et delt vedvarende abonnement med samme navn og klientidentifikator.
Siden da:
JMS 2.0
IMessageConsumer CreateDurableConsumer(ITopic destination, strengnavn, strengvælger, bool noLocal);
hvor messageSelector er meddelelsesvælgeren; noLocal-flaget er falsk som standard, og når det sættes til true, begrænser det forbrugere fra kun at modtage beskeder, der er offentliggjort af samme forbindelse som dem selv, hvilket kun gælder for emner, ikke køer. Navnet er den unikke identitet for abonnementsemnet, og denne parameter skal sættes, når du abonnerer på et vedvarende abonnement.
Activemq .net skal referere til pakkedownload:Hyperlink-login er synlig.
Fuld kildekode-download:
Turister, hvis I vil se det skjulte indhold i dette indlæg, så vær venlig Svar
|
[Kopier link]
Opslået på 27/07/2017 13.19.10
|
|
|
|
Opslået på 16/01/2018 09.11.47
|
