ajax方法调用Web API，谁消耗了GRPC服务（如何从DB中获取列表？）：错误415和400

Question

我在Web控制台中遇到问题，首先给我错误的415没有contentType：'application/json; charset = utf-8'，在ajax方法中，它给了我错误400。

如果错误在后端代码中，我也尝试进行调试，调试器应该运行...）

我的目标是返回用户及其电子邮件的列表，类似这样

//试图在我的服务中执行此操作
iEnumerable（）

// c＃
类 弹奏者：
（字符串）用户名：user1
（字符串）电子邮件：

” GRPC，所以我将拥有一个Web API控制器，称为GRPC方法

，因为GRPC中没有IEnumerable，因此我的原始和方法看起来像这样：

proto：

syntax = "proto3";

option csharp_namespace = "GrpcService1.Protos";

package UserAuth;

service UserAuth {
rpc GetAllUsers(MessageRequest) returns(ListUsersResponse);
}

message ListUserResponse{
     string username = 1;
     string email = 2;
}

message ListUsersResponse{
  repeated ListUserResponse lstUsers = 1;
}

message MessageRequest{
string message = 1;
}

grpc方法服务c＃

public override Task<ListUsersResponse> GetAllUsers(MessageRequest request, ServerCallContext context)
        {
            //This gives me an IEnumerable<ShowUsers> (this is
            correct)
            var a = _userBll.getAllUsers();

           //Here in this lines maybe be the problem but I don't
           //know where (maybe be because of json type or something into a list)
           //here im trying to put separate list of users and emails
            var names = a.Select(x => x.Username);
            var emails = a.Select(y => y.Email);

            //here im trying to put the lists into a Response
            var all = new ListUserResponse
            {
                Username = names.ToString(),
                Email = emails.ToString()
            };

            //the above will give the same but the
            ListUsersResponse is a repeated attribute
            var response = new ListUsersResponse
            {
                LstUsers = { all }
            };

            //all ok
            request.Message = "Sucess";

            return Task.FromResult(response);
        }

下面的代码是正确的（i用邮政方法测试我在没有GRPC的情况下测试的控制器和Ajax我测试了），但是您将对我在做什么（是控制器和AJAX方法）

控制器[httpget]：

[HttpGet("getAllUserInfo_2"), Authorize]
        public async Task<ActionResult<ListUsersResponse>> GetAll_2([FromBody] MessageRequest message)
        {
            _logger.Log(LogLevel.Information, "Request Received for AuthController::Register");

            var results = await _userClient.GetAllUsersAsync(message);

            _logger.Log(LogLevel.Information, "Sending Response from AuthController::Register");

            return Ok(results);
        }

ajax方法：

$(function b() {
    debugger;
    var $users_A = $('#users_A');
    $.ajax({
            contentType: 'application/json; charset=UTF-8', //if I comment this gives me 415
            url: uri_3_2,
            type: 'GET',
            dataType: 'json',
            beforeSend: function(request) {
                request.setRequestHeader("Authorization", 'Bearer ' + localStorage.getItem("key"));
            },
            success: function(date) {
                $.each(data, function (i, rice) {
                    $users_A.append('<li>Name: ' + arroz.username + ' Email: ' + arroz.email + ' </li>');
                });
            },
            error: function (xhr, textStatus, errorThrown) {
                console.log('XHR:' + xhr + '\nTextStatus:' + textStatus + '\nErrorThrown:' + errorThrown);   //this should give me more info about the error but don't works... But it 
                //works fine the implementation code
                $users_A.append('<h4>ERRRROORRRR</h4>');
            }
        });
    });

欢迎任何帮助

Answer 1

双向流RPC将是一个更好的选择
大大提高您的表现，并可能解决您的问题。

您需要更改原始原型如下：

syntax = "proto3";
option csharp_namespace = "GrpcService1.Protos";
package UserAuth;

service UserAuth {
rpc GetAllUsers(MessageRequest) returns(stream UserResponse);
}

message UserResponse{
     string username = 1;
     string email = 2;
}

message MessageRequest{
     string message = 1;
}

GRPC方法服务C＃

public override async Task GetAllUsers(MessageRequest request, IServerStreamWriter<UserResponse> responseStream, ServerCallContext context)
        {
            var users = _userBll.getAllUsers();
            foreach (user in users)
            {
                await responseStream.WriteAsync(new UserResponse
                {
                    Username = user.Username.ToString(),
                    Email = user.Email.ToString()
                });
            }
        }

在客户端中：

    public async Task<List<UserResponse> GetAllUsers()
    {
        var userResponseList = new List<UserResponse>();
        using var call = client.GetAllUsers(new MessageRequest());
        while (await call.ResponseStream.MoveNext())
        {
            var userResponse = new UserResponse
                {
                    Username = call.ResponseStream.Current.Username,
                    Email = call.ResponseStream.Current.Email
                });
            userResponseList.Add(userResponse);
        }
        return userResponseList;
    }

客户端对象来自从GRPC服务URL创建的频道（我假设您知道）。
现在，您可以将其作为服务，并通过控制器的依赖注入来调用它。
我没有测试它，所以它可能会有一些编译错误，但是方法是正确的。