sofa与springboot的入门案例

ゞ浴缸里的玫瑰 2022-03-22 15:16 383阅读 0赞

一、什么是sofa：  
SOFAStack（Scalable Open Financial Architecture Stack）是用于快速构建金融级分布式架构的一套中间件，也是在金融场景里锤炼出来的最佳实践。  
首先我们县城最简单的项目、SOFARPC 是蚂蚁金服开源的一款基于 Java 实现的 RPC 服务框架，为应用之间提供远程服务调用能力，具有高可伸缩性，高容错性，目前蚂蚁金服所有的业务的相互间的 RPC 调用都是采用 SOFARPC。SOFARPC 为用户提供了负载均衡，流量转发，链路追踪，链路数据透传，故障剔除等功能。SOFARPC 还支持不同的协议，目前包括 bolt，RESTful，dubbo，H2C 协议进行通信。其中 bolt 是蚂蚁金融服务集团开放的基于 Netty 开发的网络通信框架。  
详细信息读API文档：[https://www.sofastack.tech/sofa-rpc/docs/Home][https_www.sofastack.tech_sofa-rpc_docs_Home]  
二、多的不说上代码：  
1、服务端：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70]  
pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        
            
            
            
            
        
        <parent>
            <groupId>com.alipay.sofa</groupId>
            <artifactId>sofaboot-dependencies</artifactId>
            <version>3.0.0</version>
        </parent>
    
        <groupId>com.citydo</groupId>
        <artifactId>sofaboot_server</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>sofaboot_server</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            
                
                
            
    
            
                
                
                
            
            <dependency>
                <groupId>com.alipay.sofa</groupId>
                <artifactId>rpc-sofa-boot-starter</artifactId>
            </dependency>
    
            
                
                
            
    
            <dependency>
                <groupId>com.alipay.sofa</groupId>
                <artifactId>sofa-rpc-all</artifactId>
                <version>5.3.1</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

rpc-sofa.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:sofa="http://sofastack.io/schema/sofaboot"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                http://sofastack.io/schema/sofaboot   http://sofastack.io/schema/sofaboot.xsd"
           default-autowire="byName">
    
        <bean id="helloSynServiceImpl" class="com.citydo.sofaboot_server.service.impl.HelloSyncServiceImpl" />
        <sofa:service ref="helloSynServiceImpl" interface="com.citydo.sofaboot_server.service.HelloSyncService">
            
            <sofa:binding.bolt/>
            
            <sofa:binding.rest/>
            
            <sofa:binding.dubbo/>
        </sofa:service>
    
        
        
        
            
        
    
        
        
        
            
        
    
    
        
        
            
        
    
    </beans>

HelloSyncService.java、HelloSyncServiceImpl.java

package com.citydo.sofaboot_server.service;
    
    /**
     * @author nick
     */
    public interface HelloSyncService {
        String saySync(String string);
    }

package com.citydo.sofaboot_server.service.impl;
    
            import com.citydo.sofaboot_server.service.HelloSyncService;
    
    public class HelloSyncServiceImpl implements HelloSyncService {
    
        @Override
        public String saySync(String sync) {
            return sync;
        }
    
    }

启动类

package com.citydo.sofaboot_server;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.annotation.ImportResource;
    
    
    /**
     * 单向调用、同步调用、异步调用和回调
     */
    @ImportResource({"classpath:spring/rpc-sofa.xml"})
    @SpringBootApplication
    public class SofabootServerApplication {
    
        public static void main(String[] args) {
            SpringApplication springApplication = new SpringApplication(SofabootServerApplication.class);
            ApplicationContext applicationContext = springApplication.run(args);
        }
    
    }

2、客户端  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70 1]  
pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        
            
            
            
            
        
        <parent>
            <groupId>com.alipay.sofa</groupId>
            <artifactId>sofaboot-dependencies</artifactId>
            <version>3.0.0</version>
        </parent>
    
        <groupId>com.citydo</groupId>
        <artifactId>sofaboot_client</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>sofaboot_client</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            
                
                
            
    
            
                
                
                
            
            <dependency>
                <groupId>com.alipay.sofa</groupId>
                <artifactId>rpc-sofa-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alipay.sofa</groupId>
                <artifactId>sofa-rpc-all</artifactId>
                <version>5.3.1</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

