24小时热门版块排行榜    

查看: 656  |  回复: 2

zhanglinfeng

新虫 (小有名气)

[求助] Tcp

今天晚上对着书编了一个Tcp服务器和客户端,可客户端接不了服务器发送的数据,请问是怎么回事?小弟是新手,代码组织的不好,麻烦各位不耐其烦,帮帮忙!谢谢
附上代码:
服务器代码:
import java.io.*;
import java.net.*;
public class TcpServer {
        public static String str = null ;
        public static         boolean bl = true ;
        public static BufferedReader bfd = null ;
        public static BufferedReader bd = null ;
        public static OutputStream os = null;
        /**
         * Method main
         *
         *
         * @param args
         *
         */
        public static void main(String[] args) {
                // TODO: 在这添加你的代码
                try
                {
                        ServerSocket ss = new ServerSocket(8001);
                        Socket s = ss.accept();
                       
                        InputStream is = s.getInputStream();
                        os = s.getOutputStream();
                       
                        os.write("welcome to my domitory".getBytes());
                       
                        bfd = new BufferedReader(new InputStreamReader(System.in));
                       
                        /*byte [] buf = new byte[1024];
                       
                        int len = is.read(buf);*/
               
                        bd = new BufferedReader(new InputStreamReader(is));

                                //os.write("welcome to my domitory".getBytes());

                       
                        class Send implements Runnable
                        {
                                public void run()
                                {
                                        while(bl)
                                        {
                                                try
                                                {
                                                        System.out.println(bd.readLine());
                                                }
                                                catch(Exception e)
                                                {
                                                        e.printStackTrace();
                                                }
                                        }
                                }
                        }
                       
                        class Reserve implements Runnable
                        {
                                public void run()
                                {
                                        while(bl)
                                        {
                                                try
                                                {
                                                        //if(bfd.ready())
                                                        //{
                                                                str = bfd.readLine();
                                                                os.write(str.getBytes());
                                                        //}
                                                       
                                                }
                                                catch(Exception ex)
                                                {
                                                        ex.printStackTrace();
                                                }
                                        }
                                       
                                }
                        }
                        new Thread(new Send()).start();
                        new Thread(new Reserve()).start();
                /*        os.close();
                        bd.close();
                        s.close();
                        ss.close();*/
                }
                catch(Exception e)
                {
                        e.printStackTrace();
                }

        }       
}

