open
/
so-im
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

调用方 protobuf 和 hassion不兼容

master
tangmingyou 4 years ago
parent
acf4529d2b
commit
3a66437210
17 changed files with 61 additions and 2388 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 11
      im-entry/pom.xml
  2. 51
      im-entry/src/main/java/net/sopod/soim/entry/handlers/friend/ReqFriendSearchHandler.java
  3. 74
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/Message.java
  4. 760
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserInfo.java
  5. 39
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserInfoOrBuilder.java
  6. 770
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReply.java
  7. 33
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReplyOrBuilder.java
  8. 557
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReq.java
  9. 21
      im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReqOrBuilder.java
  10. 24
      im-service-api/im-logic-friend-api/pom.xml
  11. 37
      im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorage.java
  12. 17
      im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorageService.java
  13. 20
      im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorageServiceDubbo.java
  14. 14
      im-service-api/im-router-api/src/main/resources/proto/RouterStorage.proto
  15. 4
      im-service-api/pom.xml
  16. 15
      im-service/im-logic-user/src/main/java/net/sopod/soim/logic/user/service/UserSearchServiceImpl.java
  17. 2
      pom.xml

11
im-entry/pom.xml
Unescape View File

@ -36,11 +36,11 @@
<artifactId>im-logic-user-api</artifactId>
<version>${soim.version}</version>
</dependency>
<dependency>
<groupId>net.sopod</groupId>
<artifactId>im-logic-friend-api</artifactId>
<version>${soim.version}</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>net.sopod</groupId>-->
<!-- <artifactId>im-logic-friend-api</artifactId>-->
<!-- <version>${soim.version}</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
@ -82,6 +82,7 @@
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-registry-nacos</artifactId>
</dependency>
<dependency>
<groupId>com.lmax</groupId>
<artifactId>disruptor</artifactId>

51
im-entry/src/main/java/net/sopod/soim/entry/handlers/friend/ReqFriendSearchHandler.java
Unescape View File

@ -5,10 +5,10 @@ import lombok.extern.slf4j.Slf4j;
import net.sopod.soim.data.msg.friend.Friend;
import net.sopod.soim.entry.server.handler.AccountMessageHandler;
import net.sopod.soim.entry.server.session.Account;
import net.sopod.soim.logic.api.friend.search.AccountInfo;
import net.sopod.soim.logic.api.friend.search.AccountSearchService;
import net.sopod.soim.logic.api.friend.search.ReqAccountSearch;
import net.sopod.soim.logic.api.friend.search.ResAccountSearch;
//import net.sopod.soim.logic.api.friend.search.AccountInfo;
//import net.sopod.soim.logic.api.friend.search.AccountSearchService;
//import net.sopod.soim.logic.api.friend.search.ReqAccountSearch;
//import net.sopod.soim.logic.api.friend.search.ResAccountSearch;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Service;
@ -27,28 +27,33 @@ import java.util.stream.Collectors;
@Service
public class ReqFriendSearchHandler extends AccountMessageHandler<Friend.ReqFriendSearch> {
@DubboReference
private AccountSearchService accountSearchService;
@Override
public MessageLite handle(Account account, Friend.ReqFriendSearch msg) {
msg.getKeyword();
ReqAccountSearch search = ReqAccountSearch.newBuilder().setKeyword(msg.getKeyword()).build();
CompletableFuture<ResAccountSearch> future = accountSearchService.searchAccountLikelyAsync(search);
future.thenAccept(res -> {
log.info("用户搜索开始...");
List<AccountInfo> accounts = res.getAccountsList();
List<Friend.UserInfo> userInfos = accounts.stream().map(
acc -> Friend.UserInfo.newBuilder()
.setAccount(acc.getAccount())
.setNickname(acc.getNickname())
.setUid(acc.getUid())
.build()
).collect(Collectors.toList());
Friend.ResFriendSearch resSearch = Friend.ResFriendSearch.newBuilder().addAllUsers(userInfos).build();
account.writeNow(resSearch);
});
return null;
}
// @DubboReference
// private AccountSearchService accountSearchService;
//
// @Override
// public MessageLite handle(Account account, Friend.ReqFriendSearch msg) {
// msg.getKeyword();
// ReqAccountSearch search = ReqAccountSearch.newBuilder().setKeyword(msg.getKeyword()).build();
// CompletableFuture<ResAccountSearch> future = accountSearchService.searchAccountLikelyAsync(search);
// future.thenAccept(res -> {
// log.info("用户搜索开始...");
// List<AccountInfo> accounts = res.getAccountsList();
// List<Friend.UserInfo> userInfos = accounts.stream().map(
// acc -> Friend.UserInfo.newBuilder()
// .setAccount(acc.getAccount())
// .setNickname(acc.getNickname())
// .setUid(acc.getUid())
// .build()
// ).collect(Collectors.toList());
// Friend.ResFriendSearch resSearch = Friend.ResFriendSearch.newBuilder().addAllUsers(userInfos).build();
// account.writeNow(resSearch);
// });
// return null;
// }
}

74
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/Message.java
Unescape View File

