devbox
从前慢现在也慢
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用Android完成案例教学

作者：从前慢现在也慢 | 2024-04-13 03:31:34

赞

踩

使用Android完成案例教学

目录

题目：完成在Android平台下2个玩家分别利用2个手机连接在同一局域网下通过滑动摇杆分别使红飞机和黄飞机移动的开发。（全代码解析）

题目：完成在Android平台下2个玩家分别利用2个手机连接在同一局域网下通过滑动摇杆分别使红飞机和黄飞机移动的开发。（全代码解析）

用一个真机运行，连接此电脑 的模拟机进行利用2个手机连接在同一局域网下通过滑动摇杆分别使红飞机和黄飞机移动的开发

运行结果： 

模拟机：

真机：

DrawThread.java代码：
  1. package com.example.client.thread;
  2.  
  3. import com.example.clinet.view.GameView;
  4.  
  5. import android.annotation.SuppressLint;
  6. import android.graphics.Canvas;
  7. import android.view.SurfaceHolder;
  8.  
  9. public class DrawThread extends Thread
  10. {
  11.     private int SLEEP_SPAN =50;//睡眠的毫秒数
  12.     private SurfaceHolder surfaceHolder;
  13.     private GameView view;
  14.     private boolean flag = true;
  15.     public DrawThread(SurfaceHolder surfaceHolder, GameView view) {//构造器
  16.         this.surfaceHolder = surfaceHolder;
  17.         this.view = view;
  18.     }
  19.     public void setFlag(boolean flag) {//设置循环标记位
  20.         this.flag = flag;
  21.     }
  22.     @SuppressLint("WrongCall")
  23.     public void run()
  24.     {
  25.         Canvas c;
  26.         while(flag)
  27.         {
  28.             c = null;
  29.             try
  30.             {// 锁定整个画布，在内存要求比较高的情况下，建议参数不要为null
  31.                 c = this.surfaceHolder.lockCanvas(null);
  32.                 synchronized (this.surfaceHolder)
  33.                 {
  34.                     this.view.onDraw(c);
  35.                 }
  36.             } finally
  37.             {
  38.                 if (c != null)
  39.                 {
  40.                     //更新屏幕显示内容
  41.                     this.surfaceHolder.unlockCanvasAndPost(c);
  42.                 }
  43.             }
  44.             try
  45.             {
  46.                 Thread.sleep(SLEEP_SPAN);//睡眠指定毫秒数
  47.             }
  48.             catch(Exception e)
  49.             {
  50.                 e.printStackTrace();
  51.             }
  52.         }
  53.     }
  54. }

KeyThread.java代码：
  1. package com.example.client.thread;
  2.  
  3. import com.example.client.MainActivity;
  4. import com.example.util.GameData;
  5.  
  6.  
  7. public class KeyThread extends Thread
  8. {
  9. 	int SPAN_SLEEP=10;
  10. 	MainActivity father;
  11. 	boolean flag=true;
  12.  
  13. 	public KeyThread(MainActivity father)
  14. 	{
  15. 		this.father=father;
  16. 	}
  17.  
  18. 	public void run()
  19. 	{
  20. 		while(flag)
  21. 		{
  22.  
  23. 			try
  24. 			{
  25. 				if(GameData.state==2)
  26. 				{
  27. 					father.nt.dout.writeUTF("<#KEY#>"+father.KeyDispX+"|"+father.KeyDispY);
  28. 				}
  29. 				Thread.sleep(SPAN_SLEEP);
  30.  
  31. 			}
  32. 			catch(Exception e)
  33. 			{
  34. 				e.printStackTrace();
  35. 			}
  36. 		}
  37. 	}
  38. }
