{"id":49877,"date":"2024-08-03T12:54:34","date_gmt":"2024-08-03T03:54:34","guid":{"rendered":"https:\/\/m9js.shop\/blog\/development\/building-a-distributed-messaging-system-using-spring-boot-and-apache-pulsar"},"modified":"2024-08-03T13:46:53","modified_gmt":"2024-08-03T04:46:53","slug":"building-a-distributed-messaging-system-using-spring-boot-and-apache-pulsar","status":"publish","type":"post","link":"https:\/\/m9js.shop\/blog\/development\/building-a-distributed-messaging-system-using-spring-boot-and-apache-pulsar","title":{"rendered":"Spring Boot\uc640 Apache Pulsar\ub97c \uc774\uc6a9\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c \uad6c\ucd95"},"content":{"rendered":"

Spring Boot\uc640 Apache Pulsar\ub97c \uc774\uc6a9\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c \uad6c\ucd95<\/h1>\n
\ubd84\uc0b0 \uc2dc\uc2a4\ud15c\uc758 \ud544\uc694\uc131\uc774 \uc99d\uac00\ud568\uc5d0 \ub530\ub77c, \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc740 \ud604\ub300 \uc560\ud50c\ub9ac\ucf00\uc774\uc158 \uc544\ud0a4\ud14d\ucc98\uc5d0\uc11c \uc911\uc694\ud55c \uc5ed\ud560\uc744 \ud558\uace0 \uc788\uc2b5\ub2c8\ub2e4. \ud2b9\ud788, Spring Boot\uc640 Apache Pulsar\ub97c \uacb0\ud569\ud558\uba74 \uac15\ub825\ud558\uace0 \uc720\uc5f0\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc744 \uad6c\ucd95\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc774 \uae00\uc5d0\uc11c\ub294 Spring Boot\uc640 Apache Pulsar\ub97c \ud65c\uc6a9\ud558\uc5ec \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc744 \uad6c\ucd95\ud558\ub294 \ubc29\ubc95\uc5d0 \ub300\ud574 \ub2e4\ub8e8\uaca0\uc2b5\ub2c8\ub2e4.<\/p>\n

1. Spring Boot\uc640 Apache Pulsar \uc18c\uac1c<\/h2>\n

Spring Boot\ub294 Java \uae30\ubc18\uc758 \ud504\ub808\uc784\uc6cc\ud06c\ub85c, \uc560\ud50c\ub9ac\ucf00\uc774\uc158 \uac1c\ubc1c\uc744 \uac04\uc18c\ud654\ud558\uace0 \uc2e0\uc18d\ud558\uac8c \ud560 \uc218 \uc788\ub3c4\ub85d \ub3d5\uc2b5\ub2c8\ub2e4. \ubc18\uba74, Apache Pulsar\ub294 \uace0\uc131\ub2a5\uc758 \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c\uc73c\ub85c, \ub300\uaddc\ubaa8 \ub370\uc774\ud130 \uc2a4\ud2b8\ub9ac\ubc0d\uacfc \uba54\uc2dc\uc9c0 \ud050\uc789\uc744 \uc9c0\uc6d0\ud569\ub2c8\ub2e4. \ub450 \uae30\uc220\uc758 \uc870\ud569\uc740 \ub2e4\uc74c\uacfc \uac19\uc740 \uc7a5\uc810\uc744 \uc81c\uacf5\ud569\ub2c8\ub2e4:<\/p>\n

\uc2e0\ub8b0\uc131<\/strong>: Pulsar\ub294 \uba54\uc2dc\uc9c0\uc758 \ub0b4\uad6c\uc131\uc744 \ubcf4\uc7a5\ud558\uba70, \ub370\uc774\ud130 \uc190\uc2e4\uc744 \ubc29\uc9c0\ud569\ub2c8\ub2e4.<\/li>\n<\/ul>\n
2. Apache Pulsar \uc124\uce58 \ubc0f \uc124\uc815<\/h2>\n
Apache Pulsar\ub97c \uc124\uce58\ud558\ub294 \uacfc\uc815\uc740 \ube44\uad50\uc801 \uac04\ub2e8\ud569\ub2c8\ub2e4. \uc544\ub798\ub294 \uae30\ubcf8\uc801\uc778 \uc124\uce58 \uc808\ucc28\uc785\ub2c8\ub2e4.<\/p>\n
\n
\n
Pulsar \ub2e4\uc6b4\ub85c\ub4dc<\/strong>: Apache Pulsar \uacf5\uc2dd \uc6f9\uc0ac\uc774\ud2b8<\/a>\uc5d0\uc11c \ucd5c\uc2e0 \ubc84\uc804\uc744 \ub2e4\uc6b4\ub85c\ub4dc\ud569\ub2c8\ub2e4.<\/p>\n<\/li>\n
\n
\uc555\ucd95 \ud574\uc81c<\/strong>: \ub2e4\uc6b4\ub85c\ub4dc\ud55c \ud30c\uc77c\uc758 \uc555\ucd95\uc744 \ud574\uc81c\ud569\ub2c8\ub2e4.<\/p>\n<\/li>\n
\n
Pulsar \uc2e4\ud589<\/strong>: \ub2e4\uc74c \uba85\ub839\uc5b4\ub85c Pulsar\ub97c \uc2e4\ud589\ud569\ub2c8\ub2e4.<\/p>\n
bin\/pulsar standalone<\/code><\/pre>\n<\/li>\n\nPulsar Admin CLI \uc0ac\uc6a9<\/strong>: Pulsar\uc758 \uad00\ub9ac \ub3c4\uad6c\ub97c \uc0ac\uc6a9\ud558\uc5ec \ud1a0\ud53d\uc744 \uc0dd\uc131\ud569\ub2c8\ub2e4.<\/p>\n bin\/pulsar-admin topics create persistent:\/\/public\/default\/my-topic<\/code><\/pre>\n<\/li>\n<\/ol>\n\uc774\uc81c Pulsar\uac00 \uc815\uc0c1\uc801\uc73c\ub85c \uc2e4\ud589\ub418\uace0 \uc788\uc73c\uba70, \uba54\uc2dc\uc9c0\ub97c \uc804\uc1a1\ud560 \uc900\ube44\uac00 \ub418\uc5c8\uc2b5\ub2c8\ub2e4.<\/p>\n 3. Spring Boot \ud504\ub85c\uc81d\ud2b8 \uc124\uc815<\/h2>\nSpring Boot \ud504\ub85c\uc81d\ud2b8\ub97c \uc124\uc815\ud558\uae30 \uc704\ud574 Maven \ub610\ub294 Gradle\uc744 \uc0ac\uc6a9\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. \uc544\ub798\ub294 Maven\uc744 \uc0ac\uc6a9\ud558\ub294 \uc608\uc2dc\uc785\ub2c8\ub2e4.<\/p>\n \n\npom.xml \uc124\uc815<\/strong>: \ub2e4\uc74c \uc758\uc874\uc131\uc744 \ucd94\uac00\ud569\ub2c8\ub2e4.<\/p>\n \n org.apache.pulsar\n pulsar-client\n 2.9.1\n<\/code><\/pre>\n<\/li>\n\nSpring Boot \uc560\ud50c\ub9ac\ucf00\uc774\uc158 \uc0dd\uc131<\/strong>: \uae30\ubcf8\uc801\uc778 Spring Boot \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc744 \uc0dd\uc131\ud569\ub2c8\ub2e4.<\/p>\n @SpringBootApplication\npublic class PulsarApplication {\n public static void main(String[] args) {\n SpringApplication.run(PulsarApplication.class, args);\n }\n}<\/code><\/pre>\n<\/li>\n\nPulsar \ud074\ub77c\uc774\uc5b8\ud2b8 \uc124\uc815<\/strong>: Pulsar \ud074\ub77c\uc774\uc5b8\ud2b8\ub97c \uc124\uc815\ud558\uc5ec \uba54\uc2dc\uc9c0\ub97c \uc804\uc1a1\ud558\uace0 \uc218\uc2e0\ud560 \uc218 \uc788\ub3c4\ub85d \ud569\ub2c8\ub2e4.<\/p>\n @Bean\npublic Producer pulsarProducer() throws PulsarClientException {\n PulsarClient client = PulsarClient.builder()\n .serviceUrl(\"pulsar:\/\/localhost:6650\")\n .build();\n return client.newProducer(Schema.STRING)\n .topic(\"persistent:\/\/public\/default\/my-topic\")\n .create();\n}<\/code><\/pre>\n<\/li>\n<\/ol>\n4. \uba54\uc2dc\uc9c0 \uc804\uc1a1 \ubc0f \uc218\uc2e0 \uad6c\ud604<\/h2>\n\uc774\uc81c \uba54\uc2dc\uc9c0\ub97c \uc804\uc1a1\ud558\uace0 \uc218\uc2e0\ud558\ub294 \uae30\ub2a5\uc744 \uad6c\ud604\ud574\ubcf4\uaca0\uc2b5\ub2c8\ub2e4.<\/p>\n \uba54\uc2dc\uc9c0 \uc804\uc1a1<\/h3>\n@Autowired\nprivate Producer pulsarProducer;\n\npublic void sendMessage(String message) throws PulsarClientException {\n pulsarProducer.send(message);\n}<\/code><\/pre>\n\uba54\uc2dc\uc9c0 \uc218\uc2e0<\/h3>\n\uba54\uc2dc\uc9c0\ub97c \uc218\uc2e0\ud558\uae30 \uc704\ud574\uc11c\ub294 Consumer\ub97c \uc124\uc815\ud574\uc57c \ud569\ub2c8\ub2e4.<\/p>\n @Bean\npublic Consumer pulsarConsumer() throws PulsarClientException {\n PulsarClient client = PulsarClient.builder()\n .serviceUrl(\"pulsar:\/\/localhost:6650\")\n .build();\n return client.newConsumer(Schema.STRING)\n .topic(\"persistent:\/\/public\/default\/my-topic\")\n .subscriptionName(\"my-subscription\")\n .subscribe();\n}<\/code><\/pre>\n\uba54\uc2dc\uc9c0\ub97c \uc218\uc2e0\ud558\ub294 \uba54\uc11c\ub4dc\ub294 \ub2e4\uc74c\uacfc \uac19\uc774 \uad6c\ud604\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.<\/p>\n public void receiveMessage() throws PulsarClientException {\n while (true) {\n Message msg = pulsarConsumer.receive();\n System.out.printf(\"Received message: %s%n\", msg.getValue());\n pulsarConsumer.acknowledge(msg);\n }\n}<\/code><\/pre>\n5. \uc0ac\ub840 \uc5f0\uad6c \ubc0f \uc131\ub2a5 \ubd84\uc11d<\/h2>\n\uc2e4\uc81c \uc0ac\ub840\ub85c, \ud55c \ub300\ud615 \uc804\uc790\uc0c1\uac70\ub798 \ud50c\ub7ab\ud3fc\uc5d0\uc11c\ub294 Spring Boot\uc640 Apache Pulsar\ub97c \uc0ac\uc6a9\ud558\uc5ec \uc8fc\ubb38 \ucc98\ub9ac \uc2dc\uc2a4\ud15c\uc744 \uad6c\ucd95\ud588\uc2b5\ub2c8\ub2e4. \uc774 \uc2dc\uc2a4\ud15c\uc740 \ub2e4\uc74c\uacfc \uac19\uc740 \uc131\uacfc\ub97c \uac70\ub450\uc5c8\uc2b5\ub2c8\ub2e4:<\/p>\n \n\ucc98\ub9ac\ub7c9 \uc99d\uac00<\/strong>: \uc8fc\ubb38 \ucc98\ub9ac \uc18d\ub3c4\uac00 30% \ud5a5\uc0c1\ub418\uc5c8\uc2b5\ub2c8\ub2e4.<\/li>\n \uc2dc\uc2a4\ud15c \uc548\uc815\uc131<\/strong>: \uc7a5\uc560 \ubc1c\uc0dd \uc2dc\uc5d0\ub3c4 \uba54\uc2dc\uc9c0\uac00 \uc190\uc2e4\ub418\uc9c0 \uc54a\uace0 \uc7ac\ucc98\ub9ac\ud560 \uc218 \uc788\uc5c8\uc2b5\ub2c8\ub2e4.<\/li>\n \uc720\uc9c0\ubcf4\uc218 \uc6a9\uc774\uc131<\/strong>: Spring Boot\uc758 \uad6c\uc870 \ub355\ubd84\uc5d0 \ucf54\ub4dc \uc720\uc9c0\ubcf4\uc218\uac00 \uc6a9\uc774\ud574\uc84c\uc2b5\ub2c8\ub2e4.<\/li>\n<\/ul>\n\uc774\ub7ec\ud55c \uc131\uacfc\ub294 Apache Pulsar\uc758 \ub192\uc740 \uc131\ub2a5\uacfc Spring Boot\uc758 \uac1c\ubc1c \uc0dd\uc0b0\uc131\uc774 \uacb0\ud569\ub41c \uacb0\uacfc\uc785\ub2c8\ub2e4.<\/p>\n \uacb0\ub860<\/h2>\nSpring Boot\uc640 Apache Pulsar\ub97c \ud65c\uc6a9\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c \uad6c\ucd95\uc740 \ud604\ub300 \uc560\ud50c\ub9ac\ucf00\uc774\uc158\uc5d0\uc11c \ud544\uc218\uc801\uc778 \uc694\uc18c\uc785\ub2c8\ub2e4. \uc774 \uc870\ud569\uc740 \ud655\uc7a5\uc131\uacfc \uc720\uc5f0\uc131\uc744 \uc81c\uacf5\ud558\uba70, \uc2e0\ub8b0\uc131 \uc788\ub294 \ub370\uc774\ud130 \uc804\uc1a1\uc744 \ubcf4\uc7a5\ud569\ub2c8\ub2e4. \uc2e4\uc81c \uc0ac\ub840\ub97c \ud1b5\ud574 \uadf8 \ud6a8\uacfc\ub97c \uc785\uc99d\ud560 \uc218 \uc788\uc73c\uba70, \uac1c\ubc1c\uc790\ub4e4\uc740 \uc774 \ub450 \uae30\uc220\uc744 \ud1b5\ud574 \ub354\uc6b1 \ud6a8\uc728\uc801\uc774\uace0 \uc548\uc815\uc801\uc778 \uc2dc\uc2a4\ud15c\uc744 \uad6c\ucd95\ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4. <\/p>\n \uc774 \uae00\uc774 Spring Boot\uc640 Apache Pulsar\ub97c \ud65c\uc6a9\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c \uad6c\ucd95\uc5d0 \ub300\ud55c \uc774\ud574\ub97c \ub192\uc774\ub294 \ub370 \ub3c4\uc6c0\uc774 \ub418\uc5c8\uae30\ub97c \ubc14\ub78d\ub2c8\ub2e4.<\/h1>\n <\/p>\n","protected":false},"excerpt":{"rendered":" Spring Boot\uc640 Apache Pulsar\ub97c \uc774\uc6a9\ud55c \ubd84\uc0b0 \uba54\uc2dc\uc9d5 \uc2dc\uc2a4\ud15c \uad6c\ucd95 \ubd84\uc0b0 \uc2dc\uc2a4\ud15c\uc758 \ud544\uc694\uc131\uc774 \uc99d\uac00\ud568\uc5d0 \ub530\ub77c, \uba54\uc2dc\uc9d5 […]<\/p>\n","protected":false},"author":1,"featured_media":49876,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[1957],"tags":[2119,2188,2156],"class_list":["post-49877","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-development","tag-api","tag-public","tag-spring"],"acf":[],"_links":{"self":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/49877","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/comments?post=49877"}],"version-history":[{"count":1,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/49877\/revisions"}],"predecessor-version":[{"id":49929,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/posts\/49877\/revisions\/49929"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media\/49876"}],"wp:attachment":[{"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/media?parent=49877"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/categories?post=49877"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/m9js.shop\/blog\/wp-json\/wp\/v2\/tags?post=49877"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}