@ -1,74 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
public final class Message {
private Message() {}
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_net_sopod_soim_logic_common_message_UserSearchReq_descriptor;
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_net_sopod_soim_logic_common_message_UserSearchReq_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor;
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_net_sopod_soim_logic_common_message_UserSearchReply_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor;
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_net_sopod_soim_logic_common_message_UserInfo_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\023proto/message.proto\022#net.sopod.soim.lo" +
"gic.common.message\" \n\rUserSearchReq\022\017\n\007k" +
"eyword\030\001 \001(\t\"O\n\017UserSearchReply\022<\n\005users" +
"\030\001 \003(\0132-.net.sopod.soim.logic.common.mes" +
"sage.UserInfo\":\n\010UserInfo\022\013\n\003uid\030\001 \001(\003\022\017" +
"\n\007account\030\002 \001(\t\022\020\n\010nickname\030\003 \001(\tB\002P\001b\006p" +
"roto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
new com.google.protobuf.Descriptors.FileDescriptor[] {
});
internal_static_net_sopod_soim_logic_common_message_UserSearchReq_descriptor =
getDescriptor().getMessageTypes().get(0);
internal_static_net_sopod_soim_logic_common_message_UserSearchReq_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_net_sopod_soim_logic_common_message_UserSearchReq_descriptor,
new java.lang.String[] { "Keyword", });
internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor =
getDescriptor().getMessageTypes().get(1);
internal_static_net_sopod_soim_logic_common_message_UserSearchReply_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor,
new java.lang.String[] { "Users", });
internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor =
getDescriptor().getMessageTypes().get(2);
internal_static_net_sopod_soim_logic_common_message_UserInfo_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor,
new java.lang.String[] { "Uid", "Account", "Nickname", });
}
// @@protoc_insertion_point(outer_class_scope)
}

760
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserInfo.java
Unescape View File

