homepage recommend

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/Hello.java

@@ -1,62 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-public final class Hello {
-  private Hello() {}
-  public static void registerAllExtensions(
-      com.google.protobuf.ExtensionRegistryLite registry) {
-  }
-
-  public static void registerAllExtensions(
-      com.google.protobuf.ExtensionRegistry registry) {
-    registerAllExtensions(
-        (com.google.protobuf.ExtensionRegistryLite) registry);
-  }
-  static final com.google.protobuf.Descriptors.Descriptor
-    internal_static_HelloRequest_descriptor;
-  static final 
-    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-      internal_static_HelloRequest_fieldAccessorTable;
-  static final com.google.protobuf.Descriptors.Descriptor
-    internal_static_HelloResponse_descriptor;
-  static final 
-    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-      internal_static_HelloResponse_fieldAccessorTable;
-
-  public static com.google.protobuf.Descriptors.FileDescriptor
-      getDescriptor() {
-    return descriptor;
-  }
-  private static  com.google.protobuf.Descriptors.FileDescriptor
-      descriptor;
-  static {
-    java.lang.String[] descriptorData = {
-      "\n.com/tzld/piaoquan/recommend/server/hel" +
-      "lo.proto\" \n\014HelloRequest\022\020\n\010greeting\030\001 \001" +
-      "(\t\"\036\n\rHelloResponse\022\r\n\005reply\030\001 \001(\t29\n\014He" +
-      "lloService\022)\n\010SayHello\022\r.HelloRequest\032\016." +
-      "HelloResponseB2\n+com.tzld.piaoquan.recom" +
-      "mend.server.gen.demoP\001\210\001\001b\006proto3"
-    };
-    descriptor = com.google.protobuf.Descriptors.FileDescriptor
-      .internalBuildGeneratedFileFrom(descriptorData,
-        new com.google.protobuf.Descriptors.FileDescriptor[] {
-        });
-    internal_static_HelloRequest_descriptor =
-      getDescriptor().getMessageTypes().get(0);
-    internal_static_HelloRequest_fieldAccessorTable = new
-      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
-        internal_static_HelloRequest_descriptor,
-        new java.lang.String[] { "Greeting", });
-    internal_static_HelloResponse_descriptor =
-      getDescriptor().getMessageTypes().get(1);
-    internal_static_HelloResponse_fieldAccessorTable = new
-      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
-        internal_static_HelloResponse_descriptor,
-        new java.lang.String[] { "Reply", });
-  }
-
-  // @@protoc_insertion_point(outer_class_scope)
-}

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloRequest.java

