java基于Socket做一个简单下载器_java

本文实例为大家分享了java基于Socket制作下载器的过程，及相关代码，供大家参考，具体内容如下

1.首先要建立一个服务器用来处理信息并给客户端传输文件(电脑)
 我是用电脑开了一个WIFI，手机连上后使用scoket传输的 
SERVERIP要根据自己实际情况更改。端口也可以随便更改0~65535，尽量选大一点 

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 测试Android客户端与PC服务器通过socket进行交互 服务器端：接收客户端的信息并回送给客户
 *
 * @author Ameyume
 *
 */
public class Server implements Runnable {
 //定义传输的IP和端口信息
 public static final String SERVERIP = "192.168.155.1";
 //定义的9888端口
 public static final int SERVERPORT = 9888;
 //定义文件
 private File file = null;

 public static void main(String[] args) {
 //建立调用线程执行传输的方法
 Thread desktopServerThread = new Thread(new Server());
 desktopServerThread.start();
 }

 public void run() {
 try {
  System.out.println("S: Connecting...9888");

  //创建套接字
  ServerSocket serverSocket = new ServerSocket(SERVERPORT);
  while (true) {
  // 等待接受客户端请求
  Socket client = serverSocket.accept();

  System.out.println("S: Receiving...9888");

  try {

   // 接受客户端信息
   BufferedReader in = new BufferedReader(
    new InputStreamReader(client.getInputStream()));
   System.out.println("S: 接收客户端信息");
   // 读取客户端的信息
   String str = in.readLine();
   String str1 = str.substring(0,2);
   String str2 = str.substring(2);
   System.out.println(str);
   //根据客户端的请求找到对应的文件并把文件大小的值传过去
   if (str.equals("file_size")) {

   //定义你要传输的文件（我这里写的是E盘下的某个文件）
   file = new File("E:\\某个文件");
   //输入流
   FileInputStream fis = new FileInputStream(file);
   //输出流
   BufferedInputStream bis = new BufferedInputStream(fis);
   //计算将要传输的文件大小
   int sum = bis.available();
   //将int型的文件大小转成字符串
   String s = String.valueOf(sum);
   System.out.println(s);
   //建立输出流以发送文件大小的信息
   PrintWriter out = new PrintWriter(new BufferedWriter(
    new OutputStreamWriter(client.getOutputStream())),
    true);
   //发送文件的大小信息
   out.println(s);
   //关闭流
   out.flush();
   bis.close();

   } else if (str1.equals("ok")) {
   int a = Integer.parseInt(str2);

   // 客户端收到文件大小的值后，再根据客户端传来的“ok”将文件传过去
   BufferedOutputStream bos = new BufferedOutputStream(
    client.getOutputStream());

   System.out.println("S: 开始传输");

   //开始传输
   if (true) {
    //输入流
    FileInputStream fis = new FileInputStream(file);
    //跳过前面已经传输过的字节
    fis.skip(a);
    //缓冲输入流
    BufferedInputStream bis = new BufferedInputStream(
     fis);

    int t = -1;
    while ((t = bis.read()) >= 0) {
    bos.write(t);
    }

    String s = "已传输";
    //关闭流
    bos.flush();
    bis.close();
    bos.close();
    // serverSocket.close();

    System.out.println("S: Received: '" + s + "'");
   }
   } else {
   System.out
    .println("Not receiver anything from client!");
   }
  } catch (Exception e) {
   System.out.println("S: Error 1");
   e.printStackTrace();
  } finally {
   client.close();
   System.out.println("S: Done.");
  }
  }
 } catch (Exception e) {
  System.out.println("S: Error 2");
  e.printStackTrace();
 }
 }

}

 2.再建立一个客户端，我这里用的是安卓写的MainActivity.java（我是在手机上运行的） 

package com.xhy.zz;

import android.app.Activity;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.TextView;

public class MainActivity extends Activity {

 // 定义Handler
 public static Handler myHandler;

 // 定义intent
 private Intent intent;

 // 获取控件
 private TextView text_name;
 private TextView text_percent;
 private Button btn_start;
 private Button btn_stop;

 // 文件显示
 private TextView text_sel_file;

