吐槽net下没有靠谱的FastDFS的sdk之使用thrift实现JAVA和C#互通

原文:吐槽net下没有靠谱的FastDFS的sdk之使用thrift实现JAVA和C#互通

　事情是这样的，在一个新项目中引入了fastdfs，用这玩意做一些小数据的存储还是很方便的，然后在nuget上就找到了一个FastDFS的sdk，如下图：

一眼就看到了这个top1的sdk，应该会比较靠谱。。。简单的在项目中应用了一下没啥问题就忽悠上线了，然后就悲剧了，测试那边反馈说上传了一个

人群，拉下来的时候少了几个人，我的使用方式是将一批customerid按照bitmap的形式存到byte[]数组传到fastdfs，最后硬着头皮追踪下来发现是这个所谓

的sdk在upload的时候在bytes数组处理上出了bug，这下无语了，哎，nuget上这写sdk的估计也就是个人写着玩玩丢上去的，哪里敢用到生产上，还好在测

试环境发现了，不然又得出什么乱子了。

一：解决办法

　　问题还得要解决，不过庆幸的是，fastdfs是阿里的一个大牛YuQing写的，那应该有java的sdk更靠谱一点，用maven的话更方便。

        <dependency><groupId>net.oschina.zcx7878</groupId><artifactId>fastdfs-client-java</artifactId><version>1.27.0.0</version></dependency>

pull下来以后，这个sdk果然是fastdfs的作者写的，这下子安全感暴增，测试了一下，那个bug用这个sdk果然就没有问题了。。。开心~~~~

然后流程图大概就变成了这个样子。

二：解决C# 和 JAVA的互通问题

　　互通方式比较多，除了走rest这种面向http的方式，还可以使用thrift，grpc这种tcp的模式，最后我决定还是采用thrift走一遭，目前最新的版本是0.11了。

网址：http://thrift.apache.org/。看了一下C#的thrift sdk，貌似最高支持0.9.1，网址为：http://archive.apache.org/dist/thrift/0.9.1/ ，

有了这个thrift-0.9.1.exe之后，接下来就可以定义Thrift的DSL，这个DSL可以让thrift-0.9.1.exe 生成各个语言版本的sdk。

1. 定义Thrift DSL

service ThriftService
{string Upload(1: binary data),binary Download(1: string path),bool Remove(1: string path)
}

有人可能会问，这个DSL怎么写，这个大家可以看看官方的DSL的各个关键词描述的网址：http://thrift.apache.org/docs/idl 还是比较简单的，如果不清楚的

话，这个是示例大全： https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=test/ThriftTest.thrift;hb=HEAD ，然后保存为1.thrift。

2. 通过thrift生成 C# SDK

生成的方式可以参考一下官网的模板：

thrift --gen <language> <Thrift filename>

C:\Users\hxc>cd C:\java\lib\thriftC:\java\lib\thrift>thrift-0.9.1.exe -gen csharp C:\java\lib\thrift\1.thrift

可以看到，执行完之后，就多了一个gen-csharp文件夹，点进去看一下，会发现有一个文件名为DSL中定义的ThriftService.cs文件。

3. 通过thrift生成 JAVA SDK

执行完下面这条语句，你会发现你的文件夹又多了一份gen-java 。

C:\java\lib\thrift>thrift-0.9.1.exe -gen java C:\java\lib\thrift\1.thrift

三：SDK集成

　改造之后，我们使用JAVA作为服务端，C#作客户端，服务端要做的事情就是通过JAVA来封装FastDFS，然后让C#来调用。

1. JAVA服务端

《1》使用fastDFS 和 Thrift的Maven地址：

        <!-- https://mvnrepository.com/artifact/org.apache.thrift/libthrift --><dependency><groupId>org.apache.thrift</groupId><artifactId>libthrift</artifactId><version>0.9.1</version></dependency><!-- https://mvnrepository.com/artifact/net.oschina.zcx7878/fastdfs-client-java --><dependency><groupId>net.oschina.zcx7878</groupId><artifactId>fastdfs-client-java</artifactId><version>1.27.0.0</version></dependency>