更改自己电脑上的IP地址，win+R输入cmd,然后输入ipconfig命令获取此电脑的IP地址，NetworkThread.java代码如下：
  1. package com.example.client.thread;
  2.  
  3. import android.util.Log;
  4.  
  5. import java.io.DataInputStream;
  6. import java.io.DataOutputStream;
  7. import java.net.Socket;
  8. import com.example.client.MainActivity;
  9. import com.example.util.GameData;
  10.  
  11. public class NetworkThread extends Thread{
  12. 	MainActivity activity;
  13. 	Socket sc;
  14. 	DataInputStream din;
  15. 	DataOutputStream dout;
  16. 	public boolean flag=true;
  17. 	public NetworkThread(MainActivity activity)
  18. 	{
  19. 		this.activity=activity;
  20. 	}
  21. 	public void run()
  22. 	{
  23. 		try
  24. 		{//与服务端建立连接 ,参数分别是要连接的服务端IP地址和要连接的服务端对应的监听端口
  25. 			Log.i("测试", "run: 开始连接");
  26. 			sc=new Socket("192.168.43.252",9999);
  27. 			din=new DataInputStream(sc.getInputStream());
  28. 			dout=new DataOutputStream(sc.getOutputStream());
  29. 			dout.writeUTF("<#CONNECT#>");
  30. 			Log.i("测试", "run: 完成连接");
  31. 		}
  32. 		catch(Exception e)
  33. 		{
  34. 			Log.e("测试", "run: 执行失败",e );
  35. 			e.printStackTrace();
  36. 			return;
  37. 		}
  38. 		while(flag)
  39. 		{
  40. 			try
  41. 			{
  42. 				String msg=din.readUTF();
  43. 				if(msg.startsWith("<#OK#>"))
  44. 				{
  45. 					System.out.println("Connect ok...");
  46. 					GameData.state=1;
  47. 				}
  48. 				else if(msg.startsWith("<#BEGIN#>"))
  49. 				{
  50. 					GameData.state=2;
  51. 					this.activity.kt.start();
  52. 				}
  53. 				else if(msg.startsWith("<#FULL#>"))
  54. 				{
  55. 					System.out.println("Full...");
  56. 					break;
  57. 				}
  58. 				else if(msg.startsWith("<#GAME_DATA#>"))
  59. 				{
  60. 					String nr=msg.substring(13);
  61. 					String[] strA=nr.split("\\|");
  62. 					int temprx=Integer.parseInt(strA[0]);
  63. 					int tempry=Integer.parseInt(strA[1]);
  64. 					int tempgx=Integer.parseInt(strA[2]);
  65. 					int tempgy=Integer.parseInt(strA[3]);
  66. 					synchronized(this.activity.gd.lock)
  67. 					{
  68. 						this.activity.gd.rx=temprx;
  69. 						this.activity.gd.ry=tempry;
  70. 						this.activity.gd.gx=tempgx;
  71. 						this.activity.gd.gy=tempgy;
  72. 					}
  73. 				}
  74. 			}catch(Exception e)
  75. 			{
  76. 				e.printStackTrace();
  77. 			}
  78. 		}
  79.  
  80. 		try
  81. 		{
  82. 			din.close();
  83. 			dout.close();
  84. 			sc.close();
  85. 		}catch(Exception e)
  86. 		{
  87. 			e.printStackTrace();
  88. 		}
  89. 	}
  90. }

MainActivity.Java代码：
  1. package com.example.client;
  2.  
  3. import com.example.client.thread.KeyThread;
  4. import com.example.client.thread.NetworkThread;
  5. import com.example.clinet.view.GameView;
  6. import com.example.util.GameData;
  7. import android.os.Bundle;
  8. import android.view.Menu;
  9. import android.view.MenuItem;
  10. import android.app.Activity;
  11. import android.graphics.Bitmap;
  12. import android.graphics.BitmapFactory;
  13.  
  14. public class MainActivity extends Activity {
  15. 	public int KeyDispX=0;//方向x
  16. 	public int KeyDispY=0;//方向y
  17.  
  18. 	public Bitmap planer;
  19. 	public Bitmap planeg;
  20. 	public GameData gd=new GameData();
  21. 	public KeyThread kt=new KeyThread(this);
  22. 	public 	NetworkThread nt;
  23. 	GameView gv;
  24.  
  25.  
  26.  
  27. 	@Override
  28. 	protected void onCreate(Bundle savedInstanceState) {
  29. 		super.onCreate(savedInstanceState);
  30. 		setContentView(R.layout.main);
  31.  
  32. 		planer=BitmapFactory.decodeResource(getResources(), R.drawable.red);//红飞机
  33. 		planeg=BitmapFactory.decodeResource(getResources(), R.drawable.yellow);//黄飞机
  34.  
  35. 		gv=(GameView)this.findViewById(R.id.mf1);
  36. 	}
  37.  
  38. 	@Override
  39. 	public boolean onCreateOptionsMenu(Menu menu)
  40. 	{
  41. 		//调用Activity的getMenuInflater()得到一个MenuInflater，
  42. 		//使用inflate方法来把布局文件中的定义的菜单 加载给 第二个参数所对应的menu对象
  43.  
  44. 		getMenuInflater().inflate(R.menu.activity_main, menu);
  45. 		return true;
  46. 	}
  47. 	@Override
  48. 	public boolean onOptionsItemSelected(MenuItem item) {
  49. 		if(item.getItemId()==R.id.menu_connect)
  50. 		{
  51. 			if(this.nt==null)
  52. 			{
  53. 				this.nt=new NetworkThread(MainActivity.this);
  54. 				this.nt.start();
  55. 			}
  56.  
  57.  
  58. 		}
  59. 		return true;
  60. 	}
  61. }