 @Override
 protected void onCreate(Bundle savedInstanceState) {
 // TODO Auto-generated method stub
 super.onCreate(savedInstanceState);
 setContentView(R.layout.activity_main);

 text_name = (TextView) findViewById(R.id.text_name);

 text_percent = (TextView) findViewById(R.id.text_percent);

 btn_start = (Button) findViewById(R.id.btn_start);

 btn_stop = (Button) findViewById(R.id.btn_stop);

 // 按钮一的返回信息，显示进度
 myHandler = new Handler() {
  @Override
  public void handleMessage(Message msg) {
  super.handleMessage(msg);

  if (msg.what == 0x0001) {
   Bundle data = msg.getData();
   String str = data.getString("value");
   text_percent.setText(str);
  }
  }
 };
 // 显式的方式调用HelloService
 intent = new Intent(this, DownService.class);
 // 设置启动按钮点击事件
 btn_start.setOnClickListener(new OnClickListener() {
  @Override
  public void onClick(View v) {

  // 开启服务
  startService(intent);

  }
 });
 // 设置停止按钮点击事件
 btn_stop.setOnClickListener(new OnClickListener() {
  @Override
  public void onClick(View v) {
  // 关闭服务
  stopService(intent);
  }
 });

 }

 /***
 * 被调用Activity一旦返回值 该回调方法将被系统自动调用
 */
 @Override
 protected void onActivityResult(int requestCode, int resultCode,
  Intent intent) {
 super.onActivityResult(requestCode, resultCode, intent);
 // 如果请求码是0
 // 并且返回的结果码为1
 // 请求的Activity可能返回多种结果码
 if (requestCode == 0 && resultCode == 1) {
  // 取出数据
  Bundle data = intent.getExtras();
  String str = data.getString("files");
  // 显示数据
  text_sel_file.setText(str);
 }
 }

}

3.activity_main.xml文件

 <?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
  android:layout_width="match_parent"
  android:layout_height="match_parent"
  android:orientation="vertical" >

  <LinearLayout
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:layout_marginTop="20dp"
    android:orientation="horizontal" >

    <TextView
      android:id="@+id/text_name"
      android:layout_width="160dp"
      android:layout_height="wrap_content"
      android:layout_gravity="center_vertical"
      android:text="1" />

    <TextView
      android:id="@+id/text_percent"
      android:layout_width="50dp"
      android:layout_height="wrap_content"
      android:layout_gravity="center_vertical"
      android:layout_marginLeft="20dp"
      android:text="0%"/>

    <LinearLayout
      android:layout_width="wrap_content"
      android:layout_height="wrap_content"
      android:layout_marginLeft="20dp"
      android:orientation="vertical" >
      <Button
        android:id="@+id/btn_start"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="start"
        />
      <Button
        android:id="@+id/btn_stop"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="stop"
        />

    </LinearLayout>
  </LinearLayout>
</LinearLayout>

4.DownService用于在后台开启线程执行下载 

package com.xhy.zz;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.os.Bundle;
import android.os.Environment;
import android.os.IBinder;
import android.os.Message;
import android.util.Log;

public class DownService extends Service {
 private static final String TAG = "Socket_Android";

 // Preferece机制操作的文件名
 public static final String PREFERENCE_NAME = "DownService";
 // Preferece机制的操作模式
 public static int MODE = Context.MODE_PRIVATE;

 // 线程
 private Thread workThread;
 // 定义文件名
 private String filename="file";

 // 端口号
 private int port = 9888;

 private boolean isStop = false;

 /***
 * 必须要实现的方法
 */
 @Override
 public IBinder onBind(Intent intent) {
 return null;
 }

 @Override
 public void onCreate() {
 super.onCreate();

 }