《2》 ThriftServiceImpl.java 实现类：

  1 package com.datamip.thrift;
  2
  3 import java.io.IOException;
  4 import java.nio.ByteBuffer;
  5 import java.util.Date;
  6
  7 import org.apache.log4j.Logger;
  8 import org.apache.thrift.TException;
  9 import org.csource.common.MyException;
 10 import org.csource.fastdfs.StorageClient;
 11
 12 import com.fasterxml.jackson.databind.ObjectMapper;
 13
 14 /*
 15  * thrift 服务端
 16  */
 17 public class ThriftServiceImpl implements ThriftService.Iface {
 18
 19     public static Logger logger1 = Logger.getLogger(App.class);
 20
 21     StorageClient client = null;
 22
 23     ObjectMapper objectMapper=new ObjectMapper();
 24
 25     public ThriftServiceImpl() throws IOException, MyException {
 26         client = new FastService().Create();
 27     }
 28
 29     //上传文件
 30     public String Upload(ByteBuffer data) {
 31
 32         byte[] bytes = data.array();
 33
 34         logger1.info("已成功接受到upload请求: bytes.length="+bytes.length);
 35
 36         if(bytes==null || bytes.length==0) return "";
 37
 38         // 目前给的 “后缀名为 g1",以后可以动态变更，通过‘阿波罗’动态配置
 39         String[] result = null;
 40
 41         try {
 42             result = client.upload_file(bytes, "g1", null);
 43
 44             logger1.info("update 上传结果为： "+objectMapper.writeValueAsString(result));
 45
 46             if (result.length < 2) return "";
 47
 48         }catch (Exception e) {
 49             logger1.error("upload异常",e);
 50         }
 51
 52         return result[1];
 53     }
 54
 55     // 文件下载
 56     public ByteBuffer Download(String path) throws TException {
 57
 58         logger1.info("已成功接受到download请求:"+path);
 59
 60         if (path == null || path == "")
 61             return ByteBuffer.allocate(0);
 62
 63         String[] arr = path.split("\\.");
 64
 65         if (arr.length < 2)
 66             return ByteBuffer.allocate(0);
 67
 68         String group_name = arr[1];
 69
 70         try {
 71             byte[] bytes = client.download_file(group_name, path);
 72
 73             logger1.info(String.format("根据path=%s，获取的bytes长度为:%s",path,bytes.length));
 74
 75             return ByteBuffer.wrap(bytes);
 76
 77         }catch (Exception e) {
 78             logger1.error("download异常",e);
 79         }
 80
 81         // TODO Auto-generated method stub
 82         return ByteBuffer.allocate(0);
 83     }
 84
 85     // 删除文件
 86     public boolean Remove(String path) throws TException {
 87
 88         logger1.info("已成功接受到remove请求:"+path);
 89
 90         if (path == null || path == "") return false;
 91
 92         String[] arr = path.split("\\.");
 93
 94         if(arr==null || arr.length<2) return false;
 95
 96         String group_name = arr[1];
 97
 98         try {
 99             int code = client.delete_file(group_name, path);
100
101             logger1.info(String.format("当前path=%s, groupname=%s,返回状态值=%s",
102                                        path,group_name,code));
103
104             if(code==0) {
105                 return true;
106             }
107
108         }catch (Exception e) {
109             logger1.error("Remove异常",e);
110         }
111
112         return false;
113     }
114 }

《3》 FastDFS的封装类

 1 package com.datamip.thrift;
 2
 3 import java.io.IOException;
 4
 5 import org.csource.common.MyException;
 6 import org.csource.fastdfs.ClientGlobal;
 7 import org.csource.fastdfs.StorageClient;
 8 import org.csource.fastdfs.StorageServer;
 9 import org.csource.fastdfs.TrackerClient;
10 import org.csource.fastdfs.TrackerServer;
11
12 import com.datamip.utils.PropertiesUtils;
13
14 public class FastService {
15
16     public StorageClient Create() throws IOException, MyException {
17
18         //读取配置文件
19         String path = PropertiesUtils.getProperties("setting.properties","fastdfs");
20         return this.Create(path);
21     }
22
23     public StorageClient Create(String host) throws IOException, MyException {
24
25         ClientGlobal.initByTrackers(host);
26
27         // 3、创建一个TrackerClient对象。
28         TrackerClient trackerClient = new TrackerClient();
29
30         // 4、创建一个TrackerServer对象。
31         TrackerServer trackerServer = trackerClient.getConnection();
32
33         // 5、声明一个StorageServer对象，null。
34         StorageServer storageServer = null;
35
36         // 6、获得StorageClient对象。
37         StorageClient storageClient = new StorageClient(trackerServer, storageServer);
38
39         return storageClient;
40     }
41 }