@@ -1,557 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-/**
- * Protobuf type {@code HelloRequest}
- */
-public final class HelloRequest extends
-    com.google.protobuf.GeneratedMessageV3 implements
-    // @@protoc_insertion_point(message_implements:HelloRequest)
-    HelloRequestOrBuilder {
-private static final long serialVersionUID = 0L;
-  // Use HelloRequest.newBuilder() to construct.
-  private HelloRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
-    super(builder);
-  }
-  private HelloRequest() {
-    greeting_ = "";
-  }
-
-  @java.lang.Override
-  @SuppressWarnings({"unused"})
-  protected java.lang.Object newInstance(
-      UnusedPrivateParameter unused) {
-    return new HelloRequest();
-  }
-
-  @java.lang.Override
-  public final com.google.protobuf.UnknownFieldSet
-  getUnknownFields() {
-    return this.unknownFields;
-  }
-  private HelloRequest(
-      com.google.protobuf.CodedInputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    this();
-    if (extensionRegistry == null) {
-      throw new java.lang.NullPointerException();
-    }
-    com.google.protobuf.UnknownFieldSet.Builder unknownFields =
-        com.google.protobuf.UnknownFieldSet.newBuilder();
-    try {
-      boolean done = false;
-      while (!done) {
-        int tag = input.readTag();
-        switch (tag) {
-          case 0:
-            done = true;
-            break;
-          case 10: {
-            java.lang.String s = input.readStringRequireUtf8();
-
-            greeting_ = s;
-            break;
-          }
-          default: {
-            if (!parseUnknownField(
-                input, unknownFields, extensionRegistry, tag)) {
-              done = true;
-            }
-            break;
-          }
-        }
-      }
-    } catch (com.google.protobuf.InvalidProtocolBufferException e) {
-      throw e.setUnfinishedMessage(this);
-    } catch (java.io.IOException e) {
-      throw new com.google.protobuf.InvalidProtocolBufferException(
-          e).setUnfinishedMessage(this);
-    } finally {
-      this.unknownFields = unknownFields.build();
-      makeExtensionsImmutable();
-    }
-  }
-  public static final com.google.protobuf.Descriptors.Descriptor
-      getDescriptor() {
-    return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloRequest_descriptor;
-  }
-
-  @java.lang.Override
-  protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-      internalGetFieldAccessorTable() {
-    return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloRequest_fieldAccessorTable
-        .ensureFieldAccessorsInitialized(
-            com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.class, com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.Builder.class);
-  }
-
-  public static final int GREETING_FIELD_NUMBER = 1;
-  private volatile java.lang.Object greeting_;
-  /**
-   * <code>string greeting = 1;</code>
-   * @return The greeting.
-   */
-  @java.lang.Override
-  public java.lang.String getGreeting() {
-    java.lang.Object ref = greeting_;
-    if (ref instanceof java.lang.String) {
-      return (java.lang.String) ref;
-    } else {
-      com.google.protobuf.ByteString bs = 
-          (com.google.protobuf.ByteString) ref;
-      java.lang.String s = bs.toStringUtf8();
-      greeting_ = s;
-      return s;
-    }
-  }
-  /**
-   * <code>string greeting = 1;</code>
-   * @return The bytes for greeting.
-   */
-  @java.lang.Override
-  public com.google.protobuf.ByteString
-      getGreetingBytes() {
-    java.lang.Object ref = greeting_;
-    if (ref instanceof java.lang.String) {
-      com.google.protobuf.ByteString b = 
-          com.google.protobuf.ByteString.copyFromUtf8(
-              (java.lang.String) ref);
-      greeting_ = b;
-      return b;
-    } else {
-      return (com.google.protobuf.ByteString) ref;
-    }
-  }
-
-  private byte memoizedIsInitialized = -1;
-  @java.lang.Override
-  public final boolean isInitialized() {
-    byte isInitialized = memoizedIsInitialized;
-    if (isInitialized == 1) return true;
-    if (isInitialized == 0) return false;
-
-    memoizedIsInitialized = 1;
-    return true;
-  }
-
-  @java.lang.Override
-  public void writeTo(com.google.protobuf.CodedOutputStream output)
-                      throws java.io.IOException {
-    if (!getGreetingBytes().isEmpty()) {
-      com.google.protobuf.GeneratedMessageV3.writeString(output, 1, greeting_);
-    }
-    unknownFields.writeTo(output);
-  }
-
-  @java.lang.Override
-  public int getSerializedSize() {
-    int size = memoizedSize;
-    if (size != -1) return size;
-
-    size = 0;
-    if (!getGreetingBytes().isEmpty()) {
-      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, greeting_);
-    }
-    size += unknownFields.getSerializedSize();
-    memoizedSize = size;
-    return size;
-  }
-
-  @java.lang.Override
-  public boolean equals(final java.lang.Object obj) {
-    if (obj == this) {
-     return true;
-    }
-    if (!(obj instanceof com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest)) {
-      return super.equals(obj);
-    }
-    com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest other = (com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest) obj;
-
-    if (!getGreeting()
-        .equals(other.getGreeting())) return false;
-    if (!unknownFields.equals(other.unknownFields)) return false;
-    return true;
-  }
-
-  @java.lang.Override
-  public int hashCode() {
-    if (memoizedHashCode != 0) {
-      return memoizedHashCode;
-    }
-    int hash = 41;
-    hash = (19 * hash) + getDescriptor().hashCode();
-    hash = (37 * hash) + GREETING_FIELD_NUMBER;
-    hash = (53 * hash) + getGreeting().hashCode();
-    hash = (29 * hash) + unknownFields.hashCode();
-    memoizedHashCode = hash;
-    return hash;
-  }
-
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      java.nio.ByteBuffer data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      java.nio.ByteBuffer data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      com.google.protobuf.ByteString data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      com.google.protobuf.ByteString data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(byte[] data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      byte[] data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(java.io.InputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      java.io.InputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseDelimitedFrom(java.io.InputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseDelimitedWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseDelimitedFrom(
-      java.io.InputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      com.google.protobuf.CodedInputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parseFrom(
-      com.google.protobuf.CodedInputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input, extensionRegistry);
-  }
-
-  @java.lang.Override
-  public Builder newBuilderForType() { return newBuilder(); }
-  public static Builder newBuilder() {
-    return DEFAULT_INSTANCE.toBuilder();
-  }
-  public static Builder newBuilder(com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest prototype) {
-    return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
-  }
-  @java.lang.Override
-  public Builder toBuilder() {
-    return this == DEFAULT_INSTANCE
-        ? new Builder() : new Builder().mergeFrom(this);
-  }
-
-  @java.lang.Override
-  protected Builder newBuilderForType(
-      com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
-    Builder builder = new Builder(parent);
-    return builder;
-  }
-  /**
-   * Protobuf type {@code HelloRequest}
-   */
-  public static final class Builder extends
-      com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
-      // @@protoc_insertion_point(builder_implements:HelloRequest)
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloRequestOrBuilder {
-    public static final com.google.protobuf.Descriptors.Descriptor
-        getDescriptor() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloRequest_descriptor;
-    }
-
-    @java.lang.Override
-    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-        internalGetFieldAccessorTable() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloRequest_fieldAccessorTable
-          .ensureFieldAccessorsInitialized(
-              com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.class, com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.Builder.class);
-    }
-
-    // Construct using com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.newBuilder()
-    private Builder() {
-      maybeForceBuilderInitialization();
-    }
-
-    private Builder(
-        com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
-      super(parent);
-      maybeForceBuilderInitialization();
-    }
-    private void maybeForceBuilderInitialization() {
-      if (com.google.protobuf.GeneratedMessageV3
-              .alwaysUseFieldBuilders) {
-      }
-    }
-    @java.lang.Override
-    public Builder clear() {
-      super.clear();
-      greeting_ = "";
-
-      return this;
-    }
-
-    @java.lang.Override
-    public com.google.protobuf.Descriptors.Descriptor
-        getDescriptorForType() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloRequest_descriptor;
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest getDefaultInstanceForType() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.getDefaultInstance();
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest build() {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest result = buildPartial();
-      if (!result.isInitialized()) {
-        throw newUninitializedMessageException(result);
-      }
-      return result;
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest buildPartial() {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest result = new com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest(this);
-      result.greeting_ = greeting_;
-      onBuilt();
-      return result;
-    }
-
-    @java.lang.Override
-    public Builder clone() {
-      return super.clone();
-    }
-    @java.lang.Override
-    public Builder setField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        java.lang.Object value) {
-      return super.setField(field, value);
-    }
-    @java.lang.Override
-    public Builder clearField(
-        com.google.protobuf.Descriptors.FieldDescriptor field) {
-      return super.clearField(field);
-    }
-    @java.lang.Override
-    public Builder clearOneof(
-        com.google.protobuf.Descriptors.OneofDescriptor oneof) {
-      return super.clearOneof(oneof);
-    }
-    @java.lang.Override
-    public Builder setRepeatedField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        int index, java.lang.Object value) {
-      return super.setRepeatedField(field, index, value);
-    }
-    @java.lang.Override
-    public Builder addRepeatedField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        java.lang.Object value) {
-      return super.addRepeatedField(field, value);
-    }
-    @java.lang.Override
-    public Builder mergeFrom(com.google.protobuf.Message other) {
-      if (other instanceof com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest) {
-        return mergeFrom((com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest)other);
-      } else {
-        super.mergeFrom(other);
-        return this;
-      }
-    }
-
-    public Builder mergeFrom(com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest other) {
-      if (other == com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.getDefaultInstance()) return this;
-      if (!other.getGreeting().isEmpty()) {
-        greeting_ = other.greeting_;
-        onChanged();
-      }
-      this.mergeUnknownFields(other.unknownFields);
-      onChanged();
-      return this;
-    }
-
-    @java.lang.Override
-    public final boolean isInitialized() {
-      return true;
-    }
-
-    @java.lang.Override
-    public Builder mergeFrom(
-        com.google.protobuf.CodedInputStream input,
-        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-        throws java.io.IOException {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest parsedMessage = null;
-      try {
-        parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
-      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
-        parsedMessage = (com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest) e.getUnfinishedMessage();
-        throw e.unwrapIOException();
-      } finally {
-        if (parsedMessage != null) {
-          mergeFrom(parsedMessage);
-        }
-      }
-      return this;
-    }
-
-    private java.lang.Object greeting_ = "";
-    /**
-     * <code>string greeting = 1;</code>
-     * @return The greeting.
-     */
-    public java.lang.String getGreeting() {
-      java.lang.Object ref = greeting_;
-      if (!(ref instanceof java.lang.String)) {
-        com.google.protobuf.ByteString bs =
-            (com.google.protobuf.ByteString) ref;
-        java.lang.String s = bs.toStringUtf8();
-        greeting_ = s;
-        return s;
-      } else {
-        return (java.lang.String) ref;
-      }
-    }
-    /**
-     * <code>string greeting = 1;</code>
-     * @return The bytes for greeting.
-     */
-    public com.google.protobuf.ByteString
-        getGreetingBytes() {
-      java.lang.Object ref = greeting_;
-      if (ref instanceof String) {
-        com.google.protobuf.ByteString b = 
-            com.google.protobuf.ByteString.copyFromUtf8(
-                (java.lang.String) ref);
-        greeting_ = b;
-        return b;
-      } else {
-        return (com.google.protobuf.ByteString) ref;
-      }
-    }
-    /**
-     * <code>string greeting = 1;</code>
-     * @param value The greeting to set.
-     * @return This builder for chaining.
-     */
-    public Builder setGreeting(
-        java.lang.String value) {
-      if (value == null) {
-    throw new NullPointerException();
-  }
-  
-      greeting_ = value;
-      onChanged();
-      return this;
-    }
-    /**
-     * <code>string greeting = 1;</code>
-     * @return This builder for chaining.
-     */
-    public Builder clearGreeting() {
-      
-      greeting_ = getDefaultInstance().getGreeting();
-      onChanged();
-      return this;
-    }
-    /**
-     * <code>string greeting = 1;</code>
-     * @param value The bytes for greeting to set.
-     * @return This builder for chaining.
-     */
-    public Builder setGreetingBytes(
-        com.google.protobuf.ByteString value) {
-      if (value == null) {
-    throw new NullPointerException();
-  }
-  checkByteStringIsUtf8(value);
-      
-      greeting_ = value;
-      onChanged();
-      return this;
-    }
-    @java.lang.Override
-    public final Builder setUnknownFields(
-        final com.google.protobuf.UnknownFieldSet unknownFields) {
-      return super.setUnknownFields(unknownFields);
-    }
-
-    @java.lang.Override
-    public final Builder mergeUnknownFields(
-        final com.google.protobuf.UnknownFieldSet unknownFields) {
-      return super.mergeUnknownFields(unknownFields);
-    }
-
-
-    // @@protoc_insertion_point(builder_scope:HelloRequest)
-  }
-
-  // @@protoc_insertion_point(class_scope:HelloRequest)
-  private static final com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest DEFAULT_INSTANCE;
-  static {
-    DEFAULT_INSTANCE = new com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest();
-  }
-
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest getDefaultInstance() {
-    return DEFAULT_INSTANCE;
-  }
-
-  private static final com.google.protobuf.Parser<HelloRequest>
-      PARSER = new com.google.protobuf.AbstractParser<HelloRequest>() {
-    @java.lang.Override
-    public HelloRequest parsePartialFrom(
-        com.google.protobuf.CodedInputStream input,
-        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-        throws com.google.protobuf.InvalidProtocolBufferException {
-      return new HelloRequest(input, extensionRegistry);
-    }
-  };
-
-  public static com.google.protobuf.Parser<HelloRequest> parser() {
-    return PARSER;
-  }
-
-  @java.lang.Override
-  public com.google.protobuf.Parser<HelloRequest> getParserForType() {
-    return PARSER;
-  }
-
-  @java.lang.Override
-  public com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest getDefaultInstanceForType() {
-    return DEFAULT_INSTANCE;
-  }
-
-}
-

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloRequestOrBuilder.java