 @Override
 public int onStartCommand(Intent intent, int flags, int startId) {

 Log.v("TCP", filename);
 // 建立传输的方法
 Runnable backgroundWork = new Runnable() {
  @Override
  public void run() {

   // setTitle("测试Socket连接");
   Socket socket = null;
   Socket socket1 = null;

   try {
   /*
    * 指定Server的IP地址，此地址为局域网地址，如果是使用WIFI上网，则为PC机的WIFI IP地址
    * 在ipconfig查看到的IP地址如下： Ethernet adapter 无线网络连接:
    * Connection-specific DNS Suffix . : IP Address. . . .
    * . . . . . . . . : 192.168.155.1
    */
   InetAddress serverAddr = InetAddress
    .getByName("192.168.155.1");// TCPServer.SERVERIP
   Log.d("TCP", "C: Connecting...");
   Log.d("TCP", filename + " " + port);
   // 应用Server的IP和端口建立Socket对象，向服务端发送请求获取文件大小的值
   socket1 = new Socket(serverAddr, port);
   String message = "---Test_Socket_Android---";

   Log.d("TCP", "C: Sending: '" + message + "'");

   // 将信息通过这个对象来发送给Server
   PrintWriter out = new PrintWriter(new BufferedWriter(
    new OutputStreamWriter(
     socket1.getOutputStream())), true);

   // 把用户输入的内容发送给server
   out.println("file_size");
   out.flush();

   // 接收服务器信息
   BufferedReader in = new BufferedReader(
    new InputStreamReader(socket1.getInputStream()));
   // 获取文件大小
   String str1 = in.readLine();

   Log.d("TCP", str1);
   // 将文件大小转成int型
   int sum = Integer.parseInt(str1);
   Log.d("TCP", str1);
   // 关闭输入流
   in.close();

   SharedPreferences sharedPreferences = getSharedPreferences(
    PREFERENCE_NAME, MODE);

   SharedPreferences.Editor editor = sharedPreferences
    .edit();
   //取出已经传输了的字节
   int pre = sharedPreferences.getInt("DownService", 0);
   int _pre = pre;
   //将其转化为字符串以便发送给服务端
   String s = String.valueOf(_pre);

   // 应用Server的IP和端口建立Socket对象再次向服务端发送请求，以获取文件内容
   socket = new Socket(serverAddr, port);

   // 向服务端发送请求获得文件的字符
   PrintWriter out1 = new PrintWriter(
    new BufferedWriter(new OutputStreamWriter(
     socket.getOutputStream())), true);

   out1.println("ok"+s);
   out1.flush();
   out.close();

   // 定义输入流
   BufferedInputStream bis = new BufferedInputStream(
    socket.getInputStream());

   String file1 = filename;
   String file;
   // 判断手机是否插入了SDCard，是则将文件插入内存卡
   if (Environment.getExternalStorageState().equals(
    Environment.MEDIA_MOUNTED)) {
    File sdCard = Environment
     .getExternalStorageDirectory();

    // SD卡定义文件
    file = sdCard.getCanonicalFile() + "/" + file1;
    // 定义文件输出流
    FileOutputStream fos = new FileOutputStream(file,true);
    try {
    int t = -1;
    int downloaded = pre;

    // 定义每次传输的字节数
    byte[] buff = new byte[8192];
    Log.i("sum", sum + "");
    // 开始将服务端的文件写入手机SD卡中
    while ((t = bis.read(buff)) != -1) {
     if (isStop == true) {
     break;
     }
     fos.write(buff, 0, t);
     downloaded += t;

     //将传输的进度存储起来
     editor.putInt("DownService", downloaded);
     editor.commit();

     //当传完了则把存储信息归零
     if (downloaded == sum) {
     editor.putInt("DownService", 0);
     editor.commit();
     }
     // 获得文件传输的进度
     float wb = ((downloaded * 100) / (float) sum);
     int wi = (int) wb;
     System.out.println(downloaded);
     String str = String.valueOf(wi) + "%";

     // 将文件的传输进度给送给BaseActivity,以显示给用户
     Message msg = new Message(); // 生成消息
     // 生成消息
     msg.what = 0x0001; // 设置消息类型
     // 生成Bundle携带数据
     Bundle data = new Bundle();
     data.putString("value", str);
     msg.setData(data);
     // 利用Handler发送消息
     MainActivity.myHandler.sendMessage(msg);

    }

    // 关闭输入输出流
    bis.close();
    fos.flush();
    fos.close();

    } catch (Exception e) {
    bis.close();
    fos.flush();
    fos.close();
    }
   }
   Log.d(TAG, "From server:'已接收" + "'");
   } catch (UnknownHostException e) {
   Log.e(TAG, "192.168.155.1 is unkown server!");
   } catch (Exception e) {
   e.printStackTrace();
   } finally {
   try {
    socket.close();
   } catch (Exception e) {
    e.printStackTrace();
   }
   }

  }

 };
 workThread = new Thread(backgroundWork);
 // isAlive方法用于判断workThread线程是否被开启
 if (!workThread.isAlive()) {
  // 生成新线程
  workThread.start();
  Log.v("ServiceLife", "线程开始工作");
 } else {
  Log.v("workThread", "线程已经被调用");
 }

 return START_STICKY;
 }

 @Override
 public void onDestroy() {

 super.onDestroy();
 // 利用interrupt方式中断该线程
 isStop = true;

 Log.v("ServiceLife", "onDestroy方法被调用");
 }

}

5、最后别忘了注册AndroidManifest.xml

 <uses-permission android:name="android.permission.INTERNET" />
 <uses-permission android:name="android.permission.MOUNT_UNMOUNT_FILESYSTEMS" >
 </uses-permission>
 <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" >
 </uses-permission>

 <service android:name=".DownService" ></service>

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索java
， socket
下载器
java socket简单实例、socket java 简单、简单小说下载器、java下载器、java多线程下载器，以便于您获取更多的相关知识。

时间： 2024-11-16 05:40:29

java基于Socket做一个简单下载器_java的相关文章

