RError.com

RError.com Logo RError.com Logo

RError.com Navigation

  • 主页

Mobile menu

Close
  • 主页
  • 系统&网络
    • 热门问题
    • 最新问题
    • 标签
  • Ubuntu
    • 热门问题
    • 最新问题
    • 标签
  • 帮助
主页 / 问题 / 573591
Accepted
Алекс Сотник
Алекс Сотник
Asked:2020-10-04 19:25:53 +0000 UTC2020-10-04 19:25:53 +0000 UTC 2020-10-04 19:25:53 +0000 UTC

从服务器向客户端发送消息时出错

  • 772

弹出一个错误:

error: no method named `write` found for type `std::io::BufWriter<&&mut std::net::TcpStream>` in the current scope
  --> <anon>:89:28
   |
89 |                     writer.write(b"OK");
   |                            ^^^^^
   |
   = note: the method `write` exists but the following trait bounds were not satisfied: `&&mut std::net::TcpStream : std::io::Write`

我不知道如何在收到他的数据包后向客户端发送“OK”消息。

游乐场网址和Git 网址

use std::net::{TcpListener, TcpStream};
use std::io::{BufReader, BufWriter};
use std::io::prelude::*;
use std::thread;
//use commands;

pub struct LoginServer {
    address: String,
    //    reader: BufReader<TcpStream>,
}

impl LoginServer {
    pub fn new(hostname: &str, port: &str) -> LoginServer {
        let address = format!("{}:{}", hostname, port);
        //        let stream = TcpStream::connect(&*address).unwrap();

        LoginServer {
            address: address,
            //            reader: BufReader::new(stream),
        }
    }

    pub fn start(&mut self) -> bool {
        let listener = match TcpListener::bind(&*self.address) {
            Ok(data) => data,
            Err(e) => {
                println!("Ошибка открытия порта: {}", e);
                return false;
            },
        };

        for stream in listener.incoming() {
            match stream {
                Ok(mut stream) => {
                    let address = self.address.clone();

                    thread::spawn(move || {
                        handle_client(address, &mut stream);
                    });
                },
                Err(e) => {
                    println!("Ошибка при запуске сервера: {}", e);
                    return false;
                }
            }
        }

        fn handle_client(address: String, client_stream: &mut TcpStream) {
            /*println!("Подключен неизвестный клиент, ip: {}:{}",
                     reader.get_ref().local_addr().unwrap().ip(),
                     reader.get_ref().local_addr().unwrap().port());*/

            let mut writer = BufWriter::new(&client_stream);

            loop {
                let mut data = String::new();

                let result = {
                    let mut reader = BufReader::new(client_stream);


                    match reader.read_line(&mut data).unwrap() {
                        0 => {
                            println!("Неизвестный клиент был отключен, ip: {}:{}",
                                     reader.get_ref().local_addr().unwrap().ip(),
                                     reader.get_ref().local_addr().unwrap().port());
                            return;
                        },
                        _ => (),
                    }

                    let mut server_stream = TcpStream::connect(&*address).unwrap();

                    println!("Принял данные: {}", data);

                    let data = data.trim();
                    let data: Vec<&str> = data.split_whitespace().collect();

                    match data[0] {
                        "login" => true, //commands::login(reader.get_mut(), &mut server_stream, &data[1..]),
                        "register" => true, //commands::new_account(&data[1..]),
                        _ => false,
                    }
                };

                if !result {
                    println!("Неверная команда");
                } else {
                    writer.write(b"OK");
                    //let client_reference = client_stream.by_ref();
                    //let _ = client_reference.write(b"OK");
                }
            }
        }

        true
    }
}
клиент-сервер
  • 1 1 个回答
  • 10 Views

1 个回答

  • Voted
  1. Best Answer
    Алекс Сотник
    2020-10-04T20:46:16Z2020-10-04T20:46:16Z

    问题解决了,现在接受数据了。创建时,BufReader我将client_stream其替换为指针&client_stream。还与BufWriter.

    当向客户端发送响应时writer.write(b"OK"),您需要编写而不是

    writer.write(b"OK").unwrap();
    writer.flush().unwrap();
    

    所有工作代码: https ://gist.github.com/b59174f800109ef0d1620bada24d4505

    • 1

相关问题

  • Asp .NET 和 AngularJS 应用程序中的一些逻辑

Sidebar

Stats

  • 问题 10021
  • Answers 30001
  • 最佳答案 8000
  • 用户 6900
  • 常问
  • 回答
  • Marko Smith

    如何停止编写糟糕的代码?

    • 3 个回答
  • Marko Smith

    onCreateView 方法重构

    • 1 个回答
  • Marko Smith

    通用还是非通用

    • 2 个回答
  • Marko Smith

    如何访问 jQuery 中的列

    • 1 个回答
  • Marko Smith

    *.tga 文件的组重命名(3620 个)

    • 1 个回答
  • Marko Smith

    内存分配列表C#

    • 1 个回答
  • Marko Smith

    常规赛适度贪婪

    • 1 个回答
  • Marko Smith

    如何制作自己的自动完成/自动更正?

    • 1 个回答
  • Marko Smith

    选择斐波那契数列

    • 2 个回答
  • Marko Smith

    所有 API 版本中的通用权限代码

    • 2 个回答
  • Martin Hope
    jfs *(星号)和 ** 双星号在 Python 中是什么意思? 2020-11-23 05:07:40 +0000 UTC
  • Martin Hope
    hwak 哪个孩子调用了父母的静态方法?还是不可能完成的任务? 2020-11-18 16:30:55 +0000 UTC
  • Martin Hope
    Qwertiy 并变成3个无穷大 2020-11-06 07:15:57 +0000 UTC
  • Martin Hope
    koks_rs 什么是样板代码? 2020-10-27 15:43:19 +0000 UTC
  • Martin Hope
    user207618 Codegolf——组合选择算法的实现 2020-10-23 18:46:29 +0000 UTC
  • Martin Hope
    Sirop4ik 向 git 提交发布的正确方法是什么? 2020-10-05 00:02:00 +0000 UTC
  • Martin Hope
    Arch ArrayList 与 LinkedList 的区别? 2020-09-20 02:42:49 +0000 UTC
  • Martin Hope
    iluxa1810 哪个更正确使用:if () 或 try-catch? 2020-08-23 18:56:13 +0000 UTC
  • Martin Hope
    faoxis 为什么在这么多示例中函数都称为 foo? 2020-08-15 04:42:49 +0000 UTC
  • Martin Hope
    Pavel Mayorov 如何从事件或回调函数中返回值?或者至少等他们完成。 2020-08-11 16:49:28 +0000 UTC

热门标签

javascript python java php c# c++ html android jquery mysql

Explore

  • 主页
  • 问题
    • 热门问题
    • 最新问题
  • 标签
  • 帮助

Footer

RError.com

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

帮助

© 2023 RError.com All Rights Reserve   沪ICP备12040472号-5