SpringBoot與分布式

一、SpringCloud

1姚建、注冊(cè)中心eureka-server
配置文件

server.port=8761
spring.application.name=server
eureka.instance.hostname=server
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
#默認(rèn)配置也是http://localhost:8761/eureka/
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

在SpringBoot主程序上添加@EnableEurekaServer開(kāi)啟服務(wù),主程序運(yùn)行后可以在瀏覽器http://localhost:8761查看注冊(cè)的服務(wù)
2吱殉、提供者eureka-provider
配置文件

spring.application.name=provider
server.port=8081
eureka.instance.prefer-ip-address=true  //使用ip地址來(lái)注冊(cè)服務(wù)
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

TicketService

public interface TicketService {
    public String getTicket();
}

TicketServiceImpl

@Service
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "《魔獸世界大電影》";
    }
}

TicketController

@RestController
public class TicketController {
    @Autowired
    TicketService ticketService;
    @GetMapping("/getTicket")
    public String getTicket(){
        return ticketService.getTicket();
    }
}

啟動(dòng)主程序后將會(huì)把服務(wù)注冊(cè)到自己配置的eureka注冊(cè)中心

3掸冤、Eureka-Consumer

配置文件

server.port=8082
spring.application.name=consumer
eureka.instance.prefer-ip-address=true
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

SpringBoot主程序

@SpringBootApplication
@EnableDiscoveryClient   //開(kāi)啟Eureka客戶端發(fā)現(xiàn)服務(wù)
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    //主要將RestTemplate放入容器,可以在其他配置類
    @Bean
    @LoadBalanced  //當(dāng)使用服務(wù)注冊(cè)中心的Application名時(shí)必須開(kāi)啟友雳,否則會(huì)異常找不到服務(wù)
                                 //如果使用服務(wù)時(shí)用得時(shí)ip地址+端口號(hào)的方式則不能使用負(fù)載均衡
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

Controller

@RestController
public class MyController {
    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/buyTicket")
    public String buyTicket(String name){
        //使用ip+port方式稿湿,RestTemplate就不能使用@LoadBalanced負(fù)載均衡
        //String ticket = restTemplate.getForObject("http://localhost:8081/getTicket", String.class);
        //PROVIDER為注冊(cè)中心服務(wù)名,RestTemplate就必須使用@LoadBalanced負(fù)載均衡
        String ticket = restTemplate.getForObject("http://PROVIDER/getTicket", String.class);
        return name + "購(gòu)買了" + ticket;
    }
}

二押赊、Dubbo

1饺藤、使用docker安裝zookeeper,測(cè)試使用的是zookeeper 3.4.12和3.4.14
2流礁、pom依賴涕俗,需要?jiǎng)?chuàng)建兩個(gè)模塊Provider和Consumer,都加入以下依賴(若版本問(wèn)題報(bào)錯(cuò)可以看另一篇文章)

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.7</version>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.12</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

3崇棠、Provider
配置文件

server.port=8100
spring.application.name=provider
dubbo.scan.base-packages=com.crsbg.provider.service
dubbo.registry.address=zookeeper://zookeeper所在服務(wù)器ip地址:2182
dubbo.registry.timeout=10000  #默認(rèn)為3000

ProServiceImpl

@Component
@DubboService
public class ProServiceImpl implements ProService {
    @Override
    public String getTicket() {
        return "《魔獸世界大電影》";
    }
}

4咽袜、Consumer
配置文件

server.port=8200
spring.application.name=consumer
dubbo.registry.address=zookeeper://zookeeper所在服務(wù)器ip地址:2182
dubbo.registry.timeout=10000

在Consumer中創(chuàng)建一個(gè)和provider中ProService相同的接口,全類名要一致
Cousumer自己的Service

@Service
public class ConService {
    @DubboReference
    ProService proService;

    public String buyTicket(){
        return proService.getTicket();
    }
}

Controller

@RestController
public class ConController {
    @Autowired
    ConService conService;
    @RequestMapping("/buyTicket")
    public String buyTicket(String name){
        return name + "購(gòu)買了" + conService.buyTicket();
    }
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末枕稀,一起剝皮案震驚了整個(gè)濱河市询刹,隨后出現(xiàn)的幾起案子谜嫉,更是在濱河造成了極大的恐慌,老刑警劉巖凹联,帶你破解...
    沈念sama閱讀 216,692評(píng)論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件沐兰,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡蔽挠,警方通過(guò)查閱死者的電腦和手機(jī)住闯,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,482評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)澳淑,“玉大人比原,你說(shuō)我怎么就攤上這事「苎玻” “怎么了量窘?”我有些...
    開(kāi)封第一講書(shū)人閱讀 162,995評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)氢拥。 經(jīng)常有香客問(wèn)我蚌铜,道長(zhǎng),這世上最難降的妖魔是什么嫩海? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,223評(píng)論 1 292
  • 正文 為了忘掉前任冬殃,我火速辦了婚禮,結(jié)果婚禮上叁怪,老公的妹妹穿的比我還像新娘审葬。我一直安慰自己,他們只是感情好骂束,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,245評(píng)論 6 388
  • 文/花漫 我一把揭開(kāi)白布耳璧。 她就那樣靜靜地躺著,像睡著了一般展箱。 火紅的嫁衣襯著肌膚如雪旨枯。 梳的紋絲不亂的頭發(fā)上,一...
    開(kāi)封第一講書(shū)人閱讀 51,208評(píng)論 1 299
  • 那天混驰,我揣著相機(jī)與錄音攀隔,去河邊找鬼。 笑死栖榨,一個(gè)胖子當(dāng)著我的面吹牛昆汹,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播婴栽,決...
    沈念sama閱讀 40,091評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼满粗,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了愚争?” 一聲冷哼從身側(cè)響起映皆,我...
    開(kāi)封第一講書(shū)人閱讀 38,929評(píng)論 0 274
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤挤聘,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后捅彻,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體组去,經(jīng)...
    沈念sama閱讀 45,346評(píng)論 1 311
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,570評(píng)論 2 333
  • 正文 我和宋清朗相戀三年步淹,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了从隆。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,739評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡缭裆,死狀恐怖键闺,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情澈驼,我是刑警寧澤艾杏,帶...
    沈念sama閱讀 35,437評(píng)論 5 344
  • 正文 年R本政府宣布,位于F島的核電站盅藻,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏畅铭。R本人自食惡果不足惜氏淑,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,037評(píng)論 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望硕噩。 院中可真熱鬧假残,春花似錦、人聲如沸炉擅。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,677評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)谍失。三九已至眶俩,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間快鱼,已是汗流浹背颠印。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 32,833評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留抹竹,地道東北人线罕。 一個(gè)月前我還...
    沈念sama閱讀 47,760評(píng)論 2 369
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像窃判,于是被迫代替她去往敵國(guó)和親钞楼。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,647評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容