ServerAgentThread.java代码如下：

  1. package com.example.util;
  2.  
  3. import java.io.*;
  4. import java.net.*;
  5. import java.util.*;
  6.  
  7. public class ServerAgentThread extends Thread
  8. {
  9. 	//�ͻ��˼�����
  10. 	static int count=0;
  11. 	//�ͻ����б�
  12. 	static List<ServerAgentThread> ulist=new ArrayList<ServerAgentThread>();
  13. 	//ȫ������
  14. 	static int rx=150;
  15. 	static int ry=750;
  16. 	static int gx=460;
  17. 	static int gy=750;
  18. 	//��������
  19. 	static Queue<Action> aq=new LinkedList<Action>();
  20. 	//����������
  21. 	static Object lock=new Object();
  22. 	
  23. 	Socket sc;
  24. 	DataInputStream din;
  25. 	DataOutputStream dout;
  26. 	int redOrYellow;
  27. 	boolean flag=true;
  28. 	
  29. 	public static void broadcastState()
  30. 	{
  31. 		for(ServerAgentThread sa:ulist)
  32. 		{
  33. 			try
  34. 			{
  35. 				sa.dout.writeUTF("<#GAME_DATA#>"+rx+"|"+ry+"|"+gx+"|"+gy);
  36. 			}
  37. 			catch(Exception e)
  38. 			{
  39. 				e.printStackTrace();
  40. 			}
  41. 		}
  42. 	}
  43. 	
  44. 	public ServerAgentThread(Socket sc)
  45. 	{
  46. 		this.sc=sc;
  47. 		try
  48. 		{
  49. 			din=new DataInputStream(sc.getInputStream());
  50. 			dout=new DataOutputStream(sc.getOutputStream());
  51. 		}
  52. 		catch(Exception e)
  53. 		{
  54. 			e.printStackTrace();
  55. 		}
  56. 	}
  57. 	
  58. 	public void run()
  59. 	{
  60. 		while(flag)
  61. 		{
  62. 			try
  63. 			{
  64. 				String msg=din.readUTF();
  65. 				if(msg.startsWith("<#CONNECT#>"))
  66. 				{
  67. 					if(count==0)
  68. 					{
  69. 						dout.writeUTF("<#OK#>");
  70. 						redOrYellow=0;
  71. 						ulist.add(this);
  72. 						count++;
  73. 						System.out.println("==red connect...");
  74. //						for(ServerAgentThread sa:ulist)
  75. //						{
  76. //							sa.dout.writeUTF("<#BEGIN#>");
  77. //						}
  78. 					}
  79. 					else if(count==1)
  80. 					{
  81. 						dout.writeUTF("<#OK#>");
  82. 						redOrYellow=1;
  83. 						ulist.add(this);
  84. 						count++;
  85. 						System.out.println("==yellow connect...");
  86. 						
  87. 						for(ServerAgentThread sa:ulist)
  88. 						{
  89. 							sa.dout.writeUTF("<#BEGIN#>");
  90. 						}
  91. 					}
  92. 					else
  93. 					{
  94. 						dout.writeUTF("<#FULL#>");
  95. 						break;
  96. 					}
  97. 				}
  98. 				else if(msg.startsWith("<#KEY#>"))
  99. 				{
  100. 					String iStr=msg.substring(7);
  101. 					String[] str=iStr.split("\\|");
  102. 					synchronized(lock)
  103. 					{//���¶����������
  104. 						aq.offer(new Action(this.redOrYellow,Integer.parseInt(str[0]),Integer.parseInt(str[1])));
  105. 					}
  106. 				}
  107. 			}
  108. 			catch(Exception e)
  109. 			{
  110. 				e.printStackTrace();
  111. 			}
  112. 		}
  113. 		try
  114. 		{
  115. 			din.close();
  116. 			dout.close();
  117. 			sc.close();
  118. 		}
  119. 		catch(Exception e)
  120. 		{
  121. 			e.printStackTrace();
  122. 		}
  123. 	}
  124. }
