`
wbj0110
  • 浏览: 1646038 次
  • 性别: 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开发中非常重要的...

      亚洲电子商务发展案例研究

      本书由国际发展研究中心(IDRC)和东南亚研究院(ISEAS)联合出版,旨在探讨亚洲背景下电子商务的发展与实践。IDRC自1970年起,致力于通过科学技术解决发展中国家的社会、经济和环境问题。书中详细介绍了IDRC的ICT4D项目,以及如何通过项目如Acacia、泛亚网络和泛美项目,在非洲、亚洲和拉丁美洲推动信息通信技术(ICTs)的影响力。特别强调了IDRC在弥合数字鸿沟方面所作出的贡献,如美洲连通性研究所和非洲连通性项目。ISEAS作为东南亚区域研究中心,专注于研究该地区的发展趋势,其出版物广泛传播东南亚的研究成果。本书还收录了电子商务在亚洲不同国家的具体案例研究,包括小型工匠和开发组织的电子商务行动研究、通过互联网直接营销手工艺品、电子营销人员的创新方法以及越南电子商务发展的政策影响。

      少儿编程scratch项目源代码文件案例素材-Leap On.zip

      少儿编程scratch项目源代码文件案例素材-Leap On.zip

      ANSYS Maxwell电磁仿真在高速无刷电机设计中的应用与优化技巧

      内容概要:本文详细介绍了ANSYS Maxwell电磁仿真软件在高速无刷电机(特别是吸尘器电机)设计中的应用。主要内容涵盖电机设计中的常见挑战及其解决方案,如定子槽开口设计、气隙磁密控制、Halbach阵列的应用、定子斜槽角度选择、散热设计以及PWM控制策略等。文中通过具体实例展示了如何利用Maxwell进行参数化扫描、瞬态场仿真、温度场耦合仿真等操作,从而优化电机性能并提高效率。此外,还讨论了仿真与实际情况之间的差异及应对措施。 适合人群:从事电机设计、电磁仿真及相关领域的工程师和技术人员。 使用场景及目标:适用于希望深入了解高速无刷电机设计原理及优化方法的专业人士。目标是在实际项目中运用Maxwell电磁仿真工具,解决设计难题,提升产品性能。 其他说明:文章强调了仿真并非万能,但合理的仿真手段能够极大促进产品研发进程。文中提供了多个实用的Python和MATLAB脚本示例,帮助读者更好地理解和应用相关技术。

      Java多态的一些小知识点

      这是我记录的第一篇笔记和博客,我现在大一下,我想以此为契机激励自己记笔记,加深对特定知识的印象!目前我在学习黑马的Java,同时期也会学一些数据结构和相关算法,我也会将这部分笔记上传。最后我想说的是一些最近的感想 1.不要美化你没走过的路 2.来都来了那就坚持走下去,不给自己留遗憾!!

      Matlab构建双输入深度学习模型:融合时序与频域特征的技术指南

      内容概要:本文详细介绍了如何利用Matlab构建并训练双输入深度学习模型,特别是针对不同长度的一维序列数据(如时序信号及其FFT频谱)。首先,作者展示了如何生成用于实验的仿真数据,接着深入探讨了网络架构的设计思路,包括采用CNN-LSTM处理时序特征以及纯CNN提取频域特征的方式。文中强调了数据预处理的重要性,如归一化处理,并提供了具体的训练选项设置方法。此外,还分享了一些实用的小贴士,如如何正确地进行模型评估和调整网络结构以适应不同的应用场景。最后,作者提到了一些常见的错误及解决办法,帮助读者避开潜在的陷阱。 适合人群:对深度学习感兴趣的科研工作者、研究生及以上水平的学生,尤其是那些希望将理论应用于实践的人群。 使用场景及目标:适用于需要同时处理多种类型数据的研究项目,如机械故障诊断、情感分析等领域。通过本教程的学习,读者能够掌握构建高效双输入深度学习模型的方法,从而提高数据分析的效果。 其他说明:本文不仅提供完整的代码示例,还包括了许多实践经验分享,有助于初学者更好地理解和应用所学知识。

      基于COMSOL的三相电力变压器温度场与流体场耦合计算模型及其实现技巧

      内容概要:本文详细介绍了使用COMSOL进行三相电力变压器温度场与流体场耦合计算的具体步骤和技术要点。首先讨论了变压器温升问题的重要性和现有仿真与实测数据之间的偏差,接着阐述了电磁-热-流三场耦合建模的难点及其解决方法。文中提供了关键的材料属性设置代码,如变压器油的密度和粘度随温度变化的关系表达式,并强调了网格划分、求解器配置以及后处理阶段需要注意的技术细节。此外,还分享了一些实用的经验和技巧,例如采用分离式步进求解策略、优化网格划分方式等,确保模型能够顺利收敛并获得精确的结果。最后,作者推荐了几种常用的湍流模型,并给出了具体的参数设置建议。 适用人群:从事电力系统设计、变压器制造及相关领域的工程师和技术人员,特别是那些希望深入了解COMSOL软件在复杂多物理场耦合计算方面应用的人群。 使用场景及目标:适用于需要对变压器内部温度分布和油流情况进行精确模拟的研究或工程项目。主要目的是提高仿真精度,使仿真结果更加贴近实际情况,从而指导产品设计和优化运行参数。 其他说明:文中不仅包含了详细的理论解释和技术指导,还提供了一些实际案例供读者参考。对于初学者来说,可以从简单的单相变压器开始练习,逐步掌握复杂的三相变压器建模技能。同时,作者提醒读者要注意单位的一致性和材料属性的准确性,这是避免许多常见错误的关键所在。

      PSD信号处理电路(PCB 原理图 封装库)亲测可用.zip

      PSD信号处理电路(PCB 原理图 封装库)亲测可用.zip

      少儿编程scratch项目源代码文件案例素材-3D游戏.zip

      少儿编程scratch项目源代码文件案例素材-3D游戏.zip

      信号分析+频率分析+频率合成+外部信号输入+光学分析

      信号分析,可导入外部信号文件 分析信号合成频率。 也可设置信号频率合成信号源。 信号合成,可导入外部频率文件 合成信号数据。也可调整频率数值合成信号源。 应用于通信领域, 光学领域,声波领域,信号和频率通过图形进行展示,所见所得,

      少儿编程scratch项目源代码文件案例素材-3D 汽车.zip

      少儿编程scratch项目源代码文件案例素材-3D 汽车.zip

      永磁同步电机FOC控制四种方法模型及Simulink仿真实践

      内容概要:本文详细介绍了永磁同步电机(PMSM)基于磁场定向控制(FOC)的四种不同控制策略及其Simulink仿真模型。首先,经典双闭环PI控制提供了稳定的基础控制方式,适用于大多数应用场景。其次,电流滞环控制采用Bang-Bang控制策略,虽然响应速度快但能耗较高。第三种方法是滑模转速控制,利用非线性切换函数提高系统的抗扰动能力,但在稳态时存在轻微抖振。最后,PR控制在静止坐标系上实现了高精度的电流跟踪,特别适合固定频率应用。每种控制方法都有详细的参数设定和仿真波形展示,帮助读者深入理解各控制策略的特点和适用范围。 适合人群:从事电机控制系统研究与开发的技术人员,尤其是有一定MATLAB/Simulink基础的研发人员。 使用场景及目标:①掌握永磁同步电机FOC控制的基本原理和技术细节;②通过具体实例和仿真模型验证不同控制策略的效果;③选择最适合特定应用场景的控制方法并进行优化。 其他说明:文中还提到了一些实用技巧,如参数调整的经验法则、常见问题的解决方案以及仿真环境配置注意事项。附带的参考文献有助于进一步深入了解相关理论背景。

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

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

      220V转12V工业电源设计方案详解:6W与12W高效低成本电路设计及认证要点

      内容概要:本文详细介绍了两种成熟的220V转12V工业电源设计方案,分别是6W和12W的反激式电源设计。文中不仅提供了详细的电路设计参数,如变压器绕制方法、元件选择、PCB布局技巧,还分享了许多实用的经验和技术细节,确保设计方案能够顺利通过相关认证。同时,文章对比了两种方案的成本和性能差异,帮助读者在实际应用中做出合适的选择。 适合人群:从事电源设计的工程师,尤其是对220V转12V工业电源设计感兴趣的初学者和有一定经验的研发人员。 使用场景及目标:适用于需要将220V交流电转换为12V直流电的应用场合,如工业设备、智能家居、医疗设备等。目标是提供高效、稳定且成本可控的电源解决方案。 其他说明:文章强调了变压器设计和EMI测试中的注意事项,以及如何在保证性能的前提下降低成本。此外,还提到了一些常见的认证问题及其解决办法。

      能源领域中基于储能电站服务的冷热微网系统双层优化模型及其应用

      内容概要:本文探讨了基于储能电站服务的冷热微网系统双层优化模型,旨在解决储能配置和运行调度在不同时间尺度下的优化问题。文中首先介绍了双层规划模型的构建,上层负责长时间尺度的储能配置,涉及储能系统的容量、充放电功率等关键参数;下层则专注于短时间尺度的微网优化运行,涵盖太阳能、风力发电等能源设备的功率输出。接着,文章阐述了如何通过KKT条件将双层模型转化为单层模型,并使用大M法将其线性化处理,以便于求解。最后,通过使用Gurobi等求解器进行求解,实现了储能系统的优化配置和高效运行。 适合人群:从事能源领域的研究人员和技术人员,尤其是对储能系统和微网优化感兴趣的读者。 使用场景及目标:适用于需要优化储能配置和微网运行的企业或研究机构,目标是提高能源利用效率,降低成本,促进可持续能源的发展。 其他说明:文章提供了详细的Python代码示例,帮助读者理解和实现双层优化模型的具体步骤。此外,还讨论了一些实际应用中的注意事项,如大M值的选择和求解器的配置等。

      永磁同步电机MTPA与弱磁控制的MATLAB/Simulink仿真建模及优化

      内容概要:本文介绍了永磁同步电机(PMSM)的最大转矩电流比(MTPA)控制和弱磁控制的MATLAB/Simulink仿真模型及其设计原理。首先阐述了这两种控制方式的背景和技术意义,接着详细解释了MTPA控制和弱磁控制的具体实现方法,包括关键公式和代码片段。然后展示了如何在Simulink中构建完整的仿真模型,涵盖各个控制模块的搭建,如电流环、速度环的PI调节器等。最后通过仿真结果分析验证了所提出的控制策略的有效性和优越性。 适合人群:从事电机控制系统研究的技术人员、高校相关专业师生、对永磁同步电机控制感兴趣的工程技术人员。 使用场景及目标:适用于需要深入了解并掌握永磁同步电机高性能控制技术的研究人员,帮助他们理解和实现高效的电机控制策略,特别是在工业自动化、电动汽车等领域。 其他说明:文中提供了详细的代码示例和仿真波形图,有助于读者更好地理解和复现实验结果。同时指出了调试过程中可能遇到的问题及解决方案,便于初学者避免常见错误。

      基于Matlab/Simulink的异步电机V/F开环与转差频率闭环调速系统仿真

      内容概要:本文详细介绍了利用Matlab/Simulink进行异步电机调速仿真的具体实现方法。首先探讨了最经典的恒压频比(V/F)开环控制系统,通过设置三相电源模块、V/F控制器和SVPWM逆变器,实现了电压和频率的线性增长,展示了开环系统在不同负载情况下的性能特点。接着引入了更为复杂的转差频率闭环控制方案,通过加入转速外环和转差频率内环,以及PID调节器,显著提高了系统的稳定性,特别是在负载突变时的表现。最后讨论了SVPWM控制的优势,强调其在改善电压波形质量和降低谐波方面的优越性。 适合人群:从事电机控制领域的研究人员和技术人员,尤其是有一定Matlab/Simulink基础的工程师。 使用场景及目标:适用于需要深入了解异步电机调速原理和仿真实现的研究项目。主要目标是掌握V/F开环和转差频率闭环两种控制方式的具体实现步骤,理解各自的特点和应用场景,同时学会优化系统参数以提高性能。 其他说明:文中提供了详细的代码片段和仿真技巧,帮助读者更好地理解和应用相关理论。建议读者在实践中结合实际硬件参数进行调整,确保仿真结果的准确性。

    Global site tag (gtag.js) - Google Analytics