@@ -1,21 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-public interface HelloRequestOrBuilder extends
-    // @@protoc_insertion_point(interface_extends:HelloRequest)
-    com.google.protobuf.MessageOrBuilder {
-
-  /**
-   * <code>string greeting = 1;</code>
-   * @return The greeting.
-   */
-  java.lang.String getGreeting();
-  /**
-   * <code>string greeting = 1;</code>
-   * @return The bytes for greeting.
-   */
-  com.google.protobuf.ByteString
-      getGreetingBytes();
-}

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloResponse.java

@@ -1,557 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-/**
- * Protobuf type {@code HelloResponse}
- */
-public final class HelloResponse extends
-    com.google.protobuf.GeneratedMessageV3 implements
-    // @@protoc_insertion_point(message_implements:HelloResponse)
-    HelloResponseOrBuilder {
-private static final long serialVersionUID = 0L;
-  // Use HelloResponse.newBuilder() to construct.
-  private HelloResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
-    super(builder);
-  }
-  private HelloResponse() {
-    reply_ = "";
-  }
-
-  @java.lang.Override
-  @SuppressWarnings({"unused"})
-  protected java.lang.Object newInstance(
-      UnusedPrivateParameter unused) {
-    return new HelloResponse();
-  }
-
-  @java.lang.Override
-  public final com.google.protobuf.UnknownFieldSet
-  getUnknownFields() {
-    return this.unknownFields;
-  }
-  private HelloResponse(
-      com.google.protobuf.CodedInputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    this();
-    if (extensionRegistry == null) {
-      throw new java.lang.NullPointerException();
-    }
-    com.google.protobuf.UnknownFieldSet.Builder unknownFields =
-        com.google.protobuf.UnknownFieldSet.newBuilder();
-    try {
-      boolean done = false;
-      while (!done) {
-        int tag = input.readTag();
-        switch (tag) {
-          case 0:
-            done = true;
-            break;
-          case 10: {
-            java.lang.String s = input.readStringRequireUtf8();
-
-            reply_ = s;
-            break;
-          }
-          default: {
-            if (!parseUnknownField(
-                input, unknownFields, extensionRegistry, tag)) {
-              done = true;
-            }
-            break;
-          }
-        }
-      }
-    } catch (com.google.protobuf.InvalidProtocolBufferException e) {
-      throw e.setUnfinishedMessage(this);
-    } catch (java.io.IOException e) {
-      throw new com.google.protobuf.InvalidProtocolBufferException(
-          e).setUnfinishedMessage(this);
-    } finally {
-      this.unknownFields = unknownFields.build();
-      makeExtensionsImmutable();
-    }
-  }
-  public static final com.google.protobuf.Descriptors.Descriptor
-      getDescriptor() {
-    return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloResponse_descriptor;
-  }
-
-  @java.lang.Override
-  protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-      internalGetFieldAccessorTable() {
-    return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloResponse_fieldAccessorTable
-        .ensureFieldAccessorsInitialized(
-            com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.class, com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.Builder.class);
-  }
-
-  public static final int REPLY_FIELD_NUMBER = 1;
-  private volatile java.lang.Object reply_;
-  /**
-   * <code>string reply = 1;</code>
-   * @return The reply.
-   */
-  @java.lang.Override
-  public java.lang.String getReply() {
-    java.lang.Object ref = reply_;
-    if (ref instanceof java.lang.String) {
-      return (java.lang.String) ref;
-    } else {
-      com.google.protobuf.ByteString bs = 
-          (com.google.protobuf.ByteString) ref;
-      java.lang.String s = bs.toStringUtf8();
-      reply_ = s;
-      return s;
-    }
-  }
-  /**
-   * <code>string reply = 1;</code>
-   * @return The bytes for reply.
-   */
-  @java.lang.Override
-  public com.google.protobuf.ByteString
-      getReplyBytes() {
-    java.lang.Object ref = reply_;
-    if (ref instanceof java.lang.String) {
-      com.google.protobuf.ByteString b = 
-          com.google.protobuf.ByteString.copyFromUtf8(
-              (java.lang.String) ref);
-      reply_ = b;
-      return b;
-    } else {
-      return (com.google.protobuf.ByteString) ref;
-    }
-  }
-
-  private byte memoizedIsInitialized = -1;
-  @java.lang.Override
-  public final boolean isInitialized() {
-    byte isInitialized = memoizedIsInitialized;
-    if (isInitialized == 1) return true;
-    if (isInitialized == 0) return false;
-
-    memoizedIsInitialized = 1;
-    return true;
-  }
-
-  @java.lang.Override
-  public void writeTo(com.google.protobuf.CodedOutputStream output)
-                      throws java.io.IOException {
-    if (!getReplyBytes().isEmpty()) {
-      com.google.protobuf.GeneratedMessageV3.writeString(output, 1, reply_);
-    }
-    unknownFields.writeTo(output);
-  }
-
-  @java.lang.Override
-  public int getSerializedSize() {
-    int size = memoizedSize;
-    if (size != -1) return size;
-
-    size = 0;
-    if (!getReplyBytes().isEmpty()) {
-      size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, reply_);
-    }
-    size += unknownFields.getSerializedSize();
-    memoizedSize = size;
-    return size;
-  }
-
-  @java.lang.Override
-  public boolean equals(final java.lang.Object obj) {
-    if (obj == this) {
-     return true;
-    }
-    if (!(obj instanceof com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse)) {
-      return super.equals(obj);
-    }
-    com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse other = (com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse) obj;
-
-    if (!getReply()
-        .equals(other.getReply())) return false;
-    if (!unknownFields.equals(other.unknownFields)) return false;
-    return true;
-  }
-
-  @java.lang.Override
-  public int hashCode() {
-    if (memoizedHashCode != 0) {
-      return memoizedHashCode;
-    }
-    int hash = 41;
-    hash = (19 * hash) + getDescriptor().hashCode();
-    hash = (37 * hash) + REPLY_FIELD_NUMBER;
-    hash = (53 * hash) + getReply().hashCode();
-    hash = (29 * hash) + unknownFields.hashCode();
-    memoizedHashCode = hash;
-    return hash;
-  }
-
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      java.nio.ByteBuffer data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      java.nio.ByteBuffer data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      com.google.protobuf.ByteString data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      com.google.protobuf.ByteString data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(byte[] data)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      byte[] data,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws com.google.protobuf.InvalidProtocolBufferException {
-    return PARSER.parseFrom(data, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(java.io.InputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      java.io.InputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseDelimitedFrom(java.io.InputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseDelimitedWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseDelimitedFrom(
-      java.io.InputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      com.google.protobuf.CodedInputStream input)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input);
-  }
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parseFrom(
-      com.google.protobuf.CodedInputStream input,
-      com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-      throws java.io.IOException {
-    return com.google.protobuf.GeneratedMessageV3
-        .parseWithIOException(PARSER, input, extensionRegistry);
-  }
-
-  @java.lang.Override
-  public Builder newBuilderForType() { return newBuilder(); }
-  public static Builder newBuilder() {
-    return DEFAULT_INSTANCE.toBuilder();
-  }
-  public static Builder newBuilder(com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse prototype) {
-    return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
-  }
-  @java.lang.Override
-  public Builder toBuilder() {
-    return this == DEFAULT_INSTANCE
-        ? new Builder() : new Builder().mergeFrom(this);
-  }
-
-  @java.lang.Override
-  protected Builder newBuilderForType(
-      com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
-    Builder builder = new Builder(parent);
-    return builder;
-  }
-  /**
-   * Protobuf type {@code HelloResponse}
-   */
-  public static final class Builder extends
-      com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
-      // @@protoc_insertion_point(builder_implements:HelloResponse)
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponseOrBuilder {
-    public static final com.google.protobuf.Descriptors.Descriptor
-        getDescriptor() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloResponse_descriptor;
-    }
-
-    @java.lang.Override
-    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
-        internalGetFieldAccessorTable() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloResponse_fieldAccessorTable
-          .ensureFieldAccessorsInitialized(
-              com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.class, com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.Builder.class);
-    }
-
-    // Construct using com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.newBuilder()
-    private Builder() {
-      maybeForceBuilderInitialization();
-    }
-
-    private Builder(
-        com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
-      super(parent);
-      maybeForceBuilderInitialization();
-    }
-    private void maybeForceBuilderInitialization() {
-      if (com.google.protobuf.GeneratedMessageV3
-              .alwaysUseFieldBuilders) {
-      }
-    }
-    @java.lang.Override
-    public Builder clear() {
-      super.clear();
-      reply_ = "";
-
-      return this;
-    }
-
-    @java.lang.Override
-    public com.google.protobuf.Descriptors.Descriptor
-        getDescriptorForType() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.internal_static_HelloResponse_descriptor;
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse getDefaultInstanceForType() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance();
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse build() {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse result = buildPartial();
-      if (!result.isInitialized()) {
-        throw newUninitializedMessageException(result);
-      }
-      return result;
-    }
-
-    @java.lang.Override
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse buildPartial() {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse result = new com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse(this);
-      result.reply_ = reply_;
-      onBuilt();
-      return result;
-    }
-
-    @java.lang.Override
-    public Builder clone() {
-      return super.clone();
-    }
-    @java.lang.Override
-    public Builder setField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        java.lang.Object value) {
-      return super.setField(field, value);
-    }
-    @java.lang.Override
-    public Builder clearField(
-        com.google.protobuf.Descriptors.FieldDescriptor field) {
-      return super.clearField(field);
-    }
-    @java.lang.Override
-    public Builder clearOneof(
-        com.google.protobuf.Descriptors.OneofDescriptor oneof) {
-      return super.clearOneof(oneof);
-    }
-    @java.lang.Override
-    public Builder setRepeatedField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        int index, java.lang.Object value) {
-      return super.setRepeatedField(field, index, value);
-    }
-    @java.lang.Override
-    public Builder addRepeatedField(
-        com.google.protobuf.Descriptors.FieldDescriptor field,
-        java.lang.Object value) {
-      return super.addRepeatedField(field, value);
-    }
-    @java.lang.Override
-    public Builder mergeFrom(com.google.protobuf.Message other) {
-      if (other instanceof com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse) {
-        return mergeFrom((com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse)other);
-      } else {
-        super.mergeFrom(other);
-        return this;
-      }
-    }
-
-    public Builder mergeFrom(com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse other) {
-      if (other == com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance()) return this;
-      if (!other.getReply().isEmpty()) {
-        reply_ = other.reply_;
-        onChanged();
-      }
-      this.mergeUnknownFields(other.unknownFields);
-      onChanged();
-      return this;
-    }
-
-    @java.lang.Override
-    public final boolean isInitialized() {
-      return true;
-    }
-
-    @java.lang.Override
-    public Builder mergeFrom(
-        com.google.protobuf.CodedInputStream input,
-        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-        throws java.io.IOException {
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse parsedMessage = null;
-      try {
-        parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
-      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
-        parsedMessage = (com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse) e.getUnfinishedMessage();
-        throw e.unwrapIOException();
-      } finally {
-        if (parsedMessage != null) {
-          mergeFrom(parsedMessage);
-        }
-      }
-      return this;
-    }
-
-    private java.lang.Object reply_ = "";
-    /**
-     * <code>string reply = 1;</code>
-     * @return The reply.
-     */
-    public java.lang.String getReply() {
-      java.lang.Object ref = reply_;
-      if (!(ref instanceof java.lang.String)) {
-        com.google.protobuf.ByteString bs =
-            (com.google.protobuf.ByteString) ref;
-        java.lang.String s = bs.toStringUtf8();
-        reply_ = s;
-        return s;
-      } else {
-        return (java.lang.String) ref;
-      }
-    }
-    /**
-     * <code>string reply = 1;</code>
-     * @return The bytes for reply.
-     */
-    public com.google.protobuf.ByteString
-        getReplyBytes() {
-      java.lang.Object ref = reply_;
-      if (ref instanceof String) {
-        com.google.protobuf.ByteString b = 
-            com.google.protobuf.ByteString.copyFromUtf8(
-                (java.lang.String) ref);
-        reply_ = b;
-        return b;
-      } else {
-        return (com.google.protobuf.ByteString) ref;
-      }
-    }
-    /**
-     * <code>string reply = 1;</code>
-     * @param value The reply to set.
-     * @return This builder for chaining.
-     */
-    public Builder setReply(
-        java.lang.String value) {
-      if (value == null) {
-    throw new NullPointerException();
-  }
-  
-      reply_ = value;
-      onChanged();
-      return this;
-    }
-    /**
-     * <code>string reply = 1;</code>
-     * @return This builder for chaining.
-     */
-    public Builder clearReply() {
-      
-      reply_ = getDefaultInstance().getReply();
-      onChanged();
-      return this;
-    }
-    /**
-     * <code>string reply = 1;</code>
-     * @param value The bytes for reply to set.
-     * @return This builder for chaining.
-     */
-    public Builder setReplyBytes(
-        com.google.protobuf.ByteString value) {
-      if (value == null) {
-    throw new NullPointerException();
-  }
-  checkByteStringIsUtf8(value);
-      
-      reply_ = value;
-      onChanged();
-      return this;
-    }
-    @java.lang.Override
-    public final Builder setUnknownFields(
-        final com.google.protobuf.UnknownFieldSet unknownFields) {
-      return super.setUnknownFields(unknownFields);
-    }
-
-    @java.lang.Override
-    public final Builder mergeUnknownFields(
-        final com.google.protobuf.UnknownFieldSet unknownFields) {
-      return super.mergeUnknownFields(unknownFields);
-    }
-
-
-    // @@protoc_insertion_point(builder_scope:HelloResponse)
-  }
-
-  // @@protoc_insertion_point(class_scope:HelloResponse)
-  private static final com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse DEFAULT_INSTANCE;
-  static {
-    DEFAULT_INSTANCE = new com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse();
-  }
-
-  public static com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse getDefaultInstance() {
-    return DEFAULT_INSTANCE;
-  }
-
-  private static final com.google.protobuf.Parser<HelloResponse>
-      PARSER = new com.google.protobuf.AbstractParser<HelloResponse>() {
-    @java.lang.Override
-    public HelloResponse parsePartialFrom(
-        com.google.protobuf.CodedInputStream input,
-        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
-        throws com.google.protobuf.InvalidProtocolBufferException {
-      return new HelloResponse(input, extensionRegistry);
-    }
-  };
-
-  public static com.google.protobuf.Parser<HelloResponse> parser() {
-    return PARSER;
-  }
-
-  @java.lang.Override
-  public com.google.protobuf.Parser<HelloResponse> getParserForType() {
-    return PARSER;
-  }
-
-  @java.lang.Override
-  public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse getDefaultInstanceForType() {
-    return DEFAULT_INSTANCE;
-  }
-
-}
-

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloResponseOrBuilder.java