Joystick.java代码：
  1. package com.example.util;
  2.  
  3. import com.example.client.MainActivity;
  4. import com.example.client.R;
  5. import com.example.clinet.view.GameView;
  6.  
  7. import static com.example.util.Constant.*;
  8. import android.graphics.BitmapFactory;
  9. import android.graphics.Canvas;
  10.  
  11. public class Joystick
  12. {
  13. 	public MainActivity activity;
  14. 	public GameView view;
  15. 	public int length;
  16. 	public float x;
  17. 	public float y;
  18. 	public Joystick( GameView view,MainActivity activity,float x,float y)
  19. 	{
  20. 		this.view=view;
  21. 		this.activity=activity;
  22. 		this.x=x;
  23. 		this.y=y;
  24. 	}
  25.  
  26. 	public void drawJoystick(Canvas canvas)
  27. 	{
  28. 		canvas.drawBitmap(BitmapFactory.decodeResource(this.activity.getResources(),R.drawable.yaogan1),
  29. 				JK_Start_x,JK_Start_y, null);
  30. 		canvas.drawBitmap(BitmapFactory.decodeResource(this.activity.getResources(),R.drawable.yaogan2),
  31. 				x,y,null);
  32. 	}
  33.  
  34.  
  35. 	public boolean change(float x,float y)
  36. 	{
  37. 		length=getLength(this.view.pCenter.x,this.view.pCenter.y, x,y);
  38. 		if(length>radio)
  39. 		{//如果手指触点不在大环范围内
  40. 			return false;
  41. 		}
  42. 		else if(length<radio)
  43. 		{ //如果手指在摇杆活动范围内，则摇杆处于手指触摸位置
  44. 			this.view.mJoystick.x=x;
  45. 			this.view.mJoystick.y=y;
  46. 		}
  47. 		else
  48. 		{//设置摇杆位置，使其处于手指触摸方向的 摇杆活动范围边缘
  49. 			float angle=getRadian(this.view.pCenter.x,this.view.pCenter.y, x, y);
  50. 			this.view.mJoystick.x=(int)(this.view.pCenter.x+radio* Math.cos(angle));
  51. 			this.view.mJoystick.y=(int)(this.view.pCenter.y+radio*Math.sin(angle));
  52. 		}
  53. 		//方向
  54. 		this.activity.KeyDispX=(int) (x-this.view.pCenter.x);//x偏移量
  55. 		this.activity.KeyDispY=(int) (y-this.view.pCenter.y);//y偏移量
  56. 		return true;
  57. 	}
  58. }

 Action.java代码：

  1. package com.example.util;
  2.  
  3. public class Action 
  4. {
  5. 	int redOrYellow;//0-red 1-green	
  6. 	float keyX;
  7. 	float keyY;
  8. 	int span=20;//�ƶ�����
  9. 	
  10. 	public Action(int redOrYellow,float keyX,float keyY)
  11. 	{
  12. 		this.redOrYellow=redOrYellow;
  13. 		this.keyX=keyX;
  14. 		this.keyY=keyY;
  15. 	}
  16. 	
  17. 	public void doAction()
  18. 	{		
  19. 		float xx=0;
  20. 		float yy=0;
  21. 		if(Math.sqrt(keyX*keyX+keyY*keyY)!=0)
  22. 		{//ת��Ϊ��λ����ֵ
  23. 			xx= (float) (keyX/Math.sqrt(keyX*keyX+keyY*keyY));
  24. 			yy=(float) (keyY/Math.sqrt(keyX*keyX+keyY*keyY));
  25. 		}
  26. 		if(redOrYellow==0)
  27. 		{//��
  28. 			if(ServerAgentThread.ry+yy*span>=0&&ServerAgentThread.ry+yy*span<=1100)
  29. 			{//���÷ɻ��ƶ���Χ
  30. 				ServerAgentThread.ry+=yy*span;
  31. 			}			
  32. 			if(ServerAgentThread.rx+xx*span>=0&&ServerAgentThread.rx+xx*span<=600)
  33. 			{
  34. 				ServerAgentThread.rx+=xx*span;
  35. 			}
  36. 		}
  37. 		else
  38. 		{//��
  39. 			if(ServerAgentThread.gy+yy*span>=0&&ServerAgentThread.gy+yy*span<=1100)
  40. 			{//���÷ɻ��ƶ���Χ
  41. 				ServerAgentThread.gy+=yy*span;
  42. 			}		
  43. 			if(ServerAgentThread.gx+xx*span>=0&&ServerAgentThread.gx+xx*span<=600)
  44. 			{
  45. 				ServerAgentThread.gx+=xx*span;
  46. 			}
  47. 		}
  48. 		
  49. 	}
  50. }