《4》最后就是AppMain，Thrift开启19999端口。

 1 package com.datamip.thrift;
 2
 3 import java.io.IOException;
 4
 5 import org.apache.log4j.Logger;
 6 import org.apache.thrift.TProcessor;
 7 import org.apache.thrift.protocol.TBinaryProtocol;
 8 import org.apache.thrift.server.TServer;
 9 import org.apache.thrift.server.TSimpleServer;
10 import org.apache.thrift.transport.TServerSocket;
11 import org.apache.thrift.transport.TTransportException;
12 import org.csource.common.MyException;
13
14 public class App {
15
16     public static Logger logger1 = Logger.getLogger(App.class);
17
18     public static void main(String[] args) throws IOException, MyException {
19
20         try {
21             TProcessor tprocessor = new ThriftService.Processor<ThriftService.Iface>(new ThriftServiceImpl());
22
23             TServerSocket serverTransport = new TServerSocket(9999);
24             TServer.Args tArgs = new TServer.Args(serverTransport);
25
26             tArgs.processor(tprocessor);
27             tArgs.protocolFactory(new TBinaryProtocol.Factory());
28
29             logger1.debug("thrift 服务端开启，开放端口 19999");
30
31             TServer server = new TSimpleServer(tArgs);
32             server.serve();
33         } catch (TTransportException e) {
34             e.printStackTrace();
35         }
36     }
37 }

2. C#客户端