@@ -1,21 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-public interface HelloResponseOrBuilder extends
-    // @@protoc_insertion_point(interface_extends:HelloResponse)
-    com.google.protobuf.MessageOrBuilder {
-
-  /**
-   * <code>string reply = 1;</code>
-   * @return The reply.
-   */
-  java.lang.String getReply();
-  /**
-   * <code>string reply = 1;</code>
-   * @return The bytes for reply.
-   */
-  com.google.protobuf.ByteString
-      getReplyBytes();
-}

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloService.java

@@ -1,237 +0,0 @@
-// Generated by the protocol buffer compiler.  DO NOT EDIT!
-// source: com/tzld/piaoquan/recommend/server/hello.proto
-
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-/**
- * Protobuf service {@code HelloService}
- */
-public  abstract class HelloService
-    implements com.google.protobuf.Service {
-  protected HelloService() {}
-
-  public interface Interface {
-    /**
-     * <code>rpc SayHello(.HelloRequest) returns (.HelloResponse);</code>
-     */
-    public abstract void sayHello(
-        com.google.protobuf.RpcController controller,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-        com.google.protobuf.RpcCallback<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> done);
-
-  }
-
-  public static com.google.protobuf.Service newReflectiveService(
-      final Interface impl) {
-    return new HelloService() {
-      @java.lang.Override
-      public  void sayHello(
-          com.google.protobuf.RpcController controller,
-          com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-          com.google.protobuf.RpcCallback<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> done) {
-        impl.sayHello(controller, request, done);
-      }
-
-    };
-  }
-
-  public static com.google.protobuf.BlockingService
-      newReflectiveBlockingService(final BlockingInterface impl) {
-    return new com.google.protobuf.BlockingService() {
-      public final com.google.protobuf.Descriptors.ServiceDescriptor
-          getDescriptorForType() {
-        return getDescriptor();
-      }
-
-      public final com.google.protobuf.Message callBlockingMethod(
-          com.google.protobuf.Descriptors.MethodDescriptor method,
-          com.google.protobuf.RpcController controller,
-          com.google.protobuf.Message request)
-          throws com.google.protobuf.ServiceException {
-        if (method.getService() != getDescriptor()) {
-          throw new java.lang.IllegalArgumentException(
-            "Service.callBlockingMethod() given method descriptor for " +
-            "wrong service type.");
-        }
-        switch(method.getIndex()) {
-          case 0:
-            return impl.sayHello(controller, (com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest)request);
-          default:
-            throw new java.lang.AssertionError("Can't get here.");
-        }
-      }
-
-      public final com.google.protobuf.Message
-          getRequestPrototype(
-          com.google.protobuf.Descriptors.MethodDescriptor method) {
-        if (method.getService() != getDescriptor()) {
-          throw new java.lang.IllegalArgumentException(
-            "Service.getRequestPrototype() given method " +
-            "descriptor for wrong service type.");
-        }
-        switch(method.getIndex()) {
-          case 0:
-            return com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.getDefaultInstance();
-          default:
-            throw new java.lang.AssertionError("Can't get here.");
-        }
-      }
-
-      public final com.google.protobuf.Message
-          getResponsePrototype(
-          com.google.protobuf.Descriptors.MethodDescriptor method) {
-        if (method.getService() != getDescriptor()) {
-          throw new java.lang.IllegalArgumentException(
-            "Service.getResponsePrototype() given method " +
-            "descriptor for wrong service type.");
-        }
-        switch(method.getIndex()) {
-          case 0:
-            return com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance();
-          default:
-            throw new java.lang.AssertionError("Can't get here.");
-        }
-      }
-
-    };
-  }
-
-  /**
-   * <code>rpc SayHello(.HelloRequest) returns (.HelloResponse);</code>
-   */
-  public abstract void sayHello(
-      com.google.protobuf.RpcController controller,
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-      com.google.protobuf.RpcCallback<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> done);
-
-  public static final
-      com.google.protobuf.Descriptors.ServiceDescriptor
-      getDescriptor() {
-    return com.tzld.piaoquan.recommend.server.gen.demo.Hello.getDescriptor().getServices().get(0);
-  }
-  public final com.google.protobuf.Descriptors.ServiceDescriptor
-      getDescriptorForType() {
-    return getDescriptor();
-  }
-
-  public final void callMethod(
-      com.google.protobuf.Descriptors.MethodDescriptor method,
-      com.google.protobuf.RpcController controller,
-      com.google.protobuf.Message request,
-      com.google.protobuf.RpcCallback<
-        com.google.protobuf.Message> done) {
-    if (method.getService() != getDescriptor()) {
-      throw new java.lang.IllegalArgumentException(
-        "Service.callMethod() given method descriptor for wrong " +
-        "service type.");
-    }
-    switch(method.getIndex()) {
-      case 0:
-        this.sayHello(controller, (com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest)request,
-          com.google.protobuf.RpcUtil.<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse>specializeCallback(
-            done));
-        return;
-      default:
-        throw new java.lang.AssertionError("Can't get here.");
-    }
-  }
-
-  public final com.google.protobuf.Message
-      getRequestPrototype(
-      com.google.protobuf.Descriptors.MethodDescriptor method) {
-    if (method.getService() != getDescriptor()) {
-      throw new java.lang.IllegalArgumentException(
-        "Service.getRequestPrototype() given method " +
-        "descriptor for wrong service type.");
-    }
-    switch(method.getIndex()) {
-      case 0:
-        return com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.getDefaultInstance();
-      default:
-        throw new java.lang.AssertionError("Can't get here.");
-    }
-  }
-
-  public final com.google.protobuf.Message
-      getResponsePrototype(
-      com.google.protobuf.Descriptors.MethodDescriptor method) {
-    if (method.getService() != getDescriptor()) {
-      throw new java.lang.IllegalArgumentException(
-        "Service.getResponsePrototype() given method " +
-        "descriptor for wrong service type.");
-    }
-    switch(method.getIndex()) {
-      case 0:
-        return com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance();
-      default:
-        throw new java.lang.AssertionError("Can't get here.");
-    }
-  }
-
-  public static Stub newStub(
-      com.google.protobuf.RpcChannel channel) {
-    return new Stub(channel);
-  }
-
-  public static final class Stub extends com.tzld.piaoquan.recommend.server.gen.demo.HelloService implements Interface {
-    private Stub(com.google.protobuf.RpcChannel channel) {
-      this.channel = channel;
-    }
-
-    private final com.google.protobuf.RpcChannel channel;
-
-    public com.google.protobuf.RpcChannel getChannel() {
-      return channel;
-    }
-
-    public  void sayHello(
-        com.google.protobuf.RpcController controller,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-        com.google.protobuf.RpcCallback<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> done) {
-      channel.callMethod(
-        getDescriptor().getMethods().get(0),
-        controller,
-        request,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance(),
-        com.google.protobuf.RpcUtil.generalizeCallback(
-          done,
-          com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.class,
-          com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance()));
-    }
-  }
-
-  public static BlockingInterface newBlockingStub(
-      com.google.protobuf.BlockingRpcChannel channel) {
-    return new BlockingStub(channel);
-  }
-
-  public interface BlockingInterface {
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse sayHello(
-        com.google.protobuf.RpcController controller,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request)
-        throws com.google.protobuf.ServiceException;
-  }
-
-  private static final class BlockingStub implements BlockingInterface {
-    private BlockingStub(com.google.protobuf.BlockingRpcChannel channel) {
-      this.channel = channel;
-    }
-
-    private final com.google.protobuf.BlockingRpcChannel channel;
-
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse sayHello(
-        com.google.protobuf.RpcController controller,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request)
-        throws com.google.protobuf.ServiceException {
-      return (com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse) channel.callBlockingMethod(
-        getDescriptor().getMethods().get(0),
-        controller,
-        request,
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance());
-    }
-
-  }
-
-  // @@protoc_insertion_point(class_scope:HelloService)
-}
-