Java基于Socket的文件传输实现方法_java

本文实例讲述了Java基于Socket的文件传输实现方法.分享给大家供大家参考,具体如下: 1. Java代码如下: package sterning; import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.net.Ser

Java基于socket实现简易聊天室实例_java

本文实例讲述了Java基于socket实现简易聊天室的方法.分享给大家供大家参考.具体实现方法如下: chatroomdemo.java package com.socket.demo; import java.io.IOException; import java.net.DatagramSocket; public class ChatRoomDemo { /** * @param args * @throws IOException */ public static void main(S

用Flex3.0 做一个简单Flv 播放器

今天早上, 以前高中同学要我教他用 Flex 写一个flv播放器. 网上应该也有不少的教程了, 但中午吃完饭后, 觉得自己写写也不错, 毕竟自己很少在自己博客上写教程, 于是就写写了..... 有错误请高手指出..以下为我今天写在博客上的一篇简单教程: 用 AS2.0 做的 flv 播放器不少了, Flex 3.0 早期又出了, 就尝试着做一个 flv 播放器. 用 Flex3.0 写出来的东西, 本人觉得, 其产物可以是 flex , 也可以是 AIR ( 早期的Apollo ).  好了,

java web新闻管理系统-谁用java web做一个简单的新闻管理系统啊，急用！！！

问题描述 谁用java web做一个简单的新闻管理系统啊,急用!!! 增删改,分页,有前台和后台.后台就是管理员的增删改,前台就是显示新闻的标题和内容.用oracle数据库链接.有的请发在我邮箱825091682@qq.com.谢谢了 解决方案 smarty实现简单的新闻管理系统smarty实现简单新闻管理系统 解决方案二: 不用框架,仅用java web

c#做一个简单的视频播发器 都用什么控件啊

问题描述 我是一个人新手做一个简单的视屏播放器但是我不知道该从什么地方开始下手用什么控件虚心求教 解决方案 解决方案二:视频播放器的com组件,例如windowsmideaplayer解决方案三:支持1楼的呢帮顶解决方案四:windowsmideaplayer记载迅雷看看播放器.参考解决方案五:楼主你需要在项目内引用一个windowsmideaplayer然后在工具箱里拖动出来就可以实现了,windowsmideaplayer内有个URL连接源就可以了哦!解决方案六:看你要播放什么了.如果是播放

网站-用JAVA语言如何做一个服务器

问题描述 用JAVA语言如何做一个服务器 我要做一个网站,接收终端机发来的信息并且处理,再发数据给终端机,这样该怎么做 解决方案 java开发网站后台服务器端,看你的规模了. 如果网页简单你就直接使用这个Servlet进行开发就可以了. 很方便就可以实现了. 如果比较复杂,那你就考虑使用框架吧. 使用SSH或者是SSI框架组合进行开发. 假定你已经想好了你的网站的访问Url,业务处理方法,以及你存储数据的数据库的设计都OK,制作流程大致如下 (如果没有,你先从纸面分析设计下你的系统都有什么功能(

做一个简单的VC++的mfc单文档应用程序

问题描述 做一个简单的VC++的mfc单文档应用程序 帮忙做一个基于VC++6.0的mfc单文档应用程序(绘图),有菜单栏工具栏和快捷菜单,用到分割窗口,组合框,文档序列化 解决方案 google Scribble 示例:MDI 绘图应用程序 解决方案二: 就你的需求,不要写一行程序,用向导生成,勾选切分视图和从CFormView继承,放上组合框就好了.文档序列化是默认支持的. 解决方案三: 解决方案四: 如果你要画图,可以直接下载msdn里面切分视图画图的那个例子,然后加上一个controlb

Android基于socket实现的简单C/S聊天通信功能_Android

本文实例讲述了Android基于socket实现的简单C/S聊天通信功能.分享给大家供大家参考,具体如下: 主要想法:在客户端上发送一条信息,在后台开辟一个线程充当服务端,收到消息就立即回馈给客户端. 第一步:创建一个继续Activity的SocketClientActity类,包为com.pku.net 编写布局文件socketclient.xml,代码如下: <?xml version="1.0" encoding="utf-8"?> <Lin

Android基于socket实现的简单C/S聊天通信功能

本文实例讲述了Android基于socket实现的简单C/S聊天通信功能.分享给大家供大家参考,具体如下: 主要想法:在客户端上发送一条信息,在后台开辟一个线程充当服务端,收到消息就立即回馈给客户端. 第一步:创建一个继续Activity的SocketClientActity类,包为com.pku.net 编写布局文件socketclient.xml,代码如下: <?xml version="1.0" encoding="utf-8"?> <Lin