《1》从negut上把dll拉下来，然后把生成的ThriftService.cs引入到我们的解决方案中

  public partial class ThriftService{public interface Iface{string Upload(byte[] data);
#if SILVERLIGHTIAsyncResult Begin_Upload(AsyncCallback callback, object state, byte[] data);string End_Upload(IAsyncResult asyncResult);
#endifbyte[] Download(string path);
#if SILVERLIGHTIAsyncResult Begin_Download(AsyncCallback callback, object state, string path);byte[] End_Download(IAsyncResult asyncResult);
#endifbool Remove(string path);
#if SILVERLIGHTIAsyncResult Begin_Remove(AsyncCallback callback, object state, string path);bool End_Remove(IAsyncResult asyncResult);
#endif}public class Client : IDisposable, Iface{public Client(TProtocol prot) : this(prot, prot){}public Client(TProtocol iprot, TProtocol oprot){iprot_ = iprot;oprot_ = oprot;}protected TProtocol iprot_;protected TProtocol oprot_;protected int seqid_;public TProtocol InputProtocol{get { return iprot_; }}public TProtocol OutputProtocol{get { return oprot_; }}#region " IDisposable Support "private bool _IsDisposed;// IDisposablepublic void Dispose(){Dispose(true);}protected virtual void Dispose(bool disposing){if (!_IsDisposed){if (disposing){if (iprot_ != null){((IDisposable)iprot_).Dispose();}if (oprot_ != null){((IDisposable)oprot_).Dispose();}}}_IsDisposed = true;}#endregion#if SILVERLIGHTpublic IAsyncResult Begin_Upload(AsyncCallback callback, object state, byte[] data){return send_Upload(callback, state, data);}public string End_Upload(IAsyncResult asyncResult){oprot_.Transport.EndFlush(asyncResult);return recv_Upload();}#endifpublic string Upload(byte[] data){
#if !SILVERLIGHTsend_Upload(data);return recv_Upload();#elsevar asyncResult = Begin_Upload(null, null, data);return End_Upload(asyncResult);#endif}
#if SILVERLIGHTpublic IAsyncResult send_Upload(AsyncCallback callback, object state, byte[] data)
#elsepublic void send_Upload(byte[] data)
#endif{oprot_.WriteMessageBegin(new TMessage("Upload", TMessageType.Call, seqid_));Upload_args args = new Upload_args();args.Data = data;args.Write(oprot_);oprot_.WriteMessageEnd();
#if SILVERLIGHTreturn oprot_.Transport.BeginFlush(callback, state);
#elseoprot_.Transport.Flush();
#endif}public string recv_Upload(){TMessage msg = iprot_.ReadMessageBegin();if (msg.Type == TMessageType.Exception){TApplicationException x = TApplicationException.Read(iprot_);iprot_.ReadMessageEnd();throw x;}Upload_result result = new Upload_result();result.Read(iprot_);iprot_.ReadMessageEnd();if (result.__isset.success){return result.Success;}throw new TApplicationException(TApplicationException.ExceptionType.MissingResult, "Upload failed: unknown result");}#if SILVERLIGHTpublic IAsyncResult Begin_Download(AsyncCallback callback, object state, string path){return send_Download(callback, state, path);}public byte[] End_Download(IAsyncResult asyncResult){oprot_.Transport.EndFlush(asyncResult);return recv_Download();}#endifpublic byte[] Download(string path){
#if !SILVERLIGHTsend_Download(path);return recv_Download();#elsevar asyncResult = Begin_Download(null, null, path);return End_Download(asyncResult);#endif}
#if SILVERLIGHTpublic IAsyncResult send_Download(AsyncCallback callback, object state, string path)
#elsepublic void send_Download(string path)
#endif{oprot_.WriteMessageBegin(new TMessage("Download", TMessageType.Call, seqid_));Download_args args = new Download_args();args.Path = path;args.Write(oprot_);oprot_.WriteMessageEnd();
#if SILVERLIGHTreturn oprot_.Transport.BeginFlush(callback, state);
#elseoprot_.Transport.Flush();
#endif}public byte[] recv_Download(){TMessage msg = iprot_.ReadMessageBegin();if (msg.Type == TMessageType.Exception){TApplicationException x = TApplicationException.Read(iprot_);iprot_.ReadMessageEnd();throw x;}Download_result result = new Download_result();result.Read(iprot_);iprot_.ReadMessageEnd();if (result.__isset.success){return result.Success;}throw new TApplicationException(TApplicationException.ExceptionType.MissingResult, "Download failed: unknown result");}#if SILVERLIGHTpublic IAsyncResult Begin_Remove(AsyncCallback callback, object state, string path){return send_Remove(callback, state, path);}public bool End_Remove(IAsyncResult asyncResult){oprot_.Transport.EndFlush(asyncResult);return recv_Remove();}#endifpublic bool Remove(string path){
#if !SILVERLIGHTsend_Remove(path);return recv_Remove();#elsevar asyncResult = Begin_Remove(null, null, path);return End_Remove(asyncResult);#endif}
#if SILVERLIGHTpublic IAsyncResult send_Remove(AsyncCallback callback, object state, string path)
#elsepublic void send_Remove(string path)
#endif{oprot_.WriteMessageBegin(new TMessage("Remove", TMessageType.Call, seqid_));Remove_args args = new Remove_args();args.Path = path;args.Write(oprot_);oprot_.WriteMessageEnd();
#if SILVERLIGHTreturn oprot_.Transport.BeginFlush(callback, state);
#elseoprot_.Transport.Flush();
#endif}public bool recv_Remove(){TMessage msg = iprot_.ReadMessageBegin();if (msg.Type == TMessageType.Exception){TApplicationException x = TApplicationException.Read(iprot_);iprot_.ReadMessageEnd();throw x;}Remove_result result = new Remove_result();result.Read(iprot_);iprot_.ReadMessageEnd();if (result.__isset.success){return result.Success;}throw new TApplicationException(TApplicationException.ExceptionType.MissingResult, "Remove failed: unknown result");}}public class Processor : TProcessor{public Processor(Iface iface){iface_ = iface;processMap_["Upload"] = Upload_Process;processMap_["Download"] = Download_Process;processMap_["Remove"] = Remove_Process;}protected delegate void ProcessFunction(int seqid, TProtocol iprot, TProtocol oprot);private Iface iface_;protected Dictionary<string, ProcessFunction> processMap_ = new Dictionary<string, ProcessFunction>();public bool Process(TProtocol iprot, TProtocol oprot){try{TMessage msg = iprot.ReadMessageBegin();ProcessFunction fn;processMap_.TryGetValue(msg.Name, out fn);if (fn == null){TProtocolUtil.Skip(iprot, TType.Struct);iprot.ReadMessageEnd();TApplicationException x = new TApplicationException(TApplicationException.ExceptionType.UnknownMethod, "Invalid method name: '" + msg.Name + "'");oprot.WriteMessageBegin(new TMessage(msg.Name, TMessageType.Exception, msg.SeqID));x.Write(oprot);oprot.WriteMessageEnd();oprot.Transport.Flush();return true;}fn(msg.SeqID, iprot, oprot);}catch (IOException){return false;}return true;}public void Upload_Process(int seqid, TProtocol iprot, TProtocol oprot){Upload_args args = new Upload_args();args.Read(iprot);iprot.ReadMessageEnd();Upload_result result = new Upload_result();result.Success = iface_.Upload(args.Data);oprot.WriteMessageBegin(new TMessage("Upload", TMessageType.Reply, seqid));result.Write(oprot);oprot.WriteMessageEnd();oprot.Transport.Flush();}public void Download_Process(int seqid, TProtocol iprot, TProtocol oprot){Download_args args = new Download_args();args.Read(iprot);iprot.ReadMessageEnd();Download_result result = new Download_result();result.Success = iface_.Download(args.Path);oprot.WriteMessageBegin(new TMessage("Download", TMessageType.Reply, seqid));result.Write(oprot);oprot.WriteMessageEnd();oprot.Transport.Flush();}public void Remove_Process(int seqid, TProtocol iprot, TProtocol oprot){Remove_args args = new Remove_args();args.Read(iprot);iprot.ReadMessageEnd();Remove_result result = new Remove_result();result.Success = iface_.Remove(args.Path);oprot.WriteMessageBegin(new TMessage("Remove", TMessageType.Reply, seqid));result.Write(oprot);oprot.WriteMessageEnd();oprot.Transport.Flush();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Upload_args : TBase{private byte[] _data;public byte[] Data{get{return _data;}set{__isset.data = true;this._data = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool data;}public Upload_args(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 1:if (field.Type == TType.String){Data = iprot.ReadBinary();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Upload_args");oprot.WriteStructBegin(struc);TField field = new TField();if (Data != null && __isset.data){field.Name = "data";field.Type = TType.String;field.ID = 1;oprot.WriteFieldBegin(field);oprot.WriteBinary(Data);oprot.WriteFieldEnd();}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Upload_args(");sb.Append("Data: ");sb.Append(Data);sb.Append(")");return sb.ToString();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Upload_result : TBase{private string _success;public string Success{get{return _success;}set{__isset.success = true;this._success = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool success;}public Upload_result(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 0:if (field.Type == TType.String){Success = iprot.ReadString();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Upload_result");oprot.WriteStructBegin(struc);TField field = new TField();if (this.__isset.success){if (Success != null){field.Name = "Success";field.Type = TType.String;field.ID = 0;oprot.WriteFieldBegin(field);oprot.WriteString(Success);oprot.WriteFieldEnd();}}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Upload_result(");sb.Append("Success: ");sb.Append(Success);sb.Append(")");return sb.ToString();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Download_args : TBase{private string _path;public string Path{get{return _path;}set{__isset.path = true;this._path = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool path;}public Download_args(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 1:if (field.Type == TType.String){Path = iprot.ReadString();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Download_args");oprot.WriteStructBegin(struc);TField field = new TField();if (Path != null && __isset.path){field.Name = "path";field.Type = TType.String;field.ID = 1;oprot.WriteFieldBegin(field);oprot.WriteString(Path);oprot.WriteFieldEnd();}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Download_args(");sb.Append("Path: ");sb.Append(Path);sb.Append(")");return sb.ToString();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Download_result : TBase{private byte[] _success;public byte[] Success{get{return _success;}set{__isset.success = true;this._success = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool success;}public Download_result(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 0:if (field.Type == TType.String){Success = iprot.ReadBinary();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Download_result");oprot.WriteStructBegin(struc);TField field = new TField();if (this.__isset.success){if (Success != null){field.Name = "Success";field.Type = TType.String;field.ID = 0;oprot.WriteFieldBegin(field);oprot.WriteBinary(Success);oprot.WriteFieldEnd();}}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Download_result(");sb.Append("Success: ");sb.Append(Success);sb.Append(")");return sb.ToString();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Remove_args : TBase{private string _path;public string Path{get{return _path;}set{__isset.path = true;this._path = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool path;}public Remove_args(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 1:if (field.Type == TType.String){Path = iprot.ReadString();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Remove_args");oprot.WriteStructBegin(struc);TField field = new TField();if (Path != null && __isset.path){field.Name = "path";field.Type = TType.String;field.ID = 1;oprot.WriteFieldBegin(field);oprot.WriteString(Path);oprot.WriteFieldEnd();}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Remove_args(");sb.Append("Path: ");sb.Append(Path);sb.Append(")");return sb.ToString();}}#if !SILVERLIGHT[Serializable]
#endifpublic partial class Remove_result : TBase{private bool _success;public bool Success{get{return _success;}set{__isset.success = true;this._success = value;}}public Isset __isset;
#if !SILVERLIGHT[Serializable]
#endifpublic struct Isset{public bool success;}public Remove_result(){}public void Read(TProtocol iprot){TField field;iprot.ReadStructBegin();while (true){field = iprot.ReadFieldBegin();if (field.Type == TType.Stop){break;}switch (field.ID){case 0:if (field.Type == TType.Bool){Success = iprot.ReadBool();}else{TProtocolUtil.Skip(iprot, field.Type);}break;default:TProtocolUtil.Skip(iprot, field.Type);break;}iprot.ReadFieldEnd();}iprot.ReadStructEnd();}public void Write(TProtocol oprot){TStruct struc = new TStruct("Remove_result");oprot.WriteStructBegin(struc);TField field = new TField();if (this.__isset.success){field.Name = "Success";field.Type = TType.Bool;field.ID = 0;oprot.WriteFieldBegin(field);oprot.WriteBool(Success);oprot.WriteFieldEnd();}oprot.WriteFieldStop();oprot.WriteStructEnd();}public override string ToString(){StringBuilder sb = new StringBuilder("Remove_result(");sb.Append("Success: ");sb.Append(Success);sb.Append(")");return sb.ToString();}}}

View Code

《2》封装一个简单的CURD操作

  1     public class ThriftSHelper
  2     {
  3         private static string fastdfs = ConfigurationManager.AppSettings["fastdfs"];
  4
  5         TTransport transport = null;
  6         TProtocol protocol = null;
  7         ThriftService.Client client = null;
  8
  9         public ThriftSHelper()
 10         {
 11             var arr = fastdfs.Split(':');
 12             var host = arr[0];
 13             var port = Convert.ToInt32(arr[1]);
 14
 15             transport = new TSocket(host, port);
 16             protocol = new TBinaryProtocol(transport);
 17             client = new ThriftService.Client(protocol);
 18         }
 19
 20         public static ThriftSHelper Create()
 21         {
 22             return new ThriftSHelper();
 23         }
 24
 25         public string UploadFile(BitArray bit)
 26         {
 27             string path = string.Empty;
 28
 29             try
 30             {
 31                 var bytes = new byte[Convert.ToInt32(Math.Ceiling((double)bit.Length / 8))];
 32
 33                 transport.Open();
 34
 35                 bit.CopyTo(bytes, 0);
 36
 37                 path = client.Upload(bytes);
 38             }
 39             catch (Exception ex)
 40             {
 41                 LogHelper.Error(ex);
 42             }
 43             finally
 44             {
 45                 transport.Close();
 46             }
 47
 48             return path;
 49         }
 50
 51         /// <summary>
 52         /// 下载文件
 53         /// </summary>
 54         /// <param name="fileName"></param>
 55         /// <returns></returns>
 56         public BitArray DownloadFile(string fileName)
 57         {
 58             BitArray bitArray = null;
 59
 60             try
 61             {
 62                 transport.Open();
 63
 64                 var bytes = client.Download(fileName);
 65
 66                 return new BitArray(bytes);
 67             }
 68             catch (Exception ex)
 69             {
 70                 LogHelper.WriteLog(fileName, ex);
 71             }
 72             finally
 73             {
 74                 transport.Close();
 75             }
 76
 77             return bitArray;
 78         }
 79
 80         /// <summary>
 81         /// 删除文件
 82         /// </summary>
 83         /// <param name="fileName"></param>
 84         public void RemoveFile(string fileName)
 85         {
 86             try
 87             {
 88                 transport.Open();
 89
 90                 client.Remove(fileName);
 91             }
 92             catch (Exception ex)
 93             {
 94                 LogHelper.WriteLog(ex);
 95             }
 96             finally
 97             {
 98                 transport.Close();
 99             }
100         }
101     }

　　好了，这个问题我们就这样完美解决了，跑在生产上还是蛮好的。

posted on 2018-05-24 23:07 NET未来之路阅读(...) 评论(...) 编辑收藏

转载于:https://www.cnblogs.com/lonelyxmas/p/9085755.html

吐槽net下没有靠谱的FastDFS的sdk之使用thrift实现JAVA和C#互通相关推荐

基于SpringBoot下使用分布式文件存储FastDFS
一.FastDFS简介 1.1 FastDFS体系结构 FastDFS是一个开源的轻量级分布式文件系统,它对文件进行管理,功能包括:文件存储.文件同步.文件访问(文件上传.文件下载)等,解决了大容量存 ...
CentOS 7.5下搭建高可用的FastDFS分布式文件系统
FastDFS是一个开源的轻量级分布式文件系统,由跟踪服务器(tracker server).存储服务器(storage server)和客户端(client)三个部分组成,主要解决了海量数据存储问题 ...
Docker容器下Redis/ES/RabbitMQ/MongoDB/FastDFS启动命令总结
docker 部署etcd Etcd:一个分布式的k-v存储服务 Etcd官网https://etcd.io/ etcd安装 1. 拉取bitnami/etcd镜像 docker pull bitna ...
MATLAB环境下基于包络谱和谱峭度的一维振动信号分析
依旧是信号处理相关的东西,本文再次讲解如何应用包络谱和谱峭度分析一维振动信号进而诊断轴承故障,运行环境为MATLAB R2021B. 面包多第三方代码:
在Ubuntu下最靠谱的键位修改方法 ,亲测有效
本人刚入坑linux不久,我一直在windows下工作,同样linux我也当成windows来玩,也常有改键位的需求,我曾经百度无数改键位的方法,要么就是只能改左边的ctrol和大小写键交换,右边的a ...
服务器系统刂金苹果-下拉靠谱,百度快速排名礻金苹果实力刂:奶牛镇的小时光花菇喜欢什么花菇好感度怎么加...
奶牛镇的小时光中送礼给NPC可以增加NPC好感度,达到一定好百度竞价推广怎么优化感还能跟NPC谈恋爱.那么奶牛镇的花菇喜欢什么礼物呢,下面小seo公众微信号编就给大家带来花菇送礼攻略. 注意:每周好感 ...
java文章上一篇下一篇_每个人都必须阅读的10篇Java文章
java文章上一篇下一篇一个月前,我们发布了每个人都必须阅读的10篇SQL文章列表. 我们相信jOOQ博客上的文章列表将为我们的读者带来非凡的价值. jOOQ博客是一个专注于Java和SQL的博客, ...
什么是环境变量？环境变量配置，jdk8的path环境变量配置，各个版本下jdk结构的变化以及环境变量配置的阐述，java命令执行三个不同目录下的java.exe说明
说明:如果只想配置java中jdk的path环境变量直接跳到三即可. 一,什么是环境变量? 一般是指在操作系统中用来指定操作系统运行环境的一些参数:如文件夹的位置. 环境变量是在操作系统中是一个特定名 ...
android在java下建立模块,Android Studio：如何在Android模块中包含Java模块？
在Android工作室我有一个Android模块,我们称之为MyAndroid.我还有一个Java模块(不是独立的JAR,而是模块中的完整Java项目),我们称之为MyJava.Android Stu ...

吐槽net下没有靠谱的FastDFS的sdk之使用thrift实现JAVA和C#互通

吐槽net下没有靠谱的FastDFS的sdk之使用thrift实现JAVA和C#互通相关推荐

最新文章

热门文章