recommend-server-client/src/main/java/com/tzld/piaoquan/recommend/server/gen/demo/HelloServiceGrpc.java

@@ -1,288 +0,0 @@
-package com.tzld.piaoquan.recommend.server.gen.demo;
-
-import static io.grpc.MethodDescriptor.generateFullMethodName;
-import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
-import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
-import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
-import static io.grpc.stub.ClientCalls.asyncUnaryCall;
-import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
-import static io.grpc.stub.ClientCalls.blockingUnaryCall;
-import static io.grpc.stub.ClientCalls.futureUnaryCall;
-import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncUnaryCall;
-import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
-
-/**
- */
-@javax.annotation.Generated(
-    value = "by gRPC proto compiler (version 1.34.1)",
-    comments = "Source: com/tzld/piaoquan/recommend/server/hello.proto")
-public final class HelloServiceGrpc {
-
-  private HelloServiceGrpc() {}
-
-  public static final String SERVICE_NAME = "HelloService";
-
-  // Static method descriptors that strictly reflect the proto.
-  private static volatile io.grpc.MethodDescriptor<com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest,
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> getSayHelloMethod;
-
-  @io.grpc.stub.annotations.RpcMethod(
-      fullMethodName = SERVICE_NAME + '/' + "SayHello",
-      requestType = com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.class,
-      responseType = com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.class,
-      methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
-  public static io.grpc.MethodDescriptor<com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest,
-      com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> getSayHelloMethod() {
-    io.grpc.MethodDescriptor<com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest, com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> getSayHelloMethod;
-    if ((getSayHelloMethod = HelloServiceGrpc.getSayHelloMethod) == null) {
-      synchronized (HelloServiceGrpc.class) {
-        if ((getSayHelloMethod = HelloServiceGrpc.getSayHelloMethod) == null) {
-          HelloServiceGrpc.getSayHelloMethod = getSayHelloMethod =
-              io.grpc.MethodDescriptor.<com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest, com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse>newBuilder()
-              .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
-              .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SayHello"))
-              .setSampledToLocalTracing(true)
-              .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
-                  com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest.getDefaultInstance()))
-              .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
-                  com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse.getDefaultInstance()))
-              .setSchemaDescriptor(new HelloServiceMethodDescriptorSupplier("SayHello"))
-              .build();
-        }
-      }
-    }
-    return getSayHelloMethod;
-  }
-
-  /**
-   * Creates a new async stub that supports all call types for the service
-   */
-  public static HelloServiceStub newStub(io.grpc.Channel channel) {
-    io.grpc.stub.AbstractStub.StubFactory<HelloServiceStub> factory =
-      new io.grpc.stub.AbstractStub.StubFactory<HelloServiceStub>() {
-        @java.lang.Override
-        public HelloServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-          return new HelloServiceStub(channel, callOptions);
-        }
-      };
-    return HelloServiceStub.newStub(factory, channel);
-  }
-
-  /**
-   * Creates a new blocking-style stub that supports unary and streaming output calls on the service
-   */
-  public static HelloServiceBlockingStub newBlockingStub(
-      io.grpc.Channel channel) {
-    io.grpc.stub.AbstractStub.StubFactory<HelloServiceBlockingStub> factory =
-      new io.grpc.stub.AbstractStub.StubFactory<HelloServiceBlockingStub>() {
-        @java.lang.Override
-        public HelloServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-          return new HelloServiceBlockingStub(channel, callOptions);
-        }
-      };
-    return HelloServiceBlockingStub.newStub(factory, channel);
-  }
-
-  /**
-   * Creates a new ListenableFuture-style stub that supports unary calls on the service
-   */
-  public static HelloServiceFutureStub newFutureStub(
-      io.grpc.Channel channel) {
-    io.grpc.stub.AbstractStub.StubFactory<HelloServiceFutureStub> factory =
-      new io.grpc.stub.AbstractStub.StubFactory<HelloServiceFutureStub>() {
-        @java.lang.Override
-        public HelloServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-          return new HelloServiceFutureStub(channel, callOptions);
-        }
-      };
-    return HelloServiceFutureStub.newStub(factory, channel);
-  }
-
-  /**
-   */
-  public static abstract class HelloServiceImplBase implements io.grpc.BindableService {
-
-    /**
-     */
-    public void sayHello(com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-        io.grpc.stub.StreamObserver<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> responseObserver) {
-      asyncUnimplementedUnaryCall(getSayHelloMethod(), responseObserver);
-    }
-
-    @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
-      return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
-          .addMethod(
-            getSayHelloMethod(),
-            asyncUnaryCall(
-              new MethodHandlers<
-                com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest,
-                com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse>(
-                  this, METHODID_SAY_HELLO)))
-          .build();
-    }
-  }
-
-  /**
-   */
-  public static final class HelloServiceStub extends io.grpc.stub.AbstractAsyncStub<HelloServiceStub> {
-    private HelloServiceStub(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      super(channel, callOptions);
-    }
-
-    @java.lang.Override
-    protected HelloServiceStub build(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      return new HelloServiceStub(channel, callOptions);
-    }
-
-    /**
-     */
-    public void sayHello(com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request,
-        io.grpc.stub.StreamObserver<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> responseObserver) {
-      asyncUnaryCall(
-          getChannel().newCall(getSayHelloMethod(), getCallOptions()), request, responseObserver);
-    }
-  }
-
-  /**
-   */
-  public static final class HelloServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<HelloServiceBlockingStub> {
-    private HelloServiceBlockingStub(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      super(channel, callOptions);
-    }
-
-    @java.lang.Override
-    protected HelloServiceBlockingStub build(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      return new HelloServiceBlockingStub(channel, callOptions);
-    }
-
-    /**
-     */
-    public com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse sayHello(com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request) {
-      return blockingUnaryCall(
-          getChannel(), getSayHelloMethod(), getCallOptions(), request);
-    }
-  }
-
-  /**
-   */
-  public static final class HelloServiceFutureStub extends io.grpc.stub.AbstractFutureStub<HelloServiceFutureStub> {
-    private HelloServiceFutureStub(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      super(channel, callOptions);
-    }
-
-    @java.lang.Override
-    protected HelloServiceFutureStub build(
-        io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
-      return new HelloServiceFutureStub(channel, callOptions);
-    }
-
-    /**
-     */
-    public com.google.common.util.concurrent.ListenableFuture<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse> sayHello(
-        com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest request) {
-      return futureUnaryCall(
-          getChannel().newCall(getSayHelloMethod(), getCallOptions()), request);
-    }
-  }
-
-  private static final int METHODID_SAY_HELLO = 0;
-
-  private static final class MethodHandlers<Req, Resp> implements
-      io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
-      io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
-      io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
-      io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
-    private final HelloServiceImplBase serviceImpl;
-    private final int methodId;
-
-    MethodHandlers(HelloServiceImplBase serviceImpl, int methodId) {
-      this.serviceImpl = serviceImpl;
-      this.methodId = methodId;
-    }
-
-    @java.lang.Override
-    @java.lang.SuppressWarnings("unchecked")
-    public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
-      switch (methodId) {
-        case METHODID_SAY_HELLO:
-          serviceImpl.sayHello((com.tzld.piaoquan.recommend.server.gen.demo.HelloRequest) request,
-              (io.grpc.stub.StreamObserver<com.tzld.piaoquan.recommend.server.gen.demo.HelloResponse>) responseObserver);
-          break;
-        default:
-          throw new AssertionError();
-      }
-    }
-
-    @java.lang.Override
-    @java.lang.SuppressWarnings("unchecked")
-    public io.grpc.stub.StreamObserver<Req> invoke(
-        io.grpc.stub.StreamObserver<Resp> responseObserver) {
-      switch (methodId) {
-        default:
-          throw new AssertionError();
-      }
-    }
-  }
-
-  private static abstract class HelloServiceBaseDescriptorSupplier
-      implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
-    HelloServiceBaseDescriptorSupplier() {}
-
-    @java.lang.Override
-    public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
-      return com.tzld.piaoquan.recommend.server.gen.demo.Hello.getDescriptor();
-    }
-
-    @java.lang.Override
-    public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
-      return getFileDescriptor().findServiceByName("HelloService");
-    }
-  }
-
-  private static final class HelloServiceFileDescriptorSupplier
-      extends HelloServiceBaseDescriptorSupplier {
-    HelloServiceFileDescriptorSupplier() {}
-  }
-
-  private static final class HelloServiceMethodDescriptorSupplier
-      extends HelloServiceBaseDescriptorSupplier
-      implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
-    private final String methodName;
-
-    HelloServiceMethodDescriptorSupplier(String methodName) {
-      this.methodName = methodName;
-    }
-
-    @java.lang.Override
-    public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
-      return getServiceDescriptor().findMethodByName(methodName);
-    }
-  }
-
-  private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
-
-  public static io.grpc.ServiceDescriptor getServiceDescriptor() {
-    io.grpc.ServiceDescriptor result = serviceDescriptor;
-    if (result == null) {
-      synchronized (HelloServiceGrpc.class) {
-        result = serviceDescriptor;
-        if (result == null) {
-          serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
-              .setSchemaDescriptor(new HelloServiceFileDescriptorSupplier())
-              .addMethod(getSayHelloMethod())
-              .build();
-        }
-      }
-    }
-    return result;
-  }
-}

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/RecommendService.java