rpc-sofa.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:sofa="http://sofastack.io/schema/sofaboot"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                http://sofastack.io/schema/sofaboot http://sofastack.io/schema/sofaboot.xsd"
           default-autowire="byName">
    
        
        
        <sofa:reference id="boltHelloSyncServiceReference" interface="com.citydo.sofaboot_client.service.HelloSyncService">
            <sofa:binding.bolt/>
        </sofa:reference>
    
        
        <sofa:reference id="restHelloSyncServiceReference" interface="com.citydo.sofaboot_client.service.HelloSyncService">
            <sofa:binding.rest/>
        </sofa:reference>
    
        
        <sofa:reference id="dubboHelloSyncServiceReference" interface="com.citydo.sofaboot_client.service.HelloSyncService">
            <sofa:binding.dubbo/>
        </sofa:reference>
    
        
        
            
                
            
        
    
    
        
        
            
                
            
        
    
    
        
        
        
            
                
            
        
    
        
            
                
            
        
    </beans>

HelloSyncService.java

package com.citydo.sofaboot_client.service;
    
    public interface HelloSyncService {
        String saySync(String string);
    
    }

启动类

package com.citydo.sofaboot_client;
    
    import com.citydo.sofaboot_client.service.HelloCallbackService;
    import com.citydo.sofaboot_client.service.HelloFutureService;
    import com.citydo.sofaboot_client.service.HelloSyncService;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.annotation.ImportResource;
    
    /**
     * @author nick
     */
    @ImportResource({"classpath:spring/rpc-sofa.xml"})
    @SpringBootApplication
    public class SofabootClientApplication {
    
        public static void main(String[] args) {
            System.setProperty("server.port", "8081");
            SpringApplication springApplication = new SpringApplication(SofabootClientApplication.class);
            ApplicationContext applicationContext = springApplication.run(args);
            HelloSyncService boltHelloSyncService = (HelloSyncService) applicationContext.getBean("boltHelloSyncServiceReference");
            HelloSyncService restHelloSyncService = (HelloSyncService) applicationContext.getBean("restHelloSyncServiceReference");
            HelloSyncService dubboHelloSyncService = (HelloSyncService) applicationContext.getBean("dubboHelloSyncServiceReference");
            System.out.println("Bolt result:" + boltHelloSyncService.saySync("bolt"));
            System.out.println("Rest result:" + restHelloSyncService.saySync("rest"));
            System.out.println("Dubbo result:" + dubboHelloSyncService.saySync("dubbo"));
    
    //        HelloFutureService helloFutureServiceReference = (HelloFutureService) applicationContext
                    .getBean("helloFutureServiceReference");
            helloFutureServiceReference.sayFuture("future");
            try {
                String result = (String)SofaResponseFuture.getResponse(1000, true);
                System.out.println("Future result: " + result);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
    
    //        HelloCallbackService helloCallbackServiceReference = (HelloCallbackService) applicationContext
    //                .getBean("helloCallbackServiceReference");
    //        helloCallbackServiceReference.sayCallback("callback");
    //        try {
    //            Thread.sleep(3000);
    //        } catch (InterruptedException e) {
    //            e.printStackTrace();
    //        }
        }
    
    }

源码：[https://github.com/863473007/sofa-springboot][https_github.com_863473007_sofa-springboot]

[https_www.sofastack.tech_sofa-rpc_docs_Home]: https://www.sofastack.tech/sofa-rpc/docs/Home
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70]: /images/20220322/88edd499f80b4dc6b235fcbe3a736d26.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70 1]: /images/20220322/1a00d92adf1f4de59a4aca57e9078816.png
[https_github.com_863473007_sofa-springboot]: https://github.com/863473007/sofa-springboot