客户端代码:
import java.net.*;
import java.io.*;
class TcpClient
{
        public static Socket s = null ;
        public static OutputStream ops = null ;
        public static InputStream ips = null ;
        public static BufferedReader bfd = null ;
        public static BufferedReader br = null ;
        public static PrintStream ps = null ;
        public static void main(String [] args)
        {
                try
                {
                        s = new Socket("59.69.109.90",8001) ;
               
                        //get stream
                       
                        ops = s.getOutputStream();
                        ips = s.getInputStream() ;
                       
                        br = new BufferedReader(new InputStreamReader(ips));
                        ps = new PrintStream(ops,true);
                       
                        //get keyboard stream
                        bfd = new BufferedReader(new InputStreamReader(System.in));
                       
                       
                        class Send implements Runnable
                        {
                                public void run()
                                {
                                        while(true)
                                        {
                                                try
                                                {
                                               
                                                        String str = bfd.readLine();
                                                        ps.println(str);
                                                        if(str.equals("quit")
                                                        {
                                                                break;
                                                        }
                                                }
                                                catch(Exception ex)
                                                {
                                                        ex.printStackTrace();
                                                }
                                        }
                                }
                        }
                       
                        class Receive implements Runnable
                        {
                                public void run()
                                {
                                        while(true)
                                        {
                                                        try
                                                        {
                                                                //BufferedReader br = new BufferedReader(new InputStreamReader(ips));
                                                                String str = br.readLine();
                                                                //System.out.println(str);
                                                                //ps.println(str);
                                                                ops.write(str.getBytes());
                                                                if(str.equals("quit")
                                                                {
                                                                        break;
                                                                }
                                                        }
                                                        catch(Exception ex1)
                                                        {
                                                                ex1.printStackTrace();
                                                        }
                                        }
                                }
                        }

                        /*bfd.close();
                        br.close();
                        ps.close();
                        s.close();*/
                       
                        new Thread(new Send()).start();
                        new Thread(new Receive()).start();
                }
                catch(Exception e)
                {
                        e.printStackTrace();
                }       
        }
}
回复此楼
已阅   回复此楼   关注TA 给TA发消息 送TA红花 TA的回帖

liu2012huan

铜虫 (正式写手)

【答案】应助回帖


jjdg: 金币+1, 感谢指点 2012-12-09 01:28:45
s = new Socket("59.69.109.90",8001) ;  你这个的Ip是哪个的?在本机上测试 用 127.0.0.1   别告诉我你的这个Ip是网络上显示的?  那个不是你的局域网的IP  在本机上测试就用 127.0.0.1
图像检索,图像处理,机器学习。
2楼2012-12-08 19:40:56
已阅   回复此楼   关注TA 给TA发消息 送TA红花 TA的回帖

tsplaycool

新虫 (初入文坛)

2楼已经解答完毕
3楼2012-12-24 23:09:57
已阅   回复此楼   关注TA 给TA发消息 送TA红花 TA的回帖
相关版块跳转 我要订阅楼主 zhanglinfeng 的主题更新
最具人气热帖推荐 [查看全部] 作者 回/看 最后发表
[基金申请] 今天放榜吗? +7 布布和一二 2026-08-19 7/350 2026-08-19 09:17 by 陈晨晨陈啊
[基金申请] 朋友圈看到的 +5 wangzilk 2026-08-18 6/300 2026-08-19 08:05 by luw152
[基金申请] 不应该看fileCode +8 且听虎啸 2026-08-12 10/500 2026-08-19 08:03 by luw152
[基金申请] 结合人工智能,周易传统文化,filecode打分制来了,3分以上希望很大。 +4 Tide man 2026-08-12 5/250 2026-08-19 07:41 by 201120518022
[基金申请] 重要消息,中午系统在维护 +10 yuleib84 2026-08-18 11/550 2026-08-19 07:30 by 羽毛枫f
[教师之家] 为什么余额宝的年化利率越来越低?主要原因有哪些? +3 瞬息宇宙 2026-08-15 3/150 2026-08-18 21:40 by xiaohuixin
[基金申请] 2027广东省杰青 +3 奶牛小黑 2026-08-15 9/450 2026-08-18 20:09 by 奶牛小黑
[基金申请] 明天放榜? +5 Shxjjxjkx 2026-08-18 5/250 2026-08-18 18:14 by -大大大大大-
[基金申请] 时间戳变了,能看出什么问题? +8 基诺咪客 2026-08-17 11/550 2026-08-18 17:13 by 悠然熊猫
[论文投稿] 投稿咨询 +4 wwm09 2026-08-17 6/300 2026-08-18 15:36 by wwm09
[基金申请] 时间戳又变了8-15 +14 archvillain 2026-08-15 26/1300 2026-08-18 13:37 by phantomgost
[基金申请] 今天维护系统维护 祝所有人 高中 +8 gjjjzhong 2026-08-18 9/450 2026-08-18 13:01 by 家与远方
[基金申请] 哪位老哥知道今年的国自然具体哪一天放榜? +13 Ldrop2023 2026-08-13 16/800 2026-08-18 12:25 by 淀粉搬运工
[基金申请] 快农历七夕节了,轻松一下,男人悄悄话,女施主请不要进来。 +4 Tide man 2026-08-14 5/250 2026-08-18 11:35 by Tide man
[基金申请] 93BebMhtakh前后11位开头都是大写 +4 且听虎啸 2026-08-17 5/250 2026-08-18 00:49 by 蔡棒棒菂
[基金申请] 感觉是下周放榜了 +6 angus9576 2026-08-17 11/550 2026-08-17 23:57 by angus9576
[基金申请] 今天系统多次维护,明天很可能放榜! +8 zju2000 2026-08-16 9/450 2026-08-17 12:20 by lmz0216
[精细化工] 招聘 金属平磨液,抛光液研发工程师 +3 小天0311 2026-08-14 3/150 2026-08-16 07:31 by H9PLUS
[基金申请] 重要来源:本周末出结果 +10 瞬息宇宙 2026-08-12 10/500 2026-08-13 15:46 by likettle
[基金申请] Filecode 又变了,巨变 +3 WH3796 2026-08-12 4/200 2026-08-13 14:13 by 小木虫6752397
信息提示
请填处理意见