`
wbj0110
  • 浏览: 1646194 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

Thrift入门及Java实例演示

阅读更多

目录:

  • 概述
  • 下载配置
  • 基本概念
  1. 数据类型
  2. 服务端编码基本步骤
  3. 客户端编码基本步骤
  4. 数据传输协议
  • 实例演示(java)
    1.  thrift生成代码
    2.  实现接口Iface
    3. TSimpleServer服务模型
    4. TThreadPoolServer 服务模型
    5. TNonblockingServer 服务模型
    6. THsHaServer服务模型
    7. 异步客户端
  • [一]、概述

    Thrift是一个软件框架,用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎,以构建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 等等编程语言间无缝结合的、高效的服务。

    Thrift最初由facebook开发,07年四月开放源码,08年5月进入apache孵化器。thrift允许你定义一个简单的定义文件中的数据类型和服务接口。以作为输入文件,编译器生成代码用来方便地生成RPC客户端和服务器通信的无缝跨编程语言。

    官网地址:thrift.apache.org

    推荐值得一看的文章:

    [二]、下载配置

    到官网下载最新版本,截止今日(2012-06-11)最新版本为0.8.0.

    1. 如果是Maven构建项目的,直接在pom.xml 中添加如下内容:

    1 <dependency>
    2   <groupId>org.apache.thrift</groupId>
    3   <artifactId>libthrift</artifactId>
    4   <version>0.8.0</version>
    5 </dependency>

    2.如果自己编译lib包,把下载的压缩包解压到X:盘,然后在X:\thrift-0.8.0\lib\java 目录下运行ant进行自动编译,会在X:\thrift-0.8.0\lib\java\build\ 目录下看到编译好的lib包:libthrift-0.8.0.jar

    [三]、基本概念

    1.数据类型

    • 基本类型:
      • bool:布尔值,true 或 false,对应 Java 的 boolean
      • byte:8 位有符号整数,对应 Java 的 byte
      • i16:16 位有符号整数,对应 Java 的 short
      • i32:32 位有符号整数,对应 Java 的 int
      • i64:64 位有符号整数,对应 Java 的 long
      • double:64 位浮点数,对应 Java 的 double
      • string:utf-8编码的字符串,对应 Java 的 String
    • 结构体类型:
      • struct:定义公共的对象,类似于 C 语言中的结构体定义,在 Java 中是一个 JavaBean
    • 容器类型:
      • list:对应 Java 的 ArrayList
      • set:对应 Java 的 HashSet
      • map:对应 Java 的 HashMap
    • 异常类型:
      • exception:对应 Java 的 Exception
    • 服务类型:
      • service:对应服务的类

    2.服务端编码基本步骤:

    • 实现服务处理接口impl
    • 创建TProcessor
    • 创建TServerTransport
    • 创建TProtocol
    • 创建TServer
    • 启动Server

    3.客户端编码基本步骤:

    • 创建Transport
    • 创建TProtocol
    • 基于TTransport和TProtocol创建 Client
    • 调用Client的相应方法

    4.数据传输协议

    • TBinaryProtocol : 二进制格式.
    • TCompactProtocol : 压缩格式
    • TJSONProtocol : JSON格式
    • TSimpleJSONProtocol : 提供JSON只写协议, 生成的文件很容易通过脚本语言解析

    tips:客户端和服务端的协议要一致

    [四]、实例演示

    1. thrift生成代码

    创建Thrift文件:G:\test\thrift\demoHello.thrift ,内容如下:

    1 namespace java com.micmiu.thrift.demo
    2  
    3 service  HelloWorldService {
    4   string sayHello(1:string username)
    5 }

    目录结构如下:

    G:\test\thrift>tree /F
    卷 other 的文件夹 PATH 列表
    卷序列号为 D238-BE47
    G:.
        demoHello.thrift
        demouser.thrift
        thrift-0.8.0.exe
    
    没有子文件夹

    thrift-0.8.0.exe 是官网提供的windows下编译工具,运用这个工具生成相关代码:

    1 thrift-0.8.0.exe -r -gen java ./demoHello.thrift

    生成后的目录结构如下:

    G:\test\thrift>tree /F
    卷 other 的文件夹 PATH 列表
    卷序列号为 D238-BE47
    G:.
    │  demoHello.thrift
    │  demouser.thrift
    │  thrift-0.8.0.exe
    │
    └─gen-java
        └─com
            └─micmiu
                └─thrift
                    └─demo
                            HelloWorldService.java

    将生成的HelloWorldService.java 文件copy到自己测试的工程中,我的工程是用maven构建的,故在pom.xml中增加如下内容:

    1 <dependency>
    2     <groupId>org.apache.thrift</groupId>
    3     <artifactId>libthrift</artifactId>
    4     <version>0.8.0</version>
    5 </dependency>
    6 <dependency>
    7     <groupId>org.slf4j</groupId>
    8     <artifactId>slf4j-log4j12</artifactId>
    9     <version>1.5.8</version>
    10 </dependency>

    2. 实现接口Iface

    java代码:HelloWorldImpl.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TException;
    4  
    5 /**
    6  * blog http://www.micmiu.com
    7  *
    8  * @author Michael
    9  *
    10  */
    11 public class HelloWorldImpl implements HelloWorldService.Iface {
    12  
    13     public HelloWorldImpl() {
    14     }
    15  
    16     @Override
    17     public String sayHello(String username) throws TException {
    18         return "Hi," + username + " welcome to my blog www.micmiu.com";
    19     }
    20  
    21 }

    3.TSimpleServer服务端

    简单的单线程服务模型,一般用于测试。

    编写服务端server代码:HelloServerDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TProcessor;
    4 import org.apache.thrift.protocol.TBinaryProtocol;
    5 import org.apache.thrift.protocol.TCompactProtocol;
    6 import org.apache.thrift.protocol.TJSONProtocol;
    7 import org.apache.thrift.protocol.TSimpleJSONProtocol;
    8 import org.apache.thrift.server.TServer;
    9 import org.apache.thrift.server.TSimpleServer;
    10 import org.apache.thrift.transport.TServerSocket;
    11  
    12 /**
    13  * blog http://www.micmiu.com
    14  *
    15  * @author Michael
    16  *
    17  */
    18 public class HelloServerDemo {
    19     public static final int SERVER_PORT = 8090;
    20  
    21     public void startServer() {
    22         try {
    23             System.out.println("HelloWorld TSimpleServer start ....");
    24  
    25             TProcessor tprocessor = newHelloWorldService.Processor<HelloWorldService.Iface>(
    26                     new HelloWorldImpl());
    27             // HelloWorldService.Processor<HelloWorldService.Iface> tprocessor =
    28             // new HelloWorldService.Processor<HelloWorldService.Iface>(
    29             // new HelloWorldImpl());
    30  
    31             // 简单的单线程服务模型,一般用于测试
    32             TServerSocket serverTransport = newTServerSocket(SERVER_PORT);
    33             TServer.Args tArgs = new TServer.Args(serverTransport);
    34             tArgs.processor(tprocessor);
    35             tArgs.protocolFactory(new TBinaryProtocol.Factory());
    36             // tArgs.protocolFactory(new TCompactProtocol.Factory());
    37             // tArgs.protocolFactory(new TJSONProtocol.Factory());
    38             TServer server = new TSimpleServer(tArgs);
    39             server.serve();
    40  
    41         catch (Exception e) {
    42             System.out.println("Server start error!!!");
    43             e.printStackTrace();
    44         }
    45     }
    46  
    47     /**
    48      * @param args
    49      */
    50     public static void main(String[] args) {
    51         HelloServerDemo server = new HelloServerDemo();
    52         server.startServer();
    53     }
    54  
    55 }

    编写客户端Client代码:HelloClientDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TException;
    4 import org.apache.thrift.protocol.TBinaryProtocol;
    5 import org.apache.thrift.protocol.TCompactProtocol;
    6 import org.apache.thrift.protocol.TJSONProtocol;
    7 import org.apache.thrift.protocol.TProtocol;
    8 import org.apache.thrift.transport.TSocket;
    9 import org.apache.thrift.transport.TTransport;
    10 import org.apache.thrift.transport.TTransportException;
    11  
    12 /**
    13  * blog http://www.micmiu.com
    14  *
    15  * @author Michael
    16  *
    17  */
    18 public class HelloClientDemo {
    19  
    20     public static final String SERVER_IP = "localhost";
    21     public static final int SERVER_PORT = 8090;
    22     public static final int TIMEOUT = 30000;
    23  
    24     /**
    25      *
    26      * @param userName
    27      */
    28     public void startClient(String userName) {
    29         TTransport transport = null;
    30         try {
    31             transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);
    32             // 协议要和服务端一致
    33             TProtocol protocol = new TBinaryProtocol(transport);
    34             // TProtocol protocol = new TCompactProtocol(transport);
    35             // TProtocol protocol = new TJSONProtocol(transport);
    36             HelloWorldService.Client client = newHelloWorldService.Client(
    37                     protocol);
    38             transport.open();
    39             String result = client.sayHello(userName);
    40             System.out.println("Thrify client result =: " + result);
    41         catch (TTransportException e) {
    42             e.printStackTrace();
    43         catch (TException e) {
    44             e.printStackTrace();
    45         finally {
    46             if (null != transport) {
    47                 transport.close();
    48             }
    49         }
    50     }
    51  
    52     /**
    53      * @param args
    54      */
    55     public static void main(String[] args) {
    56         HelloClientDemo client = new HelloClientDemo();
    57         client.startClient("Michael");
    58  
    59     }
    60  
    61 }

    先运行服务端程序,日志如下:

    HelloWorld TSimpleServer start ....

    再运行客户端调用程序,日志如下:

    Thrify client result =: Hi,Michael welcome to my blog www.micmiu.com

    测试成功,和预期的返回信息一致。

    4.TThreadPoolServer 服务模型

    线程池服务模型,使用标准的阻塞式IO,预先创建一组线程处理请求。

    编写服务端代码:HelloServerDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TProcessor;
    4 import org.apache.thrift.protocol.TBinaryProtocol;
    5 import org.apache.thrift.server.TServer;
    6 import org.apache.thrift.server.TThreadPoolServer;
    7 import org.apache.thrift.transport.TServerSocket;
    8  
    9 /**
    10  * blog http://www.micmiu.com
    11  *
    12  * @author Michael
    13  *
    14  */
    15 public class HelloServerDemo {
    16     public static final int SERVER_PORT = 8090;
    17  
    18     public void startServer() {
    19         try {
    20             System.out.println("HelloWorld TThreadPoolServer start ....");
    21  
    22             TProcessor tprocessor = newHelloWorldService.Processor<HelloWorldService.Iface>(
    23                     new HelloWorldImpl());
    24  
    25              TServerSocket serverTransport = newTServerSocket(SERVER_PORT);
    26              TThreadPoolServer.Args ttpsArgs = newTThreadPoolServer.Args(
    27              serverTransport);
    28              ttpsArgs.processor(tprocessor);
    29              ttpsArgs.protocolFactory(new TBinaryProtocol.Factory());
    30  
    31             // 线程池服务模型,使用标准的阻塞式IO,预先创建一组线程处理请求。
    32              TServer server = new TThreadPoolServer(ttpsArgs);
    33              server.serve();
    34  
    35         catch (Exception e) {
    36             System.out.println("Server start error!!!");
    37             e.printStackTrace();
    38         }
    39     }
    40  
    41     /**
    42      * @param args
    43      */
    44     public static void main(String[] args) {
    45         HelloServerDemo server = new HelloServerDemo();
    46         server.startServer();
    47     }
    48  
    49 }

    客户端Client代码和之前的一样,只要数据传输的协议一致即可,客户端测试成功,结果如下:

    Thrify client result =: Hi,Michael welcome to my blog www.micmiu.com

    5.TNonblockingServer 服务模型

    使用非阻塞式IO,服务端和客户端需要指定 TFramedTransport 数据传输的方式。

    编写服务端代码:HelloServerDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TProcessor;
    4 import org.apache.thrift.protocol.TCompactProtocol;
    5 import org.apache.thrift.server.TNonblockingServer;
    6 import org.apache.thrift.server.TServer;
    7 import org.apache.thrift.transport.TFramedTransport;
    8 import org.apache.thrift.transport.TNonblockingServerSocket;
    9  
    10 /**
    11  * blog http://www.micmiu.com
    12  *
    13  * @author Michael
    14  *
    15  */
    16 public class HelloServerDemo {
    17     public static final int SERVER_PORT = 8090;
    18  
    19     public void startServer() {
    20         try {
    21             System.out.println("HelloWorld TNonblockingServer start ....");
    22  
    23             TProcessor tprocessor = newHelloWorldService.Processor<HelloWorldService.Iface>(
    24                     new HelloWorldImpl());
    25  
    26             TNonblockingServerSocket tnbSocketTransport = newTNonblockingServerSocket(
    27                     SERVER_PORT);
    28             TNonblockingServer.Args tnbArgs = newTNonblockingServer.Args(
    29                     tnbSocketTransport);
    30             tnbArgs.processor(tprocessor);
    31             tnbArgs.transportFactory(new TFramedTransport.Factory());
    32             tnbArgs.protocolFactory(new TCompactProtocol.Factory());
    33  
    34             // 使用非阻塞式IO,服务端和客户端需要指定TFramedTransport数据传输的方式
    35             TServer server = new TNonblockingServer(tnbArgs);
    36             server.serve();
    37  
    38         catch (Exception e) {
    39             System.out.println("Server start error!!!");
    40             e.printStackTrace();
    41         }
    42     }
    43  
    44     /**
    45      * @param args
    46      */
    47     public static void main(String[] args) {
    48         HelloServerDemo server = new HelloServerDemo();
    49         server.startServer();
    50     }
    51  
    52 }

    编写客户端代码:HelloClientDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TException;
    4 import org.apache.thrift.protocol.TCompactProtocol;
    5 import org.apache.thrift.protocol.TProtocol;
    6 import org.apache.thrift.transport.TFramedTransport;
    7 import org.apache.thrift.transport.TSocket;
    8 import org.apache.thrift.transport.TTransport;
    9 import org.apache.thrift.transport.TTransportException;
    10  
    11 /**
    12  * blog http://www.micmiu.com
    13  *
    14  * @author Michael
    15  *
    16  */
    17 public class HelloClientDemo {
    18  
    19     public static final String SERVER_IP = "localhost";
    20     public static final int SERVER_PORT = 8090;
    21     public static final int TIMEOUT = 30000;
    22  
    23     /**
    24      *
    25      * @param userName
    26      */
    27     public void startClient(String userName) {
    28         TTransport transport = null;
    29         try {
    30             transport = new TFramedTransport(new TSocket(SERVER_IP,
    31                     SERVER_PORT, TIMEOUT));
    32             // 协议要和服务端一致
    33             TProtocol protocol = new TCompactProtocol(transport);
    34             HelloWorldService.Client client = newHelloWorldService.Client(
    35                     protocol);
    36             transport.open();
    37             String result = client.sayHello(userName);
    38             System.out.println("Thrify client result =: " + result);
    39         catch (TTransportException e) {
    40             e.printStackTrace();
    41         catch (TException e) {
    42             e.printStackTrace();
    43         finally {
    44             if (null != transport) {
    45                 transport.close();
    46             }
    47         }
    48     }
    49  
    50     /**
    51      * @param args
    52      */
    53     public static void main(String[] args) {
    54         HelloClientDemo client = new HelloClientDemo();
    55         client.startClient("Michael");
    56  
    57     }
    58  
    59 }

    客户端的测试成功,结果如下:

    Thrify client result =: Hi,Michael welcome to my blog www.micmiu.com

    6.THsHaServer服务模型

    半同步半异步的服务端模型,需要指定为: TFramedTransport 数据传输的方式。

    编写服务端代码:HelloServerDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TProcessor;
    4 import org.apache.thrift.protocol.TBinaryProtocol;
    5 import org.apache.thrift.protocol.TCompactProtocol;
    6 import org.apache.thrift.server.THsHaServer;
    7 import org.apache.thrift.server.TNonblockingServer;
    8 import org.apache.thrift.server.TServer;
    9 import org.apache.thrift.server.TSimpleServer;
    10 import org.apache.thrift.server.TThreadPoolServer;
    11 import org.apache.thrift.transport.TFramedTransport;
    12 import org.apache.thrift.transport.TNonblockingServerSocket;
    13 import org.apache.thrift.transport.TServerSocket;
    14  
    15 /**
    16  * blog http://www.micmiu.com
    17  *
    18  * @author Michael
    19  *
    20  */
    21 public class HelloServerDemo {
    22     public static final int SERVER_PORT = 8090;
    23  
    24     public void startServer() {
    25         try {
    26             System.out.println("HelloWorld THsHaServer start ....");
    27  
    28             TProcessor tprocessor = newHelloWorldService.Processor<HelloWorldService.Iface>(
    29                     new HelloWorldImpl());
    30  
    31             TNonblockingServerSocket tnbSocketTransport = newTNonblockingServerSocket(
    32                     SERVER_PORT);
    33             THsHaServer.Args thhsArgs = newTHsHaServer.Args(tnbSocketTransport);
    34             thhsArgs.processor(tprocessor);
    35             thhsArgs.transportFactory(new TFramedTransport.Factory());
    36             thhsArgs.protocolFactory(new TBinaryProtocol.Factory());
    37  
    38             //半同步半异步的服务模型
    39             TServer server = new THsHaServer(thhsArgs);
    40             server.serve();
    41  
    42         catch (Exception e) {
    43             System.out.println("Server start error!!!");
    44             e.printStackTrace();
    45         }
    46     }
    47  
    48     /**
    49      * @param args
    50      */
    51     public static void main(String[] args) {
    52         HelloServerDemo server = new HelloServerDemo();
    53         server.startServer();
    54     }
    55  
    56 }

    客户端代码和上面 4 中的类似,只要注意传输协议一致以及指定传输方式为TFramedTransport

    7.异步客户端

    编写服务端代码:HelloServerDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import org.apache.thrift.TProcessor;
    4 import org.apache.thrift.protocol.TCompactProtocol;
    5 import org.apache.thrift.server.TNonblockingServer;
    6 import org.apache.thrift.server.TServer;
    7 import org.apache.thrift.transport.TFramedTransport;
    8 import org.apache.thrift.transport.TNonblockingServerSocket;
    9  
    10 /**
    11  * blog http://www.micmiu.com
    12  *
    13  * @author Michael
    14  *
    15  */
    16 public class HelloServerDemo {
    17     public static final int SERVER_PORT = 8090;
    18  
    19     public void startServer() {
    20         try {
    21             System.out.println("HelloWorld TNonblockingServer start ....");
    22  
    23             TProcessor tprocessor = newHelloWorldService.Processor<HelloWorldService.Iface>(
    24                     new HelloWorldImpl());
    25  
    26             TNonblockingServerSocket tnbSocketTransport = newTNonblockingServerSocket(
    27                     SERVER_PORT);
    28             TNonblockingServer.Args tnbArgs = newTNonblockingServer.Args(
    29                     tnbSocketTransport);
    30             tnbArgs.processor(tprocessor);
    31             tnbArgs.transportFactory(new TFramedTransport.Factory());
    32             tnbArgs.protocolFactory(new TCompactProtocol.Factory());
    33  
    34             // 使用非阻塞式IO,服务端和客户端需要指定TFramedTransport数据传输的方式
    35             TServer server = new TNonblockingServer(tnbArgs);
    36             server.serve();
    37  
    38         catch (Exception e) {
    39             System.out.println("Server start error!!!");
    40             e.printStackTrace();
    41         }
    42     }
    43  
    44     /**
    45      * @param args
    46      */
    47     public static void main(String[] args) {
    48         HelloServerDemo server = new HelloServerDemo();
    49         server.startServer();
    50     }
    51  
    52 }

    编写客户端Client代码:HelloAsynClientDemo.java

    1 package com.micmiu.thrift.demo;
    2  
    3 import java.util.concurrent.CountDownLatch;
    4 import java.util.concurrent.TimeUnit;
    5  
    6 import org.apache.thrift.TException;
    7 import org.apache.thrift.async.AsyncMethodCallback;
    8 import org.apache.thrift.async.TAsyncClientManager;
    9 import org.apache.thrift.protocol.TCompactProtocol;
    10 import org.apache.thrift.protocol.TProtocolFactory;
    11 import org.apache.thrift.transport.TNonblockingSocket;
    12 import org.apache.thrift.transport.TNonblockingTransport;
    13  
    14 importcom.micmiu.thrift.demo.HelloWorldService.AsyncClient.sayHello_call;
    15  
    16 /**
    17  * blog http://www.micmiu.com
    18  *
    19  * @author Michael
    20  *
    21  */
    22 public class HelloAsynClientDemo {
    23  
    24     public static final String SERVER_IP = "localhost";
    25     public static final int SERVER_PORT = 8090;
    26     public static final int TIMEOUT = 30000;
    27  
    28     /**
    29      *
    30      * @param userName
    31      */
    32     public void startClient(String userName) {
    33         try {
    34             TAsyncClientManager clientManager = newTAsyncClientManager();
    35             TNonblockingTransport transport = newTNonblockingSocket(SERVER_IP,
    36                     SERVER_PORT, TIMEOUT);
    37  
    38             TProtocolFactory tprotocol = newTCompactProtocol.Factory();
    39             HelloWorldService.AsyncClient asyncClient = newHelloWorldService.AsyncClient(
    40                     tprotocol, clientManager, transport);
    41             System.out.println("Client start .....");
    42  
    43             CountDownLatch latch = new CountDownLatch(1);
    44             AsynCallback callBack = new AsynCallback(latch);
    45             System.out.println("call method sayHello start ...");
    46             asyncClient.sayHello(userName, callBack);
    47             System.out.println("call method sayHello .... end");
    48             boolean wait = latch.await(30, TimeUnit.SECONDS);
    49             System.out.println("latch.await =:" + wait);
    50         catch (Exception e) {
    51             e.printStackTrace();
    52         }
    53         System.out.println("startClient end.");
    54     }
    55  
    56     public class AsynCallback implementsAsyncMethodCallback<sayHello_call> {
    57         private CountDownLatch latch;
    58  
    59         public AsynCallback(CountDownLatch latch) {
    60             this.latch = latch;
    61         }
    62  
    63         @Override
    64         public void onComplete(sayHello_call response) {
    65             System.out.println("onComplete");
    66             try {
    67                 // Thread.sleep(1000L * 1);
    68                 System.out.println("AsynCall result =:"
    69                         + response.getResult().toString());
    70             catch (TException e) {
    71                 e.printStackTrace();
    72             catch (Exception e) {
    73                 e.printStackTrace();
    74             finally {
    75                 latch.countDown();
    76             }
    77         }
    78  
    79         @Override
    80         public void onError(Exception exception) {
    81             System.out.println("onError :" + exception.getMessage());
    82             latch.countDown();
    83         }
    84     }
    85  
    86     /**
    87      * @param args
    88      */
    89     public static void main(String[] args) {
    90         HelloAsynClientDemo client = new HelloAsynClientDemo();
    91         client.startClient("Michael");
    92  
    93     }
    94  
    95 }

    先运行服务程序,再运行客户端程序,测试结果如下:

    Client start .....
    call method sayHello start ...
    call method sayHello .... end
    onComplete
    AsynCall result =:Hi,Michael welcome to my blog www.micmiu.com
    latch.await =:true
    startClient end.

    ————

    分享到:
    评论

    相关推荐

      maven-thrift-client

      1. **依赖管理**:在项目中,`maven-thrift-client` 可能会提供一个示例客户端,演示如何使用生成的 Thrift 代码进行通信。这通常涉及导入生成的 Java 类,并创建客户端实例来调用服务。 2. **连接设置**:根据...

      基于Java实现的RPC项目源码+项目说明.zip

      3.项目具有丰富的拓展空间,不仅可作为入门进阶,也可直接作为毕设、课程设计、大作业、项目初期立项演示等用途。 4.如果基础还行,或热爱钻研,可基于此项目进行二次开发,DIY其他不同功能。 基于Java实现的RPC项目...

      dubbo源码解析2

      1. **Java语言编程知识**:掌握Java编程的基础是非常重要的,推荐《Java编程思想》这本书作为入门书籍,了解Java的基本语法、面向对象编程等概念。 2. **Spring框架开发及应用**:Spring框架是Java开发中非常重要的...

      基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)

      基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业),个人经导师指导并认可通过的高分设计项目,评审分99分,代码完整确保可以运行,小白也可以亲自搞定,主要针对计算机相关专业的正在做大作业的学生和需要项目实战练习的学习者,可作为毕业设计、课程设计、期末大作业,代码资料完整,下载可用。 基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业)基于Python的天气预测和天气可视化项目源码+文档说明(高分毕设/大作业

      2025工业5G终端设备发展报告.pdf

      2025工业5G终端设备发展报告.pdf

      基于分布式ADMM算法与碳排放交易的MATLAB代码:电力系统优化调度

      内容概要:本文介绍了一段基于分布式ADMM算法的MATLAB代码,用于电力系统优化调度,尤其关注碳排放交易的影响。代码首先对电力系统进行分区,接着构建DC-DOPF最优潮流问题,考虑碳排放交易的成本,并利用ADMM算法求解。文中详细解释了各个关键步骤,如系统分区、目标函数设计、碳排放交易成本计算以及ADMM算法的具体实现。此外,代码还包括了多种优化技术和实用技巧,如自适应惩罚因子调整、边界条件处理等,确保算法的有效性和实用性。 适用人群:适用于对电力系统优化调度感兴趣的科研人员、工程师和技术爱好者,尤其是希望深入了解分布式算法和碳排放交易机制的人群。 使用场景及目标:①研究电力系统优化调度的新方法和技术;②探讨碳排放交易对电力系统调度策略的影响;③提高电力系统运行效率和环保性能。 其他说明:代码不仅提供了详细的注释和模块化设计,还展示了丰富的可视化结果,便于理解和进一步研究。同时,文中提到了一些实际应用案例,证明了该方法的有效性和优越性。

      IDEA中本地运行配置文件

      适配于jdk8版本

      dify-course-demo.yml

      自动化生成全套教程

      【GRP-U8软件维护】GRP-U8软件常见问题及解决方案:涵盖账务处理、自定义凭证打印、期初余额导入、双凭证模式调整、电子报表、工资模块、资产管理、物资管理、网上报销、预算编制、学生收费、安装配置及

      内容概要:本文档《GRP_U8软件近期常见问题85例.docx》详细列出了GRP_U8软件在实际使用过程中遇到的85个常见问题及其解决方案。这些问题涵盖了账务处理、电子报表、工资模块、资产管理、物资管理、成本模块、网上报销、预算编制、学生收费、安装配置以及基础数据管理等多个方面。每个问题不仅描述了现象,还提供了具体的解决步骤或SQL语句。文档强调在执行任何脚本前务必进行整库备份,并提供了维护问题的联系方式。 适合人群:适用于GRP_U8软件的管理员、技术支持人员及有一定数据库操作基础的用户。 使用场景及目标:①帮助用户快速定位并解决GRP_U8软件在账务处理、报表生成、工资管理、资产管理等模块中遇到的具体问题;②提供详细的SQL语句和操作指南,确保用户能够独立解决问题,减少对技术支持的依赖;③指导用户在遇到软件安装、配置及升级相关问题时采取正确的措施。 其他说明:文档内容正在不断完善中,用户可以通过私信反馈意见和建议。此外,文档中多次强调了数据安全的重要性,提醒用户在执行任何操作前做好备份工作。针对某些特定问题,文档还提供了多种解决方案供用户选择,以适应不同的环境和需求。

      少儿编程scratch项目源代码文件案例素材-scratch RPG 战斗.zip

      少儿编程scratch项目源代码文件案例素材-scratch RPG 战斗.zip

      基于模型预测控制(MPC)的无人艇分布式编队协同控制仿真与实现

      内容概要:本文详细介绍了利用模型预测控制(MPC)实现无人艇分布式编队协同控制的方法和技术。首先,通过简化的动力学模型和MATLAB代码展示了无人艇的基本行为预测。接着,深入探讨了编队协同控制的关键要素,包括代价函数的设计、信息交换机制以及分布式MPC的具体实现步骤。文中还提供了具体的Python代码示例,涵盖了从单个无人艇的动力学建模到多智能体之间的协作控制。此外,作者分享了一些实用技巧,如如何处理通信延迟、传感器噪声等问题,并展示了仿真效果,证明了所提出方法的有效性和鲁棒性。 适合人群:对无人艇编队控制、模型预测控制(MPC)、分布式系统感兴趣的科研人员、工程师及高校学生。 使用场景及目标:适用于研究和开发无人艇编队控制系统,特别是希望通过分布式控制实现高效、灵活的编队任务。目标是在复杂的海洋环境中,使无人艇能够自主完成编队、跟踪指定路径并应对各种干扰因素。 其他说明:文中提供的代码片段和理论解释有助于理解和实现无人艇编队控制的实际应用。建议读者在实验过程中结合实际情况进行参数调整和优化。

      操作系统实验2内存管理实验

      (3)编写程序验证FIFO和Stack LRU页面置换算法 (4)分别用FIFO和Stack LRU页置换算法,自己设定一个页面引用序列,绘制页错误次数和可用页帧总数的曲线并对比(可用Excel绘制或手绘);能否重现FIFO导致的Belady异常; (5)[选做]编程实现最优页置换算法,用课件上的序列验证。

      机器学习(深度学习):一个用于骨折分类的医学图像数据集

      一个用于骨折分类的医学图像数据集,旨在通过计算机视觉技术帮助研究人员和医疗专业人员准确识别和分类骨折类型。以下是关于该数据集的详细介绍。该数据集包含了多种类型的骨折X光图像,涵盖了常见的骨折类别,如撕脱性骨折(Avulsion Fractures)、粉碎性骨折(Comminuted Fractures)、骨折脱位(Fracture-Dislocations)、青枝骨折(Greenstick Fractures)、发际线骨折(Hairline Fractures)、嵌插性骨折(Impacted Fractures)、纵向骨折(Longitudinal Fractures)、斜行骨折(Oblique Fractures)、病理性骨折(Pathological Fractures)和螺旋形骨折(Spiral Fractures)等。多样性:数据集中的图像来自不同的骨折类型,能够为模型训练提供丰富的样本。高质量标注:数据由专业放射科医生手动标记,确保了数据的准确性和可靠性。适用性:该数据集适用于机器学习和深度学习项目,可用于开发自动化骨折分类系统。该数据集主要用于训练和验证计算机视觉模型,以实现从X光图像中自动识别和分类骨折类型。通过自动化骨折分类,可以提高医疗诊断的效率和准确性,减少人为误判,并帮助医疗专业人员更快地做出决策。是一个极具价值的医学图像数据集,能够为医疗领域的研究人员和从业者提供有力支持,推动医学影像分析技术的发展。

      互联网的兴起与数字未来

      本书《互联网的历史与数字未来》由约翰尼·瑞安撰写,探讨了互联网从诞生到成为全球性现象的历程。书中分为三个阶段:分布式网络与离心思想的兴起、互联网的扩展以及新兴环境下的互联网。第一阶段追溯了互联网概念的起源,包括冷战背景下的军事实验和计算机技术的普及。第二阶段描述了互联网如何从军事网络演变为全球互联网,并催生了万维网。第三阶段则探讨了Web 2.0的出现、网络社会的形成以及互联网对政治、文化和商业的深远影响。瑞安强调了互联网作为离心力、用户驱动和开放性的三个核心特征,并指出这些特征正在重塑我们的世界。

      易语言进程封包截取工具

      进程封包截取神器,支持TCP和UDP协议封包拦截

      最新版kibana-9.0.0-linux-x86-64.tar.gz

      最新版kibana-9.0.0-linux-x86_64.tar.gz

      子查询练习题,多练习总没有坏处,不知道凑没凑够十一个字

      子查询练习题,多练习总没有坏处,不知道凑没凑够十一个字

      可见光近红外波段VO2介电常数的Matlab计算与COMSOL仿真教程

      内容概要:本文详细介绍了如何利用Matlab计算二氧化钒(VO2)在可见光到近红外波段的介电常数,并将其应用于COMSOL多物理场仿真软件进行光学性能仿真。主要内容包括:VO2在不同温度下的相变特性及其对折射率的影响;基于Lorentz和Drude模型的介电常数计算方法;Matlab代码实现步骤;COMSOL中材料参数的导入与设置;以及常见错误提示和解决方案。文中还附带了一个详细的30分钟教学视频,帮助读者更好地理解和掌握整个流程。 适合人群:对光学材料、相变材料感兴趣的科研工作者和技术人员,尤其是从事智能窗户、光学开关等领域研究的人士。 使用场景及目标:① 学习并掌握VO2在不同温度下的光学特性和相变机制;② 利用Matlab和COMSOL进行材料参数计算和仿真,为实际应用提供理论支持;③ 解决仿真过程中可能出现的问题,提高仿真精度。 阅读建议:建议读者跟随文中的代码示例逐步操作,结合提供的教学视频加深理解。对于初学者来说,可以先熟悉Matlab的基本语法和COMSOL的操作界面,再尝试完成完整的仿真流程。

      COMSOL模拟激光打孔热应力耦合分析及优化方法

      内容概要:本文详细介绍了利用COMSOL Multiphysics进行激光打孔过程中热应力耦合仿真的具体步骤和技术要点。首先,通过建立波动光学和固体力学两个物理场,精确模拟了1064nm激光与材料相互作用产生的温度场变化及其引起的热膨胀效应。接着,针对热源加载、网格划分、求解器配置等方面进行了深入探讨,提出了多项创新性的解决方案,如采用移动高斯热源实现精准加热、引入时间条件判断调整热膨胀系数以及优化网格布局等措施。此外,还讨论了材料参数设置中的注意事项,尤其是对于高温合金材料,在不同温度区间内的导热系数和弹性模量的变化规律,并强调了相变潜热的影响。最后,通过对温度场和应力场的综合分析,揭示了激光移动速度对孔洞边缘应力分布的影响机制。 适用人群:从事激光加工、材料科学、热力学研究的专业人士,以及对多物理场耦合仿真感兴趣的科研工作者。 使用场景及目标:适用于希望深入了解激光打孔过程中热应力形成机理的研究人员;旨在提高加工精度、减少缺陷发生的工程技术人员;希望通过理论模型指导实际生产的制造业从业者。 其他说明:文中提供了大量MATLAB代码片段用于辅助理解和实施相关操作,同时分享了许多实用的经验技巧,帮助读者更好地掌握COMSOL软件的应用。

    Global site tag (gtag.js) - Google Analytics