@ -1,760 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
/**
* Protobuf type {@code net.sopod.soim.logic.common.message.UserInfo}
*/
public final class UserInfo extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:net.sopod.soim.logic.common.message.UserInfo)
UserInfoOrBuilder {
private static final long serialVersionUID = 0L;
// Use UserInfo.newBuilder() to construct.
private UserInfo(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private UserInfo() {
account_ = "";
nickname_ = "";
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new UserInfo();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet
getUnknownFields() {
return this.unknownFields;
}
private UserInfo(
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 8: {
uid_ = input.readInt64();
break;
}
case 18: {
java.lang.String s = input.readStringRequireUtf8();
account_ = s;
break;
}
case 26: {
java.lang.String s = input.readStringRequireUtf8();
nickname_ = 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 net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserInfo_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserInfo.class, net.sopod.soim.logic.common.message.UserInfo.Builder.class);
}
public static final int UID_FIELD_NUMBER = 1;
private long uid_;
/**
* <code>int64 uid = 1;</code>
* @return The uid.
*/
@java.lang.Override
public long getUid() {
return uid_;
}
public static final int ACCOUNT_FIELD_NUMBER = 2;
private volatile java.lang.Object account_;
/**
* <code>string account = 2;</code>
* @return The account.
*/
@java.lang.Override
public java.lang.String getAccount() {
java.lang.Object ref = account_;
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();
account_ = s;
return s;
}
}
/**
* <code>string account = 2;</code>
* @return The bytes for account.
*/
@java.lang.Override
public com.google.protobuf.ByteString
getAccountBytes() {
java.lang.Object ref = account_;
if (ref instanceof java.lang.String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
account_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
public static final int NICKNAME_FIELD_NUMBER = 3;
private volatile java.lang.Object nickname_;
/**
* <code>string nickname = 3;</code>
* @return The nickname.
*/
@java.lang.Override
public java.lang.String getNickname() {
java.lang.Object ref = nickname_;
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();
nickname_ = s;
return s;
}
}
/**
* <code>string nickname = 3;</code>
* @return The bytes for nickname.
*/
@java.lang.Override
public com.google.protobuf.ByteString
getNicknameBytes() {
java.lang.Object ref = nickname_;
if (ref instanceof java.lang.String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
nickname_ = 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 (uid_ != 0L) {
output.writeInt64(1, uid_);
}
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(account_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 2, account_);
}
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(nickname_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 3, nickname_);
}
unknownFields.writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
if (uid_ != 0L) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, uid_);
}
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(account_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, account_);
}
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(nickname_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, nickname_);
}
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 net.sopod.soim.logic.common.message.UserInfo)) {
return super.equals(obj);
}
net.sopod.soim.logic.common.message.UserInfo other = (net.sopod.soim.logic.common.message.UserInfo) obj;
if (getUid()
!= other.getUid()) return false;
if (!getAccount()
.equals(other.getAccount())) return false;
if (!getNickname()
.equals(other.getNickname())) 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) + UID_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
getUid());
hash = (37 * hash) + ACCOUNT_FIELD_NUMBER;
hash = (53 * hash) + getAccount().hashCode();
hash = (37 * hash) + NICKNAME_FIELD_NUMBER;
hash = (53 * hash) + getNickname().hashCode();
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserInfo parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserInfo 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 net.sopod.soim.logic.common.message.UserInfo parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserInfo 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 net.sopod.soim.logic.common.message.UserInfo parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserInfo 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(net.sopod.soim.logic.common.message.UserInfo 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 net.sopod.soim.logic.common.message.UserInfo}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:net.sopod.soim.logic.common.message.UserInfo)
net.sopod.soim.logic.common.message.UserInfoOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserInfo_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserInfo.class, net.sopod.soim.logic.common.message.UserInfo.Builder.class);
}
// Construct using net.sopod.soim.logic.common.message.UserInfo.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();
uid_ = 0L;
account_ = "";
nickname_ = "";
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserInfo_descriptor;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfo getDefaultInstanceForType() {
return net.sopod.soim.logic.common.message.UserInfo.getDefaultInstance();
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfo build() {
net.sopod.soim.logic.common.message.UserInfo result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfo buildPartial() {
net.sopod.soim.logic.common.message.UserInfo result = new net.sopod.soim.logic.common.message.UserInfo(this);
result.uid_ = uid_;
result.account_ = account_;
result.nickname_ = nickname_;
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 net.sopod.soim.logic.common.message.UserInfo) {
return mergeFrom((net.sopod.soim.logic.common.message.UserInfo)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(net.sopod.soim.logic.common.message.UserInfo other) {
if (other == net.sopod.soim.logic.common.message.UserInfo.getDefaultInstance()) return this;
if (other.getUid() != 0L) {
setUid(other.getUid());
}
if (!other.getAccount().isEmpty()) {
account_ = other.account_;
onChanged();
}
if (!other.getNickname().isEmpty()) {
nickname_ = other.nickname_;
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 {
net.sopod.soim.logic.common.message.UserInfo parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (net.sopod.soim.logic.common.message.UserInfo) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
}
return this;
}
private long uid_ ;
/**
* <code>int64 uid = 1;</code>
* @return The uid.
*/
@java.lang.Override
public long getUid() {
return uid_;
}
/**
* <code>int64 uid = 1;</code>
* @param value The uid to set.
* @return This builder for chaining.
*/
public Builder setUid(long value) {
uid_ = value;
onChanged();
return this;
}
/**
* <code>int64 uid = 1;</code>
* @return This builder for chaining.
*/
public Builder clearUid() {
uid_ = 0L;
onChanged();
return this;
}
private java.lang.Object account_ = "";
/**
* <code>string account = 2;</code>
* @return The account.
*/
public java.lang.String getAccount() {
java.lang.Object ref = account_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
account_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
* <code>string account = 2;</code>
* @return The bytes for account.
*/
public com.google.protobuf.ByteString
getAccountBytes() {
java.lang.Object ref = account_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
account_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
* <code>string account = 2;</code>
* @param value The account to set.
* @return This builder for chaining.
*/
public Builder setAccount(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
account_ = value;
onChanged();
return this;
}
/**
* <code>string account = 2;</code>
* @return This builder for chaining.
*/
public Builder clearAccount() {
account_ = getDefaultInstance().getAccount();
onChanged();
return this;
}
/**
* <code>string account = 2;</code>
* @param value The bytes for account to set.
* @return This builder for chaining.
*/
public Builder setAccountBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
account_ = value;
onChanged();
return this;
}
private java.lang.Object nickname_ = "";
/**
* <code>string nickname = 3;</code>
* @return The nickname.
*/
public java.lang.String getNickname() {
java.lang.Object ref = nickname_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
nickname_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
* <code>string nickname = 3;</code>
* @return The bytes for nickname.
*/
public com.google.protobuf.ByteString
getNicknameBytes() {
java.lang.Object ref = nickname_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
nickname_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
* <code>string nickname = 3;</code>
* @param value The nickname to set.
* @return This builder for chaining.
*/
public Builder setNickname(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
nickname_ = value;
onChanged();
return this;
}
/**
* <code>string nickname = 3;</code>
* @return This builder for chaining.
*/
public Builder clearNickname() {
nickname_ = getDefaultInstance().getNickname();
onChanged();
return this;
}
/**
* <code>string nickname = 3;</code>
* @param value The bytes for nickname to set.
* @return This builder for chaining.
*/
public Builder setNicknameBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
nickname_ = 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:net.sopod.soim.logic.common.message.UserInfo)
}
// @@protoc_insertion_point(class_scope:net.sopod.soim.logic.common.message.UserInfo)
private static final net.sopod.soim.logic.common.message.UserInfo DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new net.sopod.soim.logic.common.message.UserInfo();
}
public static net.sopod.soim.logic.common.message.UserInfo getDefaultInstance() {
return DEFAULT_INSTANCE;
}
private static final com.google.protobuf.Parser<UserInfo>
PARSER = new com.google.protobuf.AbstractParser<UserInfo>() {
@java.lang.Override
public UserInfo parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return new UserInfo(input, extensionRegistry);
}
};
public static com.google.protobuf.Parser<UserInfo> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<UserInfo> getParserForType() {
return PARSER;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfo getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}

39
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserInfoOrBuilder.java
Unescape View File

@ -1,39 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
public interface UserInfoOrBuilder extends
// @@protoc_insertion_point(interface_extends:net.sopod.soim.logic.common.message.UserInfo)
com.google.protobuf.MessageOrBuilder {
/**
* <code>int64 uid = 1;</code>
* @return The uid.
*/
long getUid();
/**
* <code>string account = 2;</code>
* @return The account.
*/
java.lang.String getAccount();
/**
* <code>string account = 2;</code>
* @return The bytes for account.
*/
com.google.protobuf.ByteString
getAccountBytes();
/**
* <code>string nickname = 3;</code>
* @return The nickname.
*/
java.lang.String getNickname();
/**
* <code>string nickname = 3;</code>
* @return The bytes for nickname.
*/
com.google.protobuf.ByteString
getNicknameBytes();
}

770
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReply.java
Unescape View File

@ -1,770 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
/**
* Protobuf type {@code net.sopod.soim.logic.common.message.UserSearchReply}
*/
public final class UserSearchReply extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:net.sopod.soim.logic.common.message.UserSearchReply)
UserSearchReplyOrBuilder {
private static final long serialVersionUID = 0L;
// Use UserSearchReply.newBuilder() to construct.
private UserSearchReply(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private UserSearchReply() {
users_ = java.util.Collections.emptyList();
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new UserSearchReply();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet
getUnknownFields() {
return this.unknownFields;
}
private UserSearchReply(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
this();
if (extensionRegistry == null) {
throw new java.lang.NullPointerException();
}
int mutable_bitField0_ = 0;
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: {
if (!((mutable_bitField0_ & 0x00000001) != 0)) {
users_ = new java.util.ArrayList<net.sopod.soim.logic.common.message.UserInfo>();
mutable_bitField0_ |= 0x00000001;
}
users_.add(
input.readMessage(net.sopod.soim.logic.common.message.UserInfo.parser(), extensionRegistry));
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 {
if (((mutable_bitField0_ & 0x00000001) != 0)) {
users_ = java.util.Collections.unmodifiableList(users_);
}
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReply_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserSearchReply.class, net.sopod.soim.logic.common.message.UserSearchReply.Builder.class);
}
public static final int USERS_FIELD_NUMBER = 1;
private java.util.List<net.sopod.soim.logic.common.message.UserInfo> users_;
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
@java.lang.Override
public java.util.List<net.sopod.soim.logic.common.message.UserInfo> getUsersList() {
return users_;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
@java.lang.Override
public java.util.List<? extends net.sopod.soim.logic.common.message.UserInfoOrBuilder>
getUsersOrBuilderList() {
return users_;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
@java.lang.Override
public int getUsersCount() {
return users_.size();
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfo getUsers(int index) {
return users_.get(index);
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
@java.lang.Override
public net.sopod.soim.logic.common.message.UserInfoOrBuilder getUsersOrBuilder(
int index) {
return users_.get(index);
}
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 {
for (int i = 0; i < users_.size(); i++) {
output.writeMessage(1, users_.get(i));
}
unknownFields.writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
for (int i = 0; i < users_.size(); i++) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(1, users_.get(i));
}
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 net.sopod.soim.logic.common.message.UserSearchReply)) {
return super.equals(obj);
}
net.sopod.soim.logic.common.message.UserSearchReply other = (net.sopod.soim.logic.common.message.UserSearchReply) obj;
if (!getUsersList()
.equals(other.getUsersList())) 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();
if (getUsersCount() > 0) {
hash = (37 * hash) + USERS_FIELD_NUMBER;
hash = (53 * hash) + getUsersList().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReply parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReply 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 net.sopod.soim.logic.common.message.UserSearchReply parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReply 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 net.sopod.soim.logic.common.message.UserSearchReply parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReply 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(net.sopod.soim.logic.common.message.UserSearchReply 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 net.sopod.soim.logic.common.message.UserSearchReply}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:net.sopod.soim.logic.common.message.UserSearchReply)
net.sopod.soim.logic.common.message.UserSearchReplyOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReply_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserSearchReply.class, net.sopod.soim.logic.common.message.UserSearchReply.Builder.class);
}
// Construct using net.sopod.soim.logic.common.message.UserSearchReply.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
private Builder(
com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
super(parent);
maybeForceBuilderInitialization();
}
private void maybeForceBuilderInitialization() {
if (com.google.protobuf.GeneratedMessageV3
.alwaysUseFieldBuilders) {
getUsersFieldBuilder();
}
}
@java.lang.Override
public Builder clear() {
super.clear();
if (usersBuilder_ == null) {
users_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000001);
} else {
usersBuilder_.clear();
}
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReply_descriptor;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReply getDefaultInstanceForType() {
return net.sopod.soim.logic.common.message.UserSearchReply.getDefaultInstance();
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReply build() {
net.sopod.soim.logic.common.message.UserSearchReply result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReply buildPartial() {
net.sopod.soim.logic.common.message.UserSearchReply result = new net.sopod.soim.logic.common.message.UserSearchReply(this);
int from_bitField0_ = bitField0_;
if (usersBuilder_ == null) {
if (((bitField0_ & 0x00000001) != 0)) {
users_ = java.util.Collections.unmodifiableList(users_);
bitField0_ = (bitField0_ & ~0x00000001);
}
result.users_ = users_;
} else {
result.users_ = usersBuilder_.build();
}
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 net.sopod.soim.logic.common.message.UserSearchReply) {
return mergeFrom((net.sopod.soim.logic.common.message.UserSearchReply)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(net.sopod.soim.logic.common.message.UserSearchReply other) {
if (other == net.sopod.soim.logic.common.message.UserSearchReply.getDefaultInstance()) return this;
if (usersBuilder_ == null) {
if (!other.users_.isEmpty()) {
if (users_.isEmpty()) {
users_ = other.users_;
bitField0_ = (bitField0_ & ~0x00000001);
} else {
ensureUsersIsMutable();
users_.addAll(other.users_);
}
onChanged();
}
} else {
if (!other.users_.isEmpty()) {
if (usersBuilder_.isEmpty()) {
usersBuilder_.dispose();
usersBuilder_ = null;
users_ = other.users_;
bitField0_ = (bitField0_ & ~0x00000001);
usersBuilder_ =
com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
getUsersFieldBuilder() : null;
} else {
usersBuilder_.addAllMessages(other.users_);
}
}
}
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 {
net.sopod.soim.logic.common.message.UserSearchReply parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (net.sopod.soim.logic.common.message.UserSearchReply) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
}
return this;
}
private int bitField0_;
private java.util.List<net.sopod.soim.logic.common.message.UserInfo> users_ =
java.util.Collections.emptyList();
private void ensureUsersIsMutable() {
if (!((bitField0_ & 0x00000001) != 0)) {
users_ = new java.util.ArrayList<net.sopod.soim.logic.common.message.UserInfo>(users_);
bitField0_ |= 0x00000001;
}
}
private com.google.protobuf.RepeatedFieldBuilderV3<
net.sopod.soim.logic.common.message.UserInfo, net.sopod.soim.logic.common.message.UserInfo.Builder, net.sopod.soim.logic.common.message.UserInfoOrBuilder> usersBuilder_;
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public java.util.List<net.sopod.soim.logic.common.message.UserInfo> getUsersList() {
if (usersBuilder_ == null) {
return java.util.Collections.unmodifiableList(users_);
} else {
return usersBuilder_.getMessageList();
}
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public int getUsersCount() {
if (usersBuilder_ == null) {
return users_.size();
} else {
return usersBuilder_.getCount();
}
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public net.sopod.soim.logic.common.message.UserInfo getUsers(int index) {
if (usersBuilder_ == null) {
return users_.get(index);
} else {
return usersBuilder_.getMessage(index);
}
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder setUsers(
int index, net.sopod.soim.logic.common.message.UserInfo value) {
if (usersBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureUsersIsMutable();
users_.set(index, value);
onChanged();
} else {
usersBuilder_.setMessage(index, value);
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder setUsers(
int index, net.sopod.soim.logic.common.message.UserInfo.Builder builderForValue) {
if (usersBuilder_ == null) {
ensureUsersIsMutable();
users_.set(index, builderForValue.build());
onChanged();
} else {
usersBuilder_.setMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder addUsers(net.sopod.soim.logic.common.message.UserInfo value) {
if (usersBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureUsersIsMutable();
users_.add(value);
onChanged();
} else {
usersBuilder_.addMessage(value);
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder addUsers(
int index, net.sopod.soim.logic.common.message.UserInfo value) {
if (usersBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
ensureUsersIsMutable();
users_.add(index, value);
onChanged();
} else {
usersBuilder_.addMessage(index, value);
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder addUsers(
net.sopod.soim.logic.common.message.UserInfo.Builder builderForValue) {
if (usersBuilder_ == null) {
ensureUsersIsMutable();
users_.add(builderForValue.build());
onChanged();
} else {
usersBuilder_.addMessage(builderForValue.build());
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder addUsers(
int index, net.sopod.soim.logic.common.message.UserInfo.Builder builderForValue) {
if (usersBuilder_ == null) {
ensureUsersIsMutable();
users_.add(index, builderForValue.build());
onChanged();
} else {
usersBuilder_.addMessage(index, builderForValue.build());
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder addAllUsers(
java.lang.Iterable<? extends net.sopod.soim.logic.common.message.UserInfo> values) {
if (usersBuilder_ == null) {
ensureUsersIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, users_);
onChanged();
} else {
usersBuilder_.addAllMessages(values);
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder clearUsers() {
if (usersBuilder_ == null) {
users_ = java.util.Collections.emptyList();
bitField0_ = (bitField0_ & ~0x00000001);
onChanged();
} else {
usersBuilder_.clear();
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public Builder removeUsers(int index) {
if (usersBuilder_ == null) {
ensureUsersIsMutable();
users_.remove(index);
onChanged();
} else {
usersBuilder_.remove(index);
}
return this;
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public net.sopod.soim.logic.common.message.UserInfo.Builder getUsersBuilder(
int index) {
return getUsersFieldBuilder().getBuilder(index);
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public net.sopod.soim.logic.common.message.UserInfoOrBuilder getUsersOrBuilder(
int index) {
if (usersBuilder_ == null) {
return users_.get(index); } else {
return usersBuilder_.getMessageOrBuilder(index);
}
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public java.util.List<? extends net.sopod.soim.logic.common.message.UserInfoOrBuilder>
getUsersOrBuilderList() {
if (usersBuilder_ != null) {
return usersBuilder_.getMessageOrBuilderList();
} else {
return java.util.Collections.unmodifiableList(users_);
}
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public net.sopod.soim.logic.common.message.UserInfo.Builder addUsersBuilder() {
return getUsersFieldBuilder().addBuilder(
net.sopod.soim.logic.common.message.UserInfo.getDefaultInstance());
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public net.sopod.soim.logic.common.message.UserInfo.Builder addUsersBuilder(
int index) {
return getUsersFieldBuilder().addBuilder(
index, net.sopod.soim.logic.common.message.UserInfo.getDefaultInstance());
}
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
public java.util.List<net.sopod.soim.logic.common.message.UserInfo.Builder>
getUsersBuilderList() {
return getUsersFieldBuilder().getBuilderList();
}
private com.google.protobuf.RepeatedFieldBuilderV3<
net.sopod.soim.logic.common.message.UserInfo, net.sopod.soim.logic.common.message.UserInfo.Builder, net.sopod.soim.logic.common.message.UserInfoOrBuilder>
getUsersFieldBuilder() {
if (usersBuilder_ == null) {
usersBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
net.sopod.soim.logic.common.message.UserInfo, net.sopod.soim.logic.common.message.UserInfo.Builder, net.sopod.soim.logic.common.message.UserInfoOrBuilder>(
users_,
((bitField0_ & 0x00000001) != 0),
getParentForChildren(),
isClean());
users_ = null;
}
return usersBuilder_;
}
@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:net.sopod.soim.logic.common.message.UserSearchReply)
}
// @@protoc_insertion_point(class_scope:net.sopod.soim.logic.common.message.UserSearchReply)
private static final net.sopod.soim.logic.common.message.UserSearchReply DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new net.sopod.soim.logic.common.message.UserSearchReply();
}
public static net.sopod.soim.logic.common.message.UserSearchReply getDefaultInstance() {
return DEFAULT_INSTANCE;
}
private static final com.google.protobuf.Parser<UserSearchReply>
PARSER = new com.google.protobuf.AbstractParser<UserSearchReply>() {
@java.lang.Override
public UserSearchReply parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return new UserSearchReply(input, extensionRegistry);
}
};
public static com.google.protobuf.Parser<UserSearchReply> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<UserSearchReply> getParserForType() {
return PARSER;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReply getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}

33
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReplyOrBuilder.java
Unescape View File

@ -1,33 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
public interface UserSearchReplyOrBuilder extends
// @@protoc_insertion_point(interface_extends:net.sopod.soim.logic.common.message.UserSearchReply)
com.google.protobuf.MessageOrBuilder {
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
java.util.List<net.sopod.soim.logic.common.message.UserInfo>
getUsersList();
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
net.sopod.soim.logic.common.message.UserInfo getUsers(int index);
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
int getUsersCount();
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
java.util.List<? extends net.sopod.soim.logic.common.message.UserInfoOrBuilder>
getUsersOrBuilderList();
/**
* <code>repeated .net.sopod.soim.logic.common.message.UserInfo users = 1;</code>
*/
net.sopod.soim.logic.common.message.UserInfoOrBuilder getUsersOrBuilder(
int index);
}

557
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReq.java
Unescape View File

@ -1,557 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
/**
* Protobuf type {@code net.sopod.soim.logic.common.message.UserSearchReq}
*/
public final class UserSearchReq extends
com.google.protobuf.GeneratedMessageV3 implements
// @@protoc_insertion_point(message_implements:net.sopod.soim.logic.common.message.UserSearchReq)
UserSearchReqOrBuilder {
private static final long serialVersionUID = 0L;
// Use UserSearchReq.newBuilder() to construct.
private UserSearchReq(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
super(builder);
}
private UserSearchReq() {
keyword_ = "";
}
@java.lang.Override
@SuppressWarnings({"unused"})
protected java.lang.Object newInstance(
UnusedPrivateParameter unused) {
return new UserSearchReq();
}
@java.lang.Override
public final com.google.protobuf.UnknownFieldSet
getUnknownFields() {
return this.unknownFields;
}
private UserSearchReq(
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();
keyword_ = 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 net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReq_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReq_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserSearchReq.class, net.sopod.soim.logic.common.message.UserSearchReq.Builder.class);
}
public static final int KEYWORD_FIELD_NUMBER = 1;
private volatile java.lang.Object keyword_;
/**
* <code>string keyword = 1;</code>
* @return The keyword.
*/
@java.lang.Override
public java.lang.String getKeyword() {
java.lang.Object ref = keyword_;
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();
keyword_ = s;
return s;
}
}
/**
* <code>string keyword = 1;</code>
* @return The bytes for keyword.
*/
@java.lang.Override
public com.google.protobuf.ByteString
getKeywordBytes() {
java.lang.Object ref = keyword_;
if (ref instanceof java.lang.String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
keyword_ = 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 (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(keyword_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 1, keyword_);
}
unknownFields.writeTo(output);
}
@java.lang.Override
public int getSerializedSize() {
int size = memoizedSize;
if (size != -1) return size;
size = 0;
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(keyword_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, keyword_);
}
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 net.sopod.soim.logic.common.message.UserSearchReq)) {
return super.equals(obj);
}
net.sopod.soim.logic.common.message.UserSearchReq other = (net.sopod.soim.logic.common.message.UserSearchReq) obj;
if (!getKeyword()
.equals(other.getKeyword())) 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) + KEYWORD_FIELD_NUMBER;
hash = (53 * hash) + getKeyword().hashCode();
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
java.nio.ByteBuffer data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data, extensionRegistry);
}
public static net.sopod.soim.logic.common.message.UserSearchReq parseFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReq 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 net.sopod.soim.logic.common.message.UserSearchReq parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseDelimitedWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReq 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 net.sopod.soim.logic.common.message.UserSearchReq parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return com.google.protobuf.GeneratedMessageV3
.parseWithIOException(PARSER, input);
}
public static net.sopod.soim.logic.common.message.UserSearchReq 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(net.sopod.soim.logic.common.message.UserSearchReq 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 net.sopod.soim.logic.common.message.UserSearchReq}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
// @@protoc_insertion_point(builder_implements:net.sopod.soim.logic.common.message.UserSearchReq)
net.sopod.soim.logic.common.message.UserSearchReqOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReq_descriptor;
}
@java.lang.Override
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReq_fieldAccessorTable
.ensureFieldAccessorsInitialized(
net.sopod.soim.logic.common.message.UserSearchReq.class, net.sopod.soim.logic.common.message.UserSearchReq.Builder.class);
}
// Construct using net.sopod.soim.logic.common.message.UserSearchReq.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();
keyword_ = "";
return this;
}
@java.lang.Override
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return net.sopod.soim.logic.common.message.Message.internal_static_net_sopod_soim_logic_common_message_UserSearchReq_descriptor;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReq getDefaultInstanceForType() {
return net.sopod.soim.logic.common.message.UserSearchReq.getDefaultInstance();
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReq build() {
net.sopod.soim.logic.common.message.UserSearchReq result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReq buildPartial() {
net.sopod.soim.logic.common.message.UserSearchReq result = new net.sopod.soim.logic.common.message.UserSearchReq(this);
result.keyword_ = keyword_;
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 net.sopod.soim.logic.common.message.UserSearchReq) {
return mergeFrom((net.sopod.soim.logic.common.message.UserSearchReq)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(net.sopod.soim.logic.common.message.UserSearchReq other) {
if (other == net.sopod.soim.logic.common.message.UserSearchReq.getDefaultInstance()) return this;
if (!other.getKeyword().isEmpty()) {
keyword_ = other.keyword_;
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 {
net.sopod.soim.logic.common.message.UserSearchReq parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
parsedMessage = (net.sopod.soim.logic.common.message.UserSearchReq) e.getUnfinishedMessage();
throw e.unwrapIOException();
} finally {
if (parsedMessage != null) {
mergeFrom(parsedMessage);
}
}
return this;
}
private java.lang.Object keyword_ = "";
/**
* <code>string keyword = 1;</code>
* @return The keyword.
*/
public java.lang.String getKeyword() {
java.lang.Object ref = keyword_;
if (!(ref instanceof java.lang.String)) {
com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref;
java.lang.String s = bs.toStringUtf8();
keyword_ = s;
return s;
} else {
return (java.lang.String) ref;
}
}
/**
* <code>string keyword = 1;</code>
* @return The bytes for keyword.
*/
public com.google.protobuf.ByteString
getKeywordBytes() {
java.lang.Object ref = keyword_;
if (ref instanceof String) {
com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8(
(java.lang.String) ref);
keyword_ = b;
return b;
} else {
return (com.google.protobuf.ByteString) ref;
}
}
/**
* <code>string keyword = 1;</code>
* @param value The keyword to set.
* @return This builder for chaining.
*/
public Builder setKeyword(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
keyword_ = value;
onChanged();
return this;
}
/**
* <code>string keyword = 1;</code>
* @return This builder for chaining.
*/
public Builder clearKeyword() {
keyword_ = getDefaultInstance().getKeyword();
onChanged();
return this;
}
/**
* <code>string keyword = 1;</code>
* @param value The bytes for keyword to set.
* @return This builder for chaining.
*/
public Builder setKeywordBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
keyword_ = 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:net.sopod.soim.logic.common.message.UserSearchReq)
}
// @@protoc_insertion_point(class_scope:net.sopod.soim.logic.common.message.UserSearchReq)
private static final net.sopod.soim.logic.common.message.UserSearchReq DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new net.sopod.soim.logic.common.message.UserSearchReq();
}
public static net.sopod.soim.logic.common.message.UserSearchReq getDefaultInstance() {
return DEFAULT_INSTANCE;
}
private static final com.google.protobuf.Parser<UserSearchReq>
PARSER = new com.google.protobuf.AbstractParser<UserSearchReq>() {
@java.lang.Override
public UserSearchReq parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return new UserSearchReq(input, extensionRegistry);
}
};
public static com.google.protobuf.Parser<UserSearchReq> parser() {
return PARSER;
}
@java.lang.Override
public com.google.protobuf.Parser<UserSearchReq> getParserForType() {
return PARSER;
}
@java.lang.Override
public net.sopod.soim.logic.common.message.UserSearchReq getDefaultInstanceForType() {
return DEFAULT_INSTANCE;
}
}

21
im-service-api/im-logic-common/src/main/java/net/sopod/soim/logic/common/message/UserSearchReqOrBuilder.java
Unescape View File

@ -1,21 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/message.proto
package net.sopod.soim.logic.common.message;
public interface UserSearchReqOrBuilder extends
// @@protoc_insertion_point(interface_extends:net.sopod.soim.logic.common.message.UserSearchReq)
com.google.protobuf.MessageOrBuilder {
/**
* <code>string keyword = 1;</code>
* @return The keyword.
*/
java.lang.String getKeyword();
/**
* <code>string keyword = 1;</code>
* @return The bytes for keyword.
*/
com.google.protobuf.ByteString
getKeywordBytes();
}

24
im-service-api/im-logic-friend-api/pom.xml
Unescape View File

@ -12,4 +12,28 @@
<artifactId>im-logic-friend-api</artifactId>
<description>好友功能模块</description>
<dependencies>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-serialization-protobuf</artifactId>
<version>${dubbo.protobuf.verion}</version>
<exclusions>
<exclusion>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-common</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>${protoc.version}</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java-util</artifactId>
<version>${protoc.version}</version>
</dependency>
</dependencies>
</project>

37
im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorage.java
Unescape View File

@ -1,37 +0,0 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: proto/RouterStorage.proto
package net.sopod.soim.router.api.service.storage;
public final class RouterStorage {
private RouterStorage() {}
public static void registerAllExtensions(
com.google.protobuf.ExtensionRegistryLite registry) {
}
public static void registerAllExtensions(
com.google.protobuf.ExtensionRegistry registry) {
registerAllExtensions(
(com.google.protobuf.ExtensionRegistryLite) registry);
}
public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() {
return descriptor;
}
private static com.google.protobuf.Descriptors.FileDescriptor
descriptor;
static {
java.lang.String[] descriptorData = {
"\n\031proto/RouterStorage.proto\022)net.sopod.s" +
"oim.router.api.service.storage2\026\n\024Router" +
"StorageServiceB\002P\001b\006proto3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
new com.google.protobuf.Descriptors.FileDescriptor[] {
});
}
// @@protoc_insertion_point(outer_class_scope)
}

17
im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorageService.java
Unescape View File

@ -1,17 +0,0 @@
package net.sopod.soim.router.api.service.storage;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicBoolean;
@javax.annotation.Generated(
value = "by Dubbo generator",
comments = "Source: proto/RouterStorage.proto")
public interface RouterStorageService {
static final String JAVA_SERVICE_NAME = "net.sopod.soim.router.api.service.storage.RouterStorageService";
static final String SERVICE_NAME = "net.sopod.soim.router.api.service.storage.RouterStorageService";
// FIXME, initialize Dubbo3 stub when interface loaded, thinking of new ways doing this.
static final boolean inited = RouterStorageServiceDubbo.init();
}

20
im-service-api/im-router-api/src/main/java/net/sopod/soim/router/api/service/storage/RouterStorageServiceDubbo.java
Unescape View File

@ -1,20 +0,0 @@
package net.sopod.soim.router.api.service.storage;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicBoolean;
@javax.annotation.Generated(
value = "by Dubbo generator",
comments = "Source: proto/RouterStorage.proto")
public final class RouterStorageServiceDubbo {
private static final AtomicBoolean registered = new AtomicBoolean();
public static boolean init() {
if (registered.compareAndSet(false, true)) {
}
return true;
}
private RouterStorageServiceDubbo() {}
}

14
im-service-api/im-router-api/src/main/resources/proto/RouterStorage.proto
Unescape View File

@ -1,14 +0,0 @@
syntax = "proto3";
option java_multiple_files = true;
package net.sopod.soim.router.api.service.storage;
// import "proto/message.proto";
service RouterStorageService {
// 关键字搜索用户
// rpc searchOnlineUsers(UserSearchReq) returns (UserSearchReply) {}
}

4
im-service-api/pom.xml
Unescape View File

@ -23,7 +23,7 @@
</modules>
<dependencies>
<dependency>
<!-- <dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-serialization-protobuf</artifactId>
<version>${dubbo.protobuf.verion}</version>
@ -38,7 +38,7 @@
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>${protoc.version}</version>
</dependency>
</dependency>-->
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>

15
im-service/im-logic-user/src/main/java/net/sopod/soim/logic/user/service/UserSearchServiceImpl.java
Unescape View File

@ -1,15 +0,0 @@
package net.sopod.soim.logic.user.service;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.dubbo.config.annotation.Method;
/**
* UserSearchService
*
* @author tmy
* @date 2022-05-15 22:14
*/
@DubboService(methods = {@Method(name = "")})
public class UserSearchServiceImpl {
}

2
pom.xml
Unescape View File

@ -40,7 +40,7 @@
<nacos.version>2.0.3</nacos.version>
<msgpack.version>0.9.1</msgpack.version>
<dubbo.compiler.version>0.0.2</dubbo.compiler.version>
<dubbo.compiler.triple.version>0.0.3</dubbo.compiler.triple.version>
<!-- <dubbo.compiler.triple.version>0.0.3</dubbo.compiler.triple.version>-->
<protoc.version>3.19.4</protoc.version>
<dubbo.protobuf.verion>2.7.15</dubbo.protobuf.verion>
</properties>

Write Preview
Loading…
Cancel
Save