@@ -144,7 +144,9 @@ public class RecommendService {
         Long idx = 0L;
         if (StringUtils.isNotBlank(value)) {
             idx = redisTemplate.opsForZSet().reverseRank(specialKeyName, value);
-            idx = idx == null ? 0L : idx;
+            if (idx == null) {
+                idx = 0L;
+            }
         }
 
         int getSize = request.getSize() * 5;

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/strategy/FlowPoolWithLevelRecallStrategy.java

@@ -86,14 +86,14 @@ public class FlowPoolWithLevelRecallStrategy extends AbstractFlowPoolWithLevelRe
     }
 
     @Data
-    class LevelWeight {
+    static class LevelWeight {
         private String level;
         private String levelKey;
         private Double weight;
     }
 
     @Data
-    class LevelP {
+    static class LevelP {
         private String levelKey;
         private double min;
         private double max;

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/strategy/FlowPoolWithLevelScoreRecallStrategy.java

@@ -57,7 +57,7 @@ public class FlowPoolWithLevelScoreRecallStrategy extends AbstractFlowPoolWithLe
         BigDecimal weightSumBD = new BigDecimal(weightSum);
         double level_p_low = 0;
         double weight_temp = 0;
-        double level_p_up = 0;
+        double level_p_up;
         Map<String, LevelP> level_p_mapping = new HashMap<>();
         for (LevelWeight lw : availableLevels) {
             BigDecimal bd = new BigDecimal(weight_temp + lw.getWeight());
@@ -86,14 +86,14 @@ public class FlowPoolWithLevelScoreRecallStrategy extends AbstractFlowPoolWithLe
     }
 
     @Data
-    class LevelWeight {
+    static class LevelWeight {
         private String level;
         private String levelKey;
         private Double weight;
     }
 
     @Data
-    class LevelP {
+    static class LevelP {
         private String levelKey;
         private double min;
         private double max;

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/util/JSONUtils.java

@@ -6,9 +6,6 @@ import com.google.gson.Gson;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 
-import java.util.Collections;
-import java.util.Map;
-
 @Slf4j
 public class JSONUtils {
 
@@ -38,11 +35,4 @@ public class JSONUtils {
         return defaultValue;
     }
 
-    public static void main(String[] args) {
-        String json = "{\"code\":-111,\"msg\":\"未知系统异常,请联系管理员\",\"data\":null,\"errorData\":null,\"extData\":null," +
-                "\"otherData\":null,\"extInfo\":null}";
-        Map<String, String> map = fromJson(json, new TypeToken<Map<String, String>>() {
-        }, Collections.emptyMap());
-        System.out.println("");
-    }
 }