ActionThread.java代码：
  1. package com.example.util;
  2.  
  3. public class ActionThread extends Thread
  4. {
  5. 	static final int SLEEP=5;
  6. 	boolean flag=true;
  7. 		
  8. 	public void run()
  9. 	{
  10. 		while(flag)
  11. 		{
  12. 			Action a=null;
  13. 			
  14. 			synchronized(ServerAgentThread.lock)
  15. 			{
  16. 				//��ȡ���Ƴ�����Ԫ��
  17. 				a=ServerAgentThread.aq.poll();
  18. 			}
  19. 			if(a!=null)
  20. 			{
  21. 				a.doAction();
  22. 				ServerAgentThread.broadcastState();	
  23. 			}
  24. 			else
  25. 			{
  26. 				try
  27. 				{
  28. 					Thread.sleep(SLEEP);
  29. 				}
  30. 				catch(Exception e)
  31. 				{
  32. 					e.printStackTrace();
  33. 				}
  34. 			}
  35. 		}
  36. 	}
  37. }
Constant.java代码：
  1. package com.example.util;
  2.  
  3. public class Constant {
  4.  
  5. 	public static final int radio=80;//半径
  6. 	public static final int JK_Start_x=30;//摇杆大环起点x
  7. 	public static final int JK_Start_y=830;//摇杆大环起点y
  8. 	public static final int  xJoystick=100;//摇杆小环x
  9. 	public static final int  yJoystick=900;//摇杆小环y
  10.  
  11.  
  12. 	//获取水平线夹角弧度
  13. 	public static float getRadian (float x1,float y1,float x2,float y2)
  14. 	{
  15. 		float lenA=x2-x1;
  16. 		float lenB=y2-y1;
  17. 		float lenC=(float) Math.sqrt(lenA*lenA+lenB*lenB);
  18. 		float angle=(float)Math.acos(lenA/lenC);
  19. 		angle=angle*(y2<y1?-1:1);
  20. 		return angle;
  21. 	}
  22.  
  23. 	//获取长度
  24. 	public static int getLength(float centerX,float centerY,float x,float y)
  25. 	{
  26. 		int result=(int)Math.sqrt(Math.pow(x-centerX, 2)+Math.pow(y-centerY, 2));
  27. 		return result;
  28. 	}
  29. }

GameData.java代码;
  1. package com.example.util;
  2.  
  3. public class GameData {
  4. 	public static int state=0;//0--未连接  1---成功连接  2--游戏开始
  5.  
  6. 	public Object lock=new Object();
  7.  
  8. 	public int rx=150;
  9. 	public int ry=750;
  10. 	public int gx=460;
  11. 	public int gy=750;
  12. }
启动ServerThread.java代码：
  1. package com.example.util;
  2. import java.net.*;
  3.  
  4. public class ServerThread extends Thread
  5. {
  6. 	boolean flag=false;
  7. 	ServerSocket ss;
  8. 	
  9. 	public void run()
  10. 	{
  11. 		try
  12. 		{
  13. 			ss=new ServerSocket(9999);
  14. 			System.out.println("Server Listening on 9999...");
  15. 			flag=true;
  16. 			new ActionThread().start();
  17. 		}
  18. 		catch(Exception e)
  19. 		{
  20. 			e.printStackTrace();
  21. 		}
  22. 		
  23. 		while(flag)
  24. 		{
  25. 			try
  26. 			{
  27. 				Socket sc=ss.accept();
  28. 				System.out.println(sc.getInetAddress()+" connect...");
  29. 				new ServerAgentThread(sc).start();
  30. 			}
  31. 			catch(Exception e)
  32. 			{
  33. 				e.printStackTrace();
  34. 			}
  35. 		}
  36. 	}
  37. 	
  38. 	public static void main(String args[])
  39. 	{
  40. 		new ServerThread().start();
  41. 	}
  42. }

 main.xml代码如下：

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     android:layout_width="match_parent"
  4.     android:layout_height="match_parent"
  5.     android:orientation="vertical" >
  6.     <com.example.clinet.view.GameView
  7.         android:id="@+id/mf1"
  8.         android:layout_width="fill_parent"
  9.         android:layout_height="wrap_content"
  10.         />
  11.  
  12. </LinearLayout>

 今天就分享到这里，感谢预览